Read

Read<K, V> is a root PTransform to produce PCollection of KafkaRecords (PTransform<PBegin, PCollection<KafkaRecord<K, V>>>).

Read is a static class of KafkaIO.

expand Method

PCollection<KafkaRecord<K, V>> expand(
  PBegin input)

expand…​FIXME

expand is part of PTransform abstraction.