Hi, I added some metrics on a step right after KafkaIO. When I compare the read time difference between producer and KafkaIO it is 800ms for P99. However somehow that step's opening and closing bundle difference is 18 seconds for p99. The step itself does not do any specific thing. Do you have any idea why bundle latency is very high ? Where should I check or tune on KafkaIO ?
Additional information I read from one topic. That topic has 15 partitions. Producer write in a round robin fashion. Thanks
