Index

A

active (kafka_overwatch.specs.report.ConsumerGroups attribute) aiven (kafka_overwatch.specs.config.Providers attribute) allow_create (kafka_overwatch.specs.config.KafkaServiceAccount attribute) api_key (kafka_overwatch.specs.config.ConfluentCloudAuth attribute) api_secret (kafka_overwatch.specs.config.ConfluentCloudAuth attribute) assign_sns_channels() (kafka_overwatch.overwatch_resources.clusters.KafkaCluster method) AssumeRole (class in kafka_overwatch.specs.config) (kafka_overwatch.specs.config.Iam attribute)

aws_emf (kafka_overwatch.specs.config.ClusterMetrics attribute) (kafka_overwatch.specs.config.KafkaOverwatchInputConfiguration attribute) aws_msk (kafka_overwatch.specs.config.Providers attribute) aws_secrets_manager (kafka_overwatch.specs.config.SaveCredentials attribute) AwsEmf (class in kafka_overwatch.specs.config) AwsEmfModel (class in kafka_overwatch.specs.config) AwsGlueSchemaRegistry (class in kafka_overwatch.specs.config)

B

backup() (kafka_overwatch.overwatch_resources.schema_registry.SchemaRegistry method) backup_config (kafka_overwatch.specs.config.SchemaRegistry attribute) backup_interval_seconds (kafka_overwatch.specs.config.BackupConfig attribute) backup_schema_registry_subjects() (in module kafka_overwatch.processing.schema_registries) BackupConfig (class in kafka_overwatch.specs.config)

BackupStyle (class in kafka_overwatch.specs.config) BackupStyles (kafka_overwatch.specs.config.ClusterTopicBackupConfig attribute) basic_auth (kafka_overwatch.specs.config.ConfluentSchemaRegistry attribute) BasicAuth (class in kafka_overwatch.specs.config) BasicAuthCreds (class in kafka_overwatch.overwatch_resources.schema_registry) bucket_name (kafka_overwatch.specs.config.S3Output attribute)

C

cfn_kafka_admin (kafka_overwatch.specs.config.BackupStyle attribute) check_replace_kafka_clients() (kafka_overwatch.overwatch_resources.clusters.KafkaCluster method) cleanup() (kafka_overwatch.overwatch_resources.topics.Partition method) client (kafka_overwatch.aws_helpers.s3.S3Handler property) cluster (kafka_overwatch.overwatch_resources.topics.Topic property) (kafka_overwatch.specs.report.ClusterUsageReportStructure attribute) cluster_arn (kafka_overwatch.specs.config.MskClusterConfig attribute) cluster_config (kafka_overwatch.specs.config.ClusterConfiguration attribute) cluster_config_auth (kafka_overwatch.specs.config.ClusterConfig attribute) cluster_name (kafka_overwatch.specs.report.ClusterReport attribute) cluster_percentage (kafka_overwatch.specs.report.TopicWasteCategory attribute) cluster_scan_interval_in_seconds (kafka_overwatch.specs.config.ClusterConfiguration attribute) (kafka_overwatch.specs.config.Global attribute) ClusterConfig (class in kafka_overwatch.specs.config) ClusterConfigAuth (class in kafka_overwatch.specs.config) ClusterConfiguration (class in kafka_overwatch.specs.config) ClusterMetrics (class in kafka_overwatch.specs.config) ClusterReport (class in kafka_overwatch.specs.report) ClusterReportingNotificationChannels (class in kafka_overwatch.specs.config) ClusterReportSnsChannel (class in kafka_overwatch.specs.config) clusters (kafka_overwatch.specs.config.KafkaOverwatchInputConfiguration attribute)

