confluent-kafka
2.3.0
confluent-kafka
Docs
»
Index
Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
W
_
__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)
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
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)
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)
txn_requires_abort() (confluent_kafka.KafkaError method)
Type (confluent_kafka.admin.ConfigResource attribute)
U
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)