CODEWITHSUNDEEP
apache-beamapache-beam-ioapache-beam-kafkaio
artofdoe
artofdoe

Reputation: 197

how to use withDynamicRead with KafkaIO in Apache BEAM

I'm using read with KafkaIO in Apache Beam and i'm trying to call withDynamicRead. I also have a basic call of withCheckStopReadingFn:

.withCheckStopReadingFn(new SerializableFunction<TopicPartition, Boolean>() {
   @Override
   public Boolean apply(TopicPartition input) {
     return false;
   }
})

I'm getting this error and i can't make sense of it. Anyone know how to call DyanamicRead properly? I'm using Apache Beam version 2.29

Exception in thread "main" org.apache.beam.sdk.transforms.display.DisplayData$InternalBuilder$PopulateDisplayDataException: Error while populating display data for component 'org.apache.beam.sdk.transforms.ParDo$MultiOutput': null

Upvotes: 0

Views: 191

Answers (1)

Kenn Knowles
Kenn Knowles

Reputation: 6023

This looks like a bug in Beam. Information on contacting the Beam community -devs and other users, and filing bug reports - are at https://beam.apache.org/community/contact-us/

Upvotes: 0

Related Questions