ClusterTopicBackupConfig (class in kafka_overwatch.specs.config) ClusterUsageReportStructure (class in kafka_overwatch.specs.report) compliant_percentage (kafka_overwatch.specs.report.GovernanceNamingConventionReport attribute) conduktor_gateway (kafka_overwatch.specs.config.Providers attribute) config (kafka_overwatch.aws_helpers.s3.S3Handler property) (kafka_overwatch.overwatch.KafkaOverwatchService property) (kafka_overwatch.overwatch_resources.clusters.KafkaCluster property) (kafka_overwatch.overwatch_resources.schema_registry.SchemaRegistry property) (kafka_overwatch.overwatch_resources.topics.Topic property) (kafka_overwatch.specs.config.SchemaRegistry attribute) confluent_cloud (kafka_overwatch.specs.config.Providers attribute) confluent_cloud_auth (kafka_overwatch.specs.config.ConfluentProvider attribute) ConfluentCloudAuth (class in kafka_overwatch.specs.config) ConfluentProvider (class in kafka_overwatch.specs.config) ConfluentSchemaRegistry (class in kafka_overwatch.specs.config) consumer_client() (kafka_overwatch.overwatch_resources.clusters.KafkaCluster method) consumer_group_naming_convention (kafka_overwatch.specs.report.Governance attribute) consumer_groups (kafka_overwatch.specs.report.Statistics attribute) consumer_groups_naming_convention (kafka_overwatch.specs.config.GovernanceReportingConfig attribute) ConsumerGroup (class in kafka_overwatch.overwatch_resources.groups) ConsumerGroups (class in kafka_overwatch.specs.report)

D

date_format (kafka_overwatch.config.logging.MyFormatter attribute) debug_format (kafka_overwatch.config.logging.MyFormatter attribute) default_format (kafka_overwatch.config.logging.MyFormatter attribute) define_topic_jobs() (in module kafka_overwatch.kafka_resources.topics) definition (kafka_overwatch.notifications.aws_sns.SnsChannel property) describe_update_all_topics() (in module kafka_overwatch.kafka_resources.topics)

describe_update_consumer_group_offsets() (in module kafka_overwatch.kafka_resources.groups) describe_update_topics() (in module kafka_overwatch.kafka_resources.topics) description (kafka_overwatch.specs.config.KafkaServiceAccount attribute) (kafka_overwatch.specs.report.TopicWasteCategory attribute) detected_unused (kafka_overwatch.specs.report.SchemasWasteEstimates attribute) detected_unused_count (kafka_overwatch.specs.report.SchemasWasteEstimates attribute) dimensions (kafka_overwatch.specs.config.AwsEmf attribute)

E

email (kafka_overwatch.specs.config.Template attribute) enabled (kafka_overwatch.specs.config.AwsEmf attribute) (kafka_overwatch.specs.config.BackupConfig attribute) (kafka_overwatch.specs.config.ClusterTopicBackupConfig attribute) (kafka_overwatch.specs.config.Prometheus attribute) end_offset (kafka_overwatch.overwatch_resources.topics.Partition property) ensure_prometheus_multiproc() (in module kafka_overwatch.processing) ErrorFilter (class in kafka_overwatch.config.logging)

estimated_waste (kafka_overwatch.specs.report.ClusterReport attribute) EstimatedWaste (class in kafka_overwatch.specs.report) eval_kafka_client_config() (in module kafka_overwatch.aws_helpers.kafka_client_secrets) evaluation_period_in_seconds (kafka_overwatch.specs.config.ReportingConfig attribute) exclude_regions (kafka_overwatch.specs.config.MskProvider attribute) export_df() (in module kafka_overwatch.reporting.tools) Exports (class in kafka_overwatch.specs.config) exports (kafka_overwatch.specs.config.ReportingConfig attribute) ExternalId (kafka_overwatch.specs.config.AssumeRole attribute)

F

fetch_set_lag() (kafka_overwatch.overwatch_resources.groups.ConsumerGroup method) filter() (kafka_overwatch.config.logging.ErrorFilter method) (kafka_overwatch.config.logging.InfoFilter method)

first_offset (kafka_overwatch.overwatch_resources.topics.Partition property) format() (kafka_overwatch.config.logging.MyFormatter method)

G

gateway_config (kafka_overwatch.specs.config.GatewayConfiguration attribute) GatewayConfiguration (class in kafka_overwatch.specs.config) generate_cluster_consumer_groups_pd_dataframe() (in module kafka_overwatch.overwatch_resources.clusters) generate_cluster_report() (in module kafka_overwatch.processing.clusters) generate_cluster_topics_pd_dataframe() (in module kafka_overwatch.overwatch_resources.clusters) generate_kafka_create_topic_command() (kafka_overwatch.overwatch_resources.topics.Topic method) get_admin_client() (kafka_overwatch.overwatch_resources.clusters.KafkaCluster method) get_client() (kafka_overwatch.overwatch_resources.schema_registry.SchemaRegistry method) get_cluster_governance() (in module kafka_overwatch.reporting) get_cluster_usage() (in module kafka_overwatch.reporting) get_consumer_groups_desc() (in module kafka_overwatch.kafka_resources.groups) get_end_offset_diff() (kafka_overwatch.overwatch_resources.topics.Partition method) get_naming_convention_report() (in module kafka_overwatch.reporting) get_schema_registry() (kafka_overwatch.overwatch_resources.clusters.KafkaCluster method)

