org.apache.beam.sdk.io.kafka

Classes

• KafkaCheckpointMark
• KafkaCheckpointMark.PartitionMark
• KafkaIO
• KafkaIO.Read
• KafkaIO.TypedWithoutMetadata
• KafkaIO.Write
• KafkaRecord
• KafkaRecordCoder