Index

_

__call__() (confluent_kafka.schema_registry.avro.AvroDeserializer method) (confluent_kafka.schema_registry.avro.AvroSerializer method) (confluent_kafka.schema_registry.json_schema.JSONDeserializer method) (confluent_kafka.schema_registry.json_schema.JSONSerializer method) (confluent_kafka.schema_registry.protobuf.ProtobufDeserializer method) (confluent_kafka.schema_registry.protobuf.ProtobufSerializer method) (confluent_kafka.serialization.Deserializer method) (confluent_kafka.serialization.DoubleDeserializer method) (confluent_kafka.serialization.DoubleSerializer method) (confluent_kafka.serialization.IntegerDeserializer method) (confluent_kafka.serialization.IntegerSerializer method) (confluent_kafka.serialization.Serializer method) (confluent_kafka.serialization.StringDeserializer method) (confluent_kafka.serialization.StringSerializer method)

A

abort_transaction() (confluent_kafka.Producer method) AclBinding (class in confluent_kafka.admin) AclBindingFilter (class in confluent_kafka.admin) AclOperation (class in confluent_kafka.admin) AclPermissionType (class in confluent_kafka.admin) add_incremental_config() (confluent_kafka.admin.ConfigResource method) AdminClient (class in confluent_kafka.admin) AdminClient.list_groups() (in module confluent_kafka.admin) AdminClient.list_topics() (in module confluent_kafka.admin) ALL (confluent_kafka.admin.AclOperation attribute) ALLOW (confluent_kafka.admin.AclPermissionType attribute) ALTER (confluent_kafka.admin.AclOperation attribute) ALTER_CONFIGS (confluent_kafka.admin.AclOperation attribute) alter_configs() (confluent_kafka.admin.AdminClient method)

alter_consumer_group_offsets() (confluent_kafka.admin.AdminClient method) alter_user_scram_credentials() (confluent_kafka.admin.AdminClient method) AlterConfigOpType (class in confluent_kafka.admin) ANY (confluent_kafka.admin.AclOperation attribute) (confluent_kafka.admin.AclPermissionType attribute) (confluent_kafka.admin.ResourcePatternType attribute) (confluent_kafka.admin.ResourceType attribute) APPEND (confluent_kafka.admin.AlterConfigOpType attribute) assign() (confluent_kafka.Consumer method) assignment() (confluent_kafka.Consumer method) AvroConsumer (class in confluent_kafka.avro) AvroDeserializer (class in confluent_kafka.schema_registry.avro) AvroProducer (class in confluent_kafka.avro) AvroSerializer (class in confluent_kafka.schema_registry.avro)

B

begin_transaction() (confluent_kafka.Producer method)

BROKER (confluent_kafka.admin.ResourceType attribute)

C

close() (confluent_kafka.Consumer method) CLUSTER_ACTION (confluent_kafka.admin.AclOperation attribute) code() (confluent_kafka.KafkaError method) commit() (confluent_kafka.Consumer method) commit_transaction() (confluent_kafka.Producer method) committed() (confluent_kafka.Consumer method) config (confluent_kafka.admin.NewTopic attribute) ConfigEntry (class in confluent_kafka.admin) ConfigResource (class in confluent_kafka.admin) ConfigSource (class in confluent_kafka.admin) confluent_kafka.admin module consume() (confluent_kafka.Consumer method) (confluent_kafka.DeserializingConsumer method) ConsumeError (class in confluent_kafka.error) Consumer (class in confluent_kafka) Consumer.assign() (in module confluent_kafka) Consumer.commit() (in module confluent_kafka) Consumer.committed() (in module confluent_kafka) Consumer.consume() (in module confluent_kafka) Consumer.Consumer() (in module confluent_kafka) Consumer.consumer_group_metadata() (in module confluent_kafka)

