See: Description
| Class | Description |
|---|---|
| KafkaCheckpointMark |
Checkpoint for an unbounded KafkaIO.Read.
|
| KafkaCheckpointMark.PartitionMark |
A tuple to hold topic, partition, and offset that comprise the checkpoint
for a single partition.
|
| KafkaIO |
An unbounded source and a sink for Kafka topics.
|
| KafkaIO.Read<K,V> |
A
PTransform to read from Kafka topics. |
| KafkaIO.TypedWithoutMetadata<K,V> |
A
PTransform to read from Kafka topics. |
| KafkaIO.Write<K,V> |
A
PTransform to write to a Kafka topic. |
| KafkaRecord<K,V> |
KafkaRecord contains key and value of the record as well as metadata for the record (topic name,
partition id, and offset).
|
| KafkaRecordCoder<K,V> |
Coder for KafkaRecord. |