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) 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) ANY (confluent_kafka.admin.AclOperation attribute) (confluent_kafka.admin.AclPermissionType attribute) (confluent_kafka.admin.ResourcePatternType attribute) (confluent_kafka.admin.ResourceType attribute) assign() (confluent_kafka.Consumer method) assignment (confluent_kafka.admin.GroupMember attribute) 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.GroupMetadata attribute)

BROKER (confluent_kafka.admin.ResourceType attribute) BrokerMetadata (class in confluent_kafka.admin) brokers (confluent_kafka.admin.ClusterMetadata attribute)

C

client_host (confluent_kafka.admin.GroupMember attribute) client_id (confluent_kafka.admin.GroupMember attribute) close() (confluent_kafka.Consumer method) CLUSTER_ACTION (confluent_kafka.admin.AclOperation attribute) cluster_id (confluent_kafka.admin.ClusterMetadata attribute) ClusterMetadata (class in confluent_kafka.admin) 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.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.store_offsets() (in module confluent_kafka) Consumer.subscribe() (in module confluent_kafka) consumer_group_metadata() (confluent_kafka.Consumer method) controller_id (confluent_kafka.admin.ClusterMetadata attribute) 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) delete_acls() (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) 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.admin.GroupMetadata attribute) (confluent_kafka.admin.PartitionMetadata attribute) (confluent_kafka.admin.TopicMetadata attribute) (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) GroupMember (class in confluent_kafka.admin) GroupMetadata (class in confluent_kafka.admin)

H

headers() (confluent_kafka.Message method)

host (confluent_kafka.admin.BrokerMetadata attribute)

I

id (confluent_kafka.admin.BrokerMetadata attribute) (confluent_kafka.admin.GroupMember attribute) (confluent_kafka.admin.GroupMetadata attribute) (confluent_kafka.admin.PartitionMetadata attribute) IDEMPOTENT_WRITE (confluent_kafka.admin.AclOperation attribute) incremental_assign() (confluent_kafka.Consumer method) 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) isrs (confluent_kafka.admin.PartitionMetadata 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 (confluent_kafka.admin.PartitionMetadata attribute) 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) members (confluent_kafka.admin.GroupMetadata attribute) Message (class in confluent_kafka) Message.len() (in module confluent_kafka)

MessageField (class in confluent_kafka.serialization) metadata (confluent_kafka.admin.GroupMember 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) orig_broker_id (confluent_kafka.admin.ClusterMetadata attribute) orig_broker_name (confluent_kafka.admin.ClusterMetadata attribute)

P

partition (confluent_kafka.TopicPartition attribute) partition() (confluent_kafka.Message method) PartitionMetadata (class in confluent_kafka.admin) partitions (confluent_kafka.admin.TopicMetadata attribute) pause() (confluent_kafka.Consumer method) poll() (confluent_kafka.avro.AvroConsumer method) (confluent_kafka.Consumer method) (confluent_kafka.DeserializingConsumer method) (confluent_kafka.Producer method) port (confluent_kafka.admin.BrokerMetadata attribute) 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) ProtobufDeserializer (class in confluent_kafka.schema_registry.protobuf) ProtobufSerializer (class in confluent_kafka.schema_registry.protobuf) protocol (confluent_kafka.admin.GroupMetadata attribute) protocol_type (confluent_kafka.admin.GroupMetadata attribute) 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)

replicas (confluent_kafka.admin.PartitionMetadata 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) 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_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_value() (confluent_kafka.Message method) source (confluent_kafka.admin.ConfigEntry attribute) state (confluent_kafka.admin.GroupMetadata 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) 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.admin.TopicMetadata attribute) (confluent_kafka.TopicPartition attribute)

topic() (confluent_kafka.Message method) TopicMetadata (class in confluent_kafka.admin) TopicPartition (class in confluent_kafka) TopicPartition.TopicPartition() (in module confluent_kafka) topics (confluent_kafka.admin.ClusterMetadata attribute) 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)

UNKNOWN_CONFIG (confluent_kafka.admin.ConfigSource attribute) unsubscribe() (confluent_kafka.Consumer method)

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)