Consumer.get_watermark_offsets() (in module confluent_kafka) Consumer.incremental_assign() (in module confluent_kafka) Consumer.incremental_unassign() (in module confluent_kafka) Consumer.list_topics() (in module confluent_kafka) Consumer.memberid() (in module confluent_kafka) Consumer.offsets_for_times() (in module confluent_kafka) Consumer.on_assign() (in module confluent_kafka) Consumer.on_lost() (in module confluent_kafka) Consumer.on_revoke() (in module confluent_kafka) Consumer.pause() (in module confluent_kafka) Consumer.poll() (in module confluent_kafka) Consumer.position() (in module confluent_kafka) Consumer.resume() (in module confluent_kafka) Consumer.seek() (in module confluent_kafka) Consumer.set_sasl_credentials() (in module confluent_kafka) Consumer.store_offsets() (in module confluent_kafka) Consumer.subscribe() (in module confluent_kafka) consumer_group_metadata() (confluent_kafka.Consumer method) CREATE (confluent_kafka.admin.AclOperation attribute) create_acls() (confluent_kafka.admin.AdminClient method) create_partitions() (confluent_kafka.admin.AdminClient method) create_topics() (confluent_kafka.admin.AdminClient method)

D

DEFAULT_CONFIG (confluent_kafka.admin.ConfigSource attribute) DELETE (confluent_kafka.admin.AclOperation attribute) (confluent_kafka.admin.AlterConfigOpType attribute) delete_acls() (confluent_kafka.admin.AdminClient method) delete_consumer_groups() (confluent_kafka.admin.AdminClient method) delete_subject() (confluent_kafka.schema_registry.SchemaRegistryClient method) delete_topics() (confluent_kafka.admin.AdminClient method) delete_version() (confluent_kafka.schema_registry.SchemaRegistryClient method) DENY (confluent_kafka.admin.AclPermissionType attribute) DESCRIBE (confluent_kafka.admin.AclOperation attribute) describe_acls() (confluent_kafka.admin.AdminClient method)

DESCRIBE_CONFIGS (confluent_kafka.admin.AclOperation attribute) describe_configs() (confluent_kafka.admin.AdminClient method) describe_consumer_groups() (confluent_kafka.admin.AdminClient method) describe_user_scram_credentials() (confluent_kafka.admin.AdminClient method) Deserializer (class in confluent_kafka.serialization) DeserializingConsumer (class in confluent_kafka) DoubleDeserializer (class in confluent_kafka.serialization) DoubleSerializer (class in confluent_kafka.serialization) DYNAMIC_BROKER_CONFIG (confluent_kafka.admin.ConfigSource attribute) DYNAMIC_DEFAULT_BROKER_CONFIG (confluent_kafka.admin.ConfigSource attribute) DYNAMIC_TOPIC_CONFIG (confluent_kafka.admin.ConfigSource attribute)

E

error (confluent_kafka.TopicPartition attribute)

error() (confluent_kafka.Message method)

F

fatal() (confluent_kafka.KafkaError method)

flush() (confluent_kafka.Producer method)

G

get_compatibility() (confluent_kafka.schema_registry.SchemaRegistryClient method) get_latest_version() (confluent_kafka.schema_registry.SchemaRegistryClient method) get_schema() (confluent_kafka.schema_registry.SchemaRegistryClient method) get_subjects() (confluent_kafka.schema_registry.SchemaRegistryClient method)

get_version() (confluent_kafka.schema_registry.SchemaRegistryClient method) get_versions() (confluent_kafka.schema_registry.SchemaRegistryClient method) get_watermark_offsets() (confluent_kafka.Consumer method) GROUP (confluent_kafka.admin.ResourceType attribute)

H

headers() (confluent_kafka.Message method)

I

IDEMPOTENT_WRITE (confluent_kafka.admin.AclOperation attribute) incremental_alter_configs() (confluent_kafka.admin.AdminClient method) incremental_assign() (confluent_kafka.Consumer method) incremental_operation (confluent_kafka.admin.ConfigEntry attribute) incremental_unassign() (confluent_kafka.Consumer method) init_transactions() (confluent_kafka.Producer method)

