Hi Team, We have a beam pipeline written in java sdk. Since the apache kafka-io does not have support for topic-regex, we have forked the kafka-io and added the regex support.
However when we are running the pipeline using custom-kafka-io, we do not see metrics exposed by kafka-io such as elements_read and bytes_read. Does anyone have faced this issue before? Regards, Neha
