@@ -12,13 +12,13 @@ kafka
1212Application code typically interacts with one of three top-level clients.
1313Each owns a background IO thread and a shared async networking layer.
1414
15- - :class: `~kafka.KafkaConsumer ` — high-level, group-aware message consumer.
15+ - :class: `~kafka.KafkaConsumer ` - high-level, group-aware message consumer.
1616 Iterable, with manual or automatic offset commits, cooperative rebalance,
1717 pluggable deserializers, and transactional-read isolation.
18- - :class: `~kafka.KafkaProducer ` — high-level, asynchronous message producer.
18+ - :class: `~kafka.KafkaProducer ` - high-level, asynchronous message producer.
1919 Batches records into a background sender thread, with optional
2020 idempotence, transactions, compression, and pluggable serializers.
21- - :class: `~kafka.KafkaAdminClient ` — admin operations: topic, ACL, config,
21+ - :class: `~kafka.KafkaAdminClient ` - admin operations: topic, ACL, config,
2222 consumer group, partition, quota, log-directory, and quorum management.
2323
2424.. toctree ::
@@ -34,14 +34,14 @@ kafka.net
3434=========
3535
3636The clients share a single async networking layer (``kafka.net ``). These
37- classes are exposed for advanced use cases — embedding the connection
37+ classes are exposed for advanced use cases - embedding the connection
3838pool, building a custom client on top of the kafka.net event loop, or
3939driving the protocol layer directly from the REPL.
4040
41- - :mod: `~kafka.net.manager ` — connection pool and
41+ - :mod: `~kafka.net.manager ` - connection pool and
4242 high-level facade over the shared IO event loop. Each top-level client
4343 owns one.
44- - :mod: `~kafka.net.connection ` — per-broker async
44+ - :mod: `~kafka.net.connection ` - per-broker async
4545 connection: state machine, request/response correlation, and SASL
4646 handshake.
4747- :mod: `~kafka.net.transport ` - Async socket I/O with write buffering,
@@ -71,12 +71,12 @@ other / misc
7171Lightweight data types used throughout the client APIs (and useful when
7272working with the lower-level protocol layer).
7373
74- - :class: `~kafka.cluster.ClusterMetadata ` — in-memory cache of brokers,
74+ - :class: `~kafka.cluster.ClusterMetadata ` - in-memory cache of brokers,
7575 topics, partitions, and the active controller. Refreshes itself on the
7676 shared IO thread.
77- - :class: `~kafka.TopicPartition ` — namedtuple identifying a partition as
77+ - :class: `~kafka.TopicPartition ` - namedtuple identifying a partition as
7878 ``(topic, partition) ``.
79- - :class: `~kafka.OffsetAndMetadata ` — committed-offset record
79+ - :class: `~kafka.OffsetAndMetadata ` - committed-offset record
8080 ``(offset, metadata, leader_epoch) ``.
8181- :class: `~kafka.OffsetSpec ` - enum for partition offset queries.
8282- :class: `~kafka.IsolationLevel ` - enum for transactional isolation.
0 commit comments