IntegerDeserializer (class in confluent_kafka.serialization) IntegerSerializer (class in confluent_kafka.serialization) is_default (confluent_kafka.admin.ConfigEntry attribute) is_read_only (confluent_kafka.admin.ConfigEntry attribute) is_sensitive (confluent_kafka.admin.ConfigEntry attribute) is_synonym (confluent_kafka.admin.ConfigEntry attribute)

J

JSONDeserializer (class in confluent_kafka.schema_registry.json_schema)

JSONSerializer (class in confluent_kafka.schema_registry.json_schema)

K

KafkaError (class in confluent_kafka) KafkaException (class in confluent_kafka) KEY (confluent_kafka.serialization.MessageField attribute)

key() (confluent_kafka.Message method) KeyDeserializationError (class in confluent_kafka.error) KeySerializationError (class in confluent_kafka.error)

L

latency() (confluent_kafka.Message method) leader_epoch (confluent_kafka.TopicPartition attribute) leader_epoch() (confluent_kafka.Message method) list_consumer_group_offsets() (confluent_kafka.admin.AdminClient method) list_consumer_groups() (confluent_kafka.admin.AdminClient method)

list_groups() (confluent_kafka.admin.AdminClient method) list_topics() (confluent_kafka.admin.AdminClient method) (confluent_kafka.Consumer method) (confluent_kafka.Producer method) LITERAL (confluent_kafka.admin.ResourcePatternType attribute) lookup_schema() (confluent_kafka.schema_registry.SchemaRegistryClient method)

M

MATCH (confluent_kafka.admin.ResourcePatternType attribute) memberid() (confluent_kafka.Consumer method) Message (class in confluent_kafka) Message.len() (in module confluent_kafka)

MessageField (class in confluent_kafka.serialization) metadata (confluent_kafka.TopicPartition attribute) module confluent_kafka.admin

N

name (confluent_kafka.admin.ConfigEntry attribute) name() (confluent_kafka.KafkaError method) new_total_count (confluent_kafka.admin.NewPartitions attribute) NewPartitions (class in confluent_kafka.admin)

NewPartitions.NewPartitions() (in module confluent_kafka.admin) NewTopic (class in confluent_kafka.admin) NewTopic.NewTopic() (in module confluent_kafka.admin) num_partitions (confluent_kafka.admin.NewTopic attribute)

O

offset (confluent_kafka.TopicPartition attribute)

offset() (confluent_kafka.Message method) offsets_for_times() (confluent_kafka.Consumer method)

P

partition (confluent_kafka.TopicPartition attribute) partition() (confluent_kafka.Message method) pause() (confluent_kafka.Consumer method) poll() (confluent_kafka.avro.AvroConsumer method) (confluent_kafka.Consumer method) (confluent_kafka.DeserializingConsumer method) (confluent_kafka.Producer method) position() (confluent_kafka.Consumer method) PREFIXED (confluent_kafka.admin.ResourcePatternType attribute) produce() (confluent_kafka.avro.AvroProducer method) (confluent_kafka.Producer method) (confluent_kafka.SerializingProducer method) ProduceError (class in confluent_kafka.error) Producer (class in confluent_kafka)

Producer.__len__() (in module confluent_kafka) Producer.abort_transaction() (in module confluent_kafka) Producer.begin_transaction() (in module confluent_kafka) Producer.commit_transaction() (in module confluent_kafka) Producer.flush() (in module confluent_kafka) Producer.list_topics() (in module confluent_kafka) Producer.poll() (in module confluent_kafka) Producer.produce() (in module confluent_kafka) Producer.Producer() (in module confluent_kafka) Producer.purge() (in module confluent_kafka) Producer.send_offsets_to_transaction() (in module confluent_kafka) Producer.set_sasl_credentials() (in module confluent_kafka) ProtobufDeserializer (class in confluent_kafka.schema_registry.protobuf) ProtobufSerializer (class in confluent_kafka.schema_registry.protobuf) purge() (confluent_kafka.Producer method)

R

READ (confluent_kafka.admin.AclOperation attribute) register_schema() (confluent_kafka.schema_registry.SchemaRegistryClient method) RegisteredSchema (class in confluent_kafka.schema_registry) replica_assignment (confluent_kafka.admin.NewPartitions attribute) (confluent_kafka.admin.NewTopic attribute)