get_schema_registry_report() (in module kafka_overwatch.reporting.schema_registry) get_session_from_iam_override() (in module kafka_overwatch.aws_helpers) get_sr_creds() (kafka_overwatch.overwatch_resources.schema_registry.BasicAuthCreds method) get_topic_descriptions() (in module kafka_overwatch.kafka_resources.topics) get_topic_partition_watermarks() (in module kafka_overwatch.kafka_resources.topics) get_topics_list() (in module kafka_overwatch.kafka_resources.topics) Global (class in kafka_overwatch.specs.config) global_ (kafka_overwatch.specs.config.KafkaOverwatchInputConfiguration attribute) Governance (class in kafka_overwatch.specs.report) governance (kafka_overwatch.specs.config.ClusterConfiguration attribute) (kafka_overwatch.specs.report.ClusterReport attribute) GovernanceNamingConventionReport (class in kafka_overwatch.specs.report) GovernanceReportingConfig (class in kafka_overwatch.specs.config) group_id (kafka_overwatch.overwatch_resources.groups.ConsumerGroup property)

H

handle_librdkafka_config() (in module kafka_overwatch.aws_helpers.kafka_client_secrets) handle_signals() (in module kafka_overwatch.overwatch) (in module kafka_overwatch.processing.signals)

has_active_groups() (kafka_overwatch.overwatch_resources.topics.Topic method) has_new_messages() (kafka_overwatch.overwatch_resources.topics.Partition method) (kafka_overwatch.overwatch_resources.topics.Topic method) high_resolution_metrics (kafka_overwatch.specs.config.AwsEmf attribute)

I

Iam (class in kafka_overwatch.specs.config) iam (kafka_overwatch.specs.config.MskClusterConfig attribute) iam_override (kafka_overwatch.specs.config.AwsGlueSchemaRegistry attribute) (kafka_overwatch.specs.config.ClusterConfigAuth attribute) (kafka_overwatch.specs.config.MskProvider attribute) (kafka_overwatch.specs.config.S3Output attribute) (kafka_overwatch.specs.config.SaaSProviderAwsSecretsManager attribute) ignore_errors (kafka_overwatch.specs.config.SnsTopicChannel attribute) ignore_regexes (kafka_overwatch.specs.config.NamingConvention attribute) import_usage_report_jinja2_templates() (kafka_overwatch.notifications.aws_sns.SnsChannel method) inactive (kafka_overwatch.specs.report.ConsumerGroups attribute)

InfoFilter (class in kafka_overwatch.config.logging) init_backup_handler() (kafka_overwatch.overwatch_resources.schema_registry.SchemaRegistry method) init_cluster_prometheus_reporting() (kafka_overwatch.overwatch_resources.clusters.KafkaCluster method) init_members (kafka_overwatch.overwatch_resources.groups.ConsumerGroup property) init_notification_channels() (kafka_overwatch.config.config.OverwatchConfig method) init_prometheus() (kafka_overwatch.overwatch.KafkaOverwatchService method) init_schema_registries() (kafka_overwatch.config.config.OverwatchConfig method) init_schema_registry_prometheus_reporting() (in module kafka_overwatch.processing.schema_registries) init_set_partitions() (in module kafka_overwatch.kafka_resources.topics) init_start_offset (kafka_overwatch.overwatch_resources.topics.Partition property) input_config (kafka_overwatch.config.config.OverwatchConfig property) is_active (kafka_overwatch.overwatch_resources.groups.ConsumerGroup property)

K

