Hi Colleagues,I receive data fro KafkaIO bounded source as
:PCollection<KafkaRecord<byte[],byte[]>> kafkarecords =
p.apply(KafkaIO.read().withBootstrapServers("kirkhost:9092").withTopics(topics).withMaxNumRecords(10));
How do I print out and/or access the records one at a time as String?Thanks for
your help.Amir
- Access PCollection contents amir bahmanyari
- Re: Access PCollection contents Lukasz Cwik