replication_factor (confluent_kafka.admin.NewTopic attribute) ResourcePatternType (class in confluent_kafka.admin) ResourceType (class in confluent_kafka.admin) resume() (confluent_kafka.Consumer method) retriable() (confluent_kafka.KafkaError method)

S

Schema (class in confluent_kafka.schema_registry) SchemaRegistryClient (class in confluent_kafka.schema_registry) SchemaRegistryError (class in confluent_kafka.schema_registry.error) SCRAM_SHA_256 (confluent_kafka.admin.ScramMechanism attribute) SCRAM_SHA_512 (confluent_kafka.admin.ScramMechanism attribute) ScramCredentialInfo (class in confluent_kafka.admin) ScramMechanism (class in confluent_kafka.admin) seek() (confluent_kafka.Consumer method) send_offsets_to_transaction() (confluent_kafka.Producer method) SerializationContext (class in confluent_kafka.serialization) SerializationError (class in confluent_kafka.error) Serializer (class in confluent_kafka.serialization) SerializingProducer (class in confluent_kafka) SET (confluent_kafka.admin.AlterConfigOpType attribute) set_compatibility() (confluent_kafka.schema_registry.SchemaRegistryClient method)

set_config() (confluent_kafka.admin.ConfigResource method) set_headers() (confluent_kafka.Message method) set_key() (confluent_kafka.Message method) set_sasl_credentials() (confluent_kafka.admin.AdminClient method) (confluent_kafka.Consumer method) (confluent_kafka.Producer method) set_value() (confluent_kafka.Message method) source (confluent_kafka.admin.ConfigEntry attribute) STATIC_BROKER_CONFIG (confluent_kafka.admin.ConfigSource attribute) store_offsets() (confluent_kafka.Consumer method) str() (confluent_kafka.KafkaError method) StringDeserializer (class in confluent_kafka.serialization) StringSerializer (class in confluent_kafka.serialization) subscribe() (confluent_kafka.Consumer method) SUBTRACT (confluent_kafka.admin.AlterConfigOpType attribute) synonyms (confluent_kafka.admin.ConfigEntry attribute)

T

test_compatibility() (confluent_kafka.schema_registry.SchemaRegistryClient method) ThrottleEvent (class in confluent_kafka) timestamp() (confluent_kafka.Message method) topic (confluent_kafka.admin.NewPartitions attribute) (confluent_kafka.admin.NewTopic attribute) TOPIC (confluent_kafka.admin.ResourceType attribute)

topic (confluent_kafka.TopicPartition attribute) topic() (confluent_kafka.Message method) TopicPartition (class in confluent_kafka) TopicPartition.TopicPartition() (in module confluent_kafka) txn_requires_abort() (confluent_kafka.KafkaError method) Type (confluent_kafka.admin.ConfigResource attribute)

U

unassign() (confluent_kafka.Consumer method) UNKNOWN (confluent_kafka.admin.AclOperation attribute) (confluent_kafka.admin.AclPermissionType attribute) (confluent_kafka.admin.ResourcePatternType attribute) (confluent_kafka.admin.ResourceType attribute) (confluent_kafka.admin.ScramMechanism attribute)

UNKNOWN_CONFIG (confluent_kafka.admin.ConfigSource attribute) unsubscribe() (confluent_kafka.Consumer method) UserScramCredentialAlteration (class in confluent_kafka.admin) UserScramCredentialDeletion (class in confluent_kafka.admin) UserScramCredentialsDescription (class in confluent_kafka.admin) UserScramCredentialUpsertion (class in confluent_kafka.admin)

V

value (confluent_kafka.admin.ConfigEntry attribute) VALUE (confluent_kafka.serialization.MessageField attribute)

value() (confluent_kafka.Message method) ValueDeserializationError (class in confluent_kafka.error) ValueSerializationError (class in confluent_kafka.error)

W

WRITE (confluent_kafka.admin.AclOperation attribute)