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

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.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)

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) assignment (confluent_kafka.admin.GroupMember attribute) 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

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) 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) COMPLETING_REBALANCING (confluent_kafka.ConsumerGroupState attribute) config (confluent_kafka.admin.NewTopic attribute) ConfigEntry (class in confluent_kafka.admin) ConfigResource (class in confluent_kafka.admin) ConfigSource (class in confluent_kafka.admin) consume() (confluent_kafka.DeserializingConsumer method) ConsumeError (class in confluent_kafka.error) 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) ConsumerGroupDescription (class in confluent_kafka.admin) ConsumerGroupListing (class in confluent_kafka.admin) ConsumerGroupState (class in confluent_kafka) ConsumerGroupTopicPartitions (class in confluent_kafka) controller_id (confluent_kafka.admin.ClusterMetadata attribute) CREATE (confluent_kafka.admin.AclOperation attribute)

D

DEAD (confluent_kafka.ConsumerGroupState attribute) DEFAULT_CONFIG (confluent_kafka.admin.ConfigSource attribute) DELETE (confluent_kafka.admin.AclOperation attribute) (confluent_kafka.admin.AlterConfigOpType attribute) delete_subject() (confluent_kafka.schema_registry.SchemaRegistryClient method) delete_version() (confluent_kafka.schema_registry.SchemaRegistryClient method) DeletedRecords (class in confluent_kafka.admin) DENY (confluent_kafka.admin.AclPermissionType attribute) DESCRIBE (confluent_kafka.admin.AclOperation attribute)

DESCRIBE_CONFIGS (confluent_kafka.admin.AclOperation attribute) DescribeClusterResult (class in confluent_kafka.admin) 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

ElectionType (class in confluent_kafka) EMPTY (confluent_kafka.ConsumerGroupState attribute) 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)

G

get_compatibility() (confluent_kafka.schema_registry.SchemaRegistryClient method) get_latest_version() (confluent_kafka.schema_registry.SchemaRegistryClient method) get_least_significant_bits() (confluent_kafka.Uuid method) get_most_significant_bits() (confluent_kafka.Uuid 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) 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_operation (confluent_kafka.admin.ConfigEntry attribute) 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) IsolationLevel (class in confluent_kafka) 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) leader_epoch (confluent_kafka.TopicPartition attribute) leader_epoch() (confluent_kafka.Message method)

ListConsumerGroupsResult (class in confluent_kafka.admin) ListOffsetsResultInfo (class in confluent_kafka.admin) LITERAL (confluent_kafka.admin.ResourcePatternType attribute) lookup_schema() (confluent_kafka.schema_registry.SchemaRegistryClient method)

M

MATCH (confluent_kafka.admin.ResourcePatternType attribute) MemberAssignment (class in confluent_kafka.admin) MemberDescription (class in confluent_kafka.admin) 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) (confluent_kafka.TopicPartition attribute)

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) Node (class in confluent_kafka) num_partitions (confluent_kafka.admin.NewTopic attribute)

O

offset (confluent_kafka.TopicPartition attribute) offset() (confluent_kafka.Message method)

OffsetSpec (class in confluent_kafka.admin) 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) poll() (confluent_kafka.avro.AvroConsumer method) (confluent_kafka.DeserializingConsumer method) port (confluent_kafka.admin.BrokerMetadata attribute) PREFERRED (confluent_kafka.ElectionType attribute) PREFIXED (confluent_kafka.admin.ResourcePatternType attribute) PREPARING_REBALANCING (confluent_kafka.ConsumerGroupState attribute) produce() (confluent_kafka.avro.AvroProducer method) (confluent_kafka.SerializingProducer method) ProduceError (class in confluent_kafka.error) 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) protocol (confluent_kafka.admin.GroupMetadata attribute) protocol_type (confluent_kafka.admin.GroupMetadata attribute)

R

READ (confluent_kafka.admin.AclOperation attribute) READ_COMMITTED (confluent_kafka.IsolationLevel attribute) READ_UNCOMMITTED (confluent_kafka.IsolationLevel 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) 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) 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_value() (confluent_kafka.Message method) source (confluent_kafka.admin.ConfigEntry attribute) STABLE (confluent_kafka.ConsumerGroupState attribute) state (confluent_kafka.admin.GroupMetadata attribute) STATIC_BROKER_CONFIG (confluent_kafka.admin.ConfigSource attribute) str() (confluent_kafka.KafkaError method) StringDeserializer (class in confluent_kafka.serialization) StringSerializer (class in confluent_kafka.serialization) 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.admin.TopicMetadata attribute) (confluent_kafka.TopicPartition attribute) topic() (confluent_kafka.Message method)

TopicCollection (class in confluent_kafka) TopicDescription (class in confluent_kafka.admin) TopicMetadata (class in confluent_kafka.admin) TopicPartition (class in confluent_kafka) TopicPartition.TopicPartition() (in module confluent_kafka) TopicPartitionInfo (class in confluent_kafka) topics (confluent_kafka.admin.ClusterMetadata attribute) TRANSACTIONAL_ID (confluent_kafka.admin.ResourceType attribute) txn_requires_abort() (confluent_kafka.KafkaError method) Type (confluent_kafka.admin.ConfigResource attribute)

U

UNCLEAN (confluent_kafka.ElectionType attribute) 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) (confluent_kafka.ConsumerGroupState attribute)

UNKNOWN_CONFIG (confluent_kafka.admin.ConfigSource attribute) UNKOWN (confluent_kafka.ConsumerGroupState attribute) UserScramCredentialAlteration (class in confluent_kafka.admin) UserScramCredentialDeletion (class in confluent_kafka.admin) UserScramCredentialsDescription (class in confluent_kafka.admin) UserScramCredentialUpsertion (class in confluent_kafka.admin) Uuid (class in confluent_kafka) Uuid.Uuid() (in module confluent_kafka)

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)