kafka (kafka_overwatch.specs.config.ClusterConfig attribute) (kafka_overwatch.specs.config.Exports attribute) kafka_overwatch module kafka_overwatch.aws_helpers module kafka_overwatch.aws_helpers.kafka_client_secrets module kafka_overwatch.aws_helpers.s3 module kafka_overwatch.cli module kafka_overwatch.cli.schema_registry_restore module kafka_overwatch.common module kafka_overwatch.config module kafka_overwatch.config.config module kafka_overwatch.config.logging module kafka_overwatch.config.threads_settings module kafka_overwatch.kafka_resources module kafka_overwatch.kafka_resources.groups module kafka_overwatch.kafka_resources.topics module kafka_overwatch.monitoring module kafka_overwatch.monitoring.prometheus module kafka_overwatch.notifications module kafka_overwatch.notifications.aws_sns module kafka_overwatch.notifications.aws_sns.usage_report module kafka_overwatch.overwatch module kafka_overwatch.overwatch_resources module kafka_overwatch.overwatch_resources.clusters module

kafka_overwatch.overwatch_resources.groups module kafka_overwatch.overwatch_resources.schema_registry module kafka_overwatch.overwatch_resources.schema_registry.schema module kafka_overwatch.overwatch_resources.schema_registry.schemas_restore module kafka_overwatch.overwatch_resources.schema_registry.subject module kafka_overwatch.overwatch_resources.topics module kafka_overwatch.processing module kafka_overwatch.processing.clusters module kafka_overwatch.processing.schema_registries module kafka_overwatch.processing.signals module kafka_overwatch.reporting module kafka_overwatch.reporting.governance module kafka_overwatch.reporting.governance.consumer_groups_naming_convention module kafka_overwatch.reporting.governance.topic_naming_convention module kafka_overwatch.reporting.schema_registry module kafka_overwatch.reporting.tools module kafka_overwatch.reporting.topics module kafka_overwatch.specs module kafka_overwatch.specs.config module kafka_overwatch.specs.report module kafka_service_account (kafka_overwatch.specs.config.ConfluentProvider attribute) kafka_topics_sh (kafka_overwatch.specs.config.BackupStyle attribute) KafkaCluster (class in kafka_overwatch.overwatch_resources.clusters) KafkaOverwatchInputConfiguration (class in kafka_overwatch.specs.config) KafkaOverwatchService (class in kafka_overwatch.overwatch) KafkaServiceAccount (class in kafka_overwatch.specs.config)

L

load_config_file() (in module kafka_overwatch.config)

local (kafka_overwatch.specs.config.Exports attribute) log_group_name (kafka_overwatch.specs.config.AwsEmfModel attribute)

M

main() (in module kafka_overwatch.cli) (in module kafka_overwatch.cli.schema_registry_restore) (in module kafka_overwatch.overwatch_resources.schema_registry.schemas_restore) measure_consumer_group_lags() (in module kafka_overwatch.processing.clusters) members (kafka_overwatch.overwatch_resources.groups.ConsumerGroup property) Metadata (class in kafka_overwatch.specs.report) metadata (kafka_overwatch.specs.report.ClusterReport attribute) metrics (kafka_overwatch.specs.config.ClusterConfiguration attribute) (kafka_overwatch.specs.config.GatewayConfiguration attribute) module kafka_overwatch kafka_overwatch.aws_helpers kafka_overwatch.aws_helpers.kafka_client_secrets kafka_overwatch.aws_helpers.s3 kafka_overwatch.cli kafka_overwatch.cli.schema_registry_restore kafka_overwatch.common kafka_overwatch.config kafka_overwatch.config.config kafka_overwatch.config.logging kafka_overwatch.config.threads_settings kafka_overwatch.kafka_resources kafka_overwatch.kafka_resources.groups kafka_overwatch.kafka_resources.topics kafka_overwatch.monitoring kafka_overwatch.monitoring.prometheus kafka_overwatch.notifications kafka_overwatch.notifications.aws_sns kafka_overwatch.notifications.aws_sns.usage_report kafka_overwatch.overwatch kafka_overwatch.overwatch_resources kafka_overwatch.overwatch_resources.clusters kafka_overwatch.overwatch_resources.groups kafka_overwatch.overwatch_resources.schema_registry kafka_overwatch.overwatch_resources.schema_registry.schema kafka_overwatch.overwatch_resources.schema_registry.schemas_restore kafka_overwatch.overwatch_resources.schema_registry.subject kafka_overwatch.overwatch_resources.topics kafka_overwatch.processing kafka_overwatch.processing.clusters kafka_overwatch.processing.schema_registries kafka_overwatch.processing.signals kafka_overwatch.reporting kafka_overwatch.reporting.governance kafka_overwatch.reporting.governance.consumer_groups_naming_convention kafka_overwatch.reporting.governance.topic_naming_convention kafka_overwatch.reporting.schema_registry kafka_overwatch.reporting.tools kafka_overwatch.reporting.topics kafka_overwatch.specs kafka_overwatch.specs.config kafka_overwatch.specs.report

