confluent-kafka
1.9.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
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.TopicPartition attribute)
(confluent_kafka.admin.PartitionMetadata attribute)
(confluent_kafka.admin.TopicMetadata 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)
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)