most_active_topics (kafka_overwatch.specs.report.Statistics attribute) MskClusterConfig (class in kafka_overwatch.specs.config) MskProvider (class in kafka_overwatch.specs.config) multi_clusters_processing() (kafka_overwatch.overwatch.KafkaOverwatchService static method) MyFormatter (class in kafka_overwatch.config.logging)

N

name (kafka_overwatch.overwatch_resources.topics.Topic property) (kafka_overwatch.specs.config.ClusterReportSnsChannel attribute) (kafka_overwatch.specs.config.KafkaServiceAccount attribute) namespace (kafka_overwatch.specs.config.AwsEmf attribute) NamingConvention (class in kafka_overwatch.specs.config)

new_messages_count() (kafka_overwatch.overwatch_resources.topics.Topic method) non_compliant_resources (kafka_overwatch.specs.report.GovernanceNamingConventionReport attribute) notification_channels (kafka_overwatch.specs.config.KafkaOverwatchInputConfiguration attribute) (kafka_overwatch.specs.config.ReportingConfig attribute) NotificationChannels (class in kafka_overwatch.specs.config)

O

output_dataframe() (in module kafka_overwatch.reporting.tools) output_formats (kafka_overwatch.specs.config.ReportingConfig attribute) OutputFormats (class in kafka_overwatch.specs.config)

overwatch_registry (kafka_overwatch.overwatch_resources.schema_registry.schema.Schema property) (kafka_overwatch.overwatch_resources.schema_registry.subject.Subject property) OverwatchConfig (class in kafka_overwatch.config.config)

P

pandas_dataframe (kafka_overwatch.specs.config.OutputFormats attribute) Partition (class in kafka_overwatch.overwatch_resources.topics) partition_id (kafka_overwatch.overwatch_resources.topics.Partition property) partitions (kafka_overwatch.specs.report.EstimatedWaste attribute) (kafka_overwatch.specs.report.Statistics attribute) partitions_offsets (kafka_overwatch.overwatch_resources.groups.ConsumerGroup property) password (kafka_overwatch.specs.config.BasicAuth attribute) pd_frame_data (kafka_overwatch.overwatch_resources.groups.ConsumerGroup property) (kafka_overwatch.overwatch_resources.topics.Topic property) prefix_key (kafka_overwatch.specs.config.S3Output attribute) process_cluster() (in module kafka_overwatch.processing.clusters) process_cluster_resources() (in module kafka_overwatch.processing.clusters)

process_cluster_topic_df() (in module kafka_overwatch.reporting.topics) process_schema_registry() (in module kafka_overwatch.processing.schema_registries) process_schemas() (in module kafka_overwatch.processing.schema_registries) ProfileName (kafka_overwatch.specs.config.Iam attribute) profiling_setup() (in module kafka_overwatch.cli) Prometheus (class in kafka_overwatch.specs.config) prometheus (kafka_overwatch.specs.config.ClusterMetrics attribute) (kafka_overwatch.specs.config.KafkaOverwatchInputConfiguration attribute) prometheus_collectors (kafka_overwatch.overwatch_resources.clusters.KafkaCluster property) prometheus_registry_dir (kafka_overwatch.config.config.OverwatchConfig property) Providers (class in kafka_overwatch.specs.config) providers (kafka_overwatch.specs.config.KafkaOverwatchInputConfiguration attribute) publish() (kafka_overwatch.notifications.aws_sns.SnsChannel method)

R

refresh_subject_metadata() (in module kafka_overwatch.overwatch_resources.schema_registry.schema) regexes (kafka_overwatch.specs.config.NamingConvention attribute) registry_arn (kafka_overwatch.specs.config.AwsGlueSchemaRegistry attribute) render_report() (kafka_overwatch.overwatch_resources.clusters.KafkaCluster method) render_restore_files() (kafka_overwatch.overwatch_resources.clusters.KafkaCluster method) render_usage_report_message_template() (kafka_overwatch.notifications.aws_sns.SnsChannel static method) reporting_config (kafka_overwatch.specs.config.ClusterConfiguration attribute) (kafka_overwatch.specs.config.GatewayConfiguration attribute) ReportingConfig (class in kafka_overwatch.specs.config)

restore_subject() (in module kafka_overwatch.overwatch_resources.schema_registry.schemas_restore) restore_subject_versions() (in module kafka_overwatch.overwatch_resources.schema_registry.schemas_restore) retrieve_from_schemas() (in module kafka_overwatch.processing.schema_registries) retrieve_from_subjects() (in module kafka_overwatch.processing.schema_registries) retry_kafka_describe_update_consumer_group_offsets() (in module kafka_overwatch.kafka_resources.groups) review_topic_naming() (in module kafka_overwatch.reporting.governance.consumer_groups_naming_convention) (in module kafka_overwatch.reporting.governance.topic_naming_convention) role_arn (kafka_overwatch.specs.config.SnsTopicChannel attribute) RoleArn (kafka_overwatch.specs.config.AssumeRole attribute) RoleSessionName (kafka_overwatch.specs.config.AssumeRole attribute)

S

S3 (kafka_overwatch.specs.config.BackupConfig attribute) (kafka_overwatch.specs.config.ClusterTopicBackupConfig attribute) (kafka_overwatch.specs.config.Exports attribute) S3Handler (class in kafka_overwatch.aws_helpers.s3) S3Output (class in kafka_overwatch.specs.config) SaaSProviderAwsSecretsManager (class in kafka_overwatch.specs.config) save_credentials (kafka_overwatch.specs.config.KafkaServiceAccount attribute) SaveCredentials (class in kafka_overwatch.specs.config) Schema (class in kafka_overwatch.overwatch_resources.schema_registry.schema) schema_registries (kafka_overwatch.specs.config.KafkaOverwatchInputConfiguration attribute) schema_registry (kafka_overwatch.specs.config.ClusterConfig attribute) (kafka_overwatch.specs.config.MskClusterConfig attribute) (kafka_overwatch.specs.report.ClusterReport attribute) schema_registry_scan_interval (kafka_overwatch.specs.config.SchemaRegistry attribute) schema_registry_url (kafka_overwatch.specs.config.ConfluentSchemaRegistry attribute) schema_type (kafka_overwatch.overwatch_resources.schema_registry.schema.Schema property) SchemaRegistry (class in kafka_overwatch.overwatch_resources.schema_registry) (class in kafka_overwatch.specs.config) SchemaRegistryReport (class in kafka_overwatch.specs.report) schemas (kafka_overwatch.overwatch_resources.schema_registry.SchemaRegistry attribute) schemas_count (kafka_overwatch.specs.report.SchemaRegistryReport attribute) schemas_estimates (kafka_overwatch.specs.report.SchemaRegistryReport attribute) SchemasWasteEstimates (class in kafka_overwatch.specs.report) secret_id (kafka_overwatch.specs.config.SaaSProviderAwsSecretsManager attribute) send_usage_report_notification() (kafka_overwatch.notifications.aws_sns.SnsChannel method) service_name (kafka_overwatch.specs.config.AwsEmfModel attribute) session (kafka_overwatch.aws_helpers.s3.S3Handler property) (kafka_overwatch.notifications.aws_sns.SnsChannel property)

set_admin_client() (in module kafka_overwatch.kafka_resources) set_cluster_connections() (kafka_overwatch.overwatch_resources.clusters.KafkaCluster method) set_cluster_properties() (kafka_overwatch.overwatch_resources.clusters.KafkaCluster method) set_cluster_topic_stats() (in module kafka_overwatch.reporting) set_consumer_client() (in module kafka_overwatch.kafka_resources) set_kafka_cluster_prometheus_registry_collectors() (in module kafka_overwatch.monitoring.prometheus) set_parser() (in module kafka_overwatch.cli) (in module kafka_overwatch.cli.schema_registry_restore) set_prometheus_env_vars() (in module kafka_overwatch.cli) set_prometheus_metrics() (in module kafka_overwatch.processing.schema_registries) set_reporting_exporters() (kafka_overwatch.overwatch_resources.clusters.KafkaCluster method) set_schema_registry_prometheus_registry_collectors() (in module kafka_overwatch.monitoring.prometheus) set_update_cluster_consumer_groups() (in module kafka_overwatch.kafka_resources.groups) set_update_filter_cluster_consumer_groups() (in module kafka_overwatch.kafka_resources.groups) setup_logging() (in module kafka_overwatch.config.logging) sign_s3_url (kafka_overwatch.specs.config.ClusterReportSnsChannel attribute) sns (kafka_overwatch.specs.config.ClusterReportingNotificationChannels attribute) (kafka_overwatch.specs.config.NotificationChannels attribute) SnsChannel (class in kafka_overwatch.notifications.aws_sns) SnsTopicChannel (class in kafka_overwatch.specs.config) start() (kafka_overwatch.overwatch.KafkaOverwatchService method) state (kafka_overwatch.overwatch_resources.groups.ConsumerGroup property) Statistics (class in kafka_overwatch.specs.report) statistics (kafka_overwatch.specs.report.ClusterReport attribute) Subject (class in kafka_overwatch.overwatch_resources.schema_registry.subject) subjects (kafka_overwatch.overwatch_resources.schema_registry.SchemaRegistry attribute) subjects_count (kafka_overwatch.specs.report.SchemaRegistryReport attribute)

T

Template (class in kafka_overwatch.specs.config) template (kafka_overwatch.specs.config.SnsTopicChannel attribute) thread_id_filter() (in module kafka_overwatch.config.logging) tidy_consumer_groups() (in module kafka_overwatch.kafka_resources.groups) timestamp (kafka_overwatch.specs.report.Metadata attribute) Topic (class in kafka_overwatch.overwatch_resources.topics) topic_arn (kafka_overwatch.specs.config.SnsTopicChannel attribute) topic_categories (kafka_overwatch.specs.report.EstimatedWaste attribute) topic_exclude_regexes (kafka_overwatch.specs.config.ClusterConfiguration attribute) (kafka_overwatch.specs.config.GatewayConfiguration attribute) topic_include_regexes (kafka_overwatch.specs.config.ClusterConfiguration attribute) (kafka_overwatch.specs.config.GatewayConfiguration attribute) topic_naming_convention (kafka_overwatch.specs.config.GovernanceReportingConfig attribute) (kafka_overwatch.specs.report.Governance attribute)

topic_partitions_sum (kafka_overwatch.specs.report.TopicWasteCategory attribute) topics (kafka_overwatch.specs.report.EstimatedWaste attribute) (kafka_overwatch.specs.report.Statistics attribute) (kafka_overwatch.specs.report.TopicWasteCategory attribute) topics_backup_config (kafka_overwatch.specs.config.ClusterConfiguration attribute) topics_count (kafka_overwatch.specs.report.TopicWasteCategory attribute) TopicWasteCategory (class in kafka_overwatch.specs.report) total (kafka_overwatch.specs.report.ConsumerGroups attribute) (kafka_overwatch.specs.report.GovernanceNamingConventionReport attribute) total_ignored (kafka_overwatch.specs.report.GovernanceNamingConventionReport attribute) total_measured (kafka_overwatch.specs.report.GovernanceNamingConventionReport attribute) total_messages_count (kafka_overwatch.overwatch_resources.topics.Partition property)

U

update_set_consumer_group_topics_partitions_offsets() (in module kafka_overwatch.kafka_resources.groups) update_set_topic_config() (in module kafka_overwatch.kafka_resources.topics)

upload() (kafka_overwatch.aws_helpers.s3.S3Handler method) usage_report_messages_templates (kafka_overwatch.notifications.aws_sns.SnsChannel property) username (kafka_overwatch.specs.config.BasicAuth attribute)

W

wait_between_intervals() (in module kafka_overwatch.processing) wait_for_result() (in module kafka_overwatch.kafka_resources)

waiting_on_futures() (in module kafka_overwatch.common) watcher_config (kafka_overwatch.specs.config.AwsEmfModel attribute) write_schema_registry_mmap() (in module kafka_overwatch.processing.schema_registries)