Hi, i’m using kafka consumer and producer on flink. i’ve succeed to consume, transform, and produce to another topic on my development env ( 1 partition and a few dummy msg)
but when i try to submit job on production env ( 20 partitions and the size is about 100Gb ), there is no one message produce into the kafka topic. i’ve try to set flink parallelism into 20 but is still not working. then i try to use rebalance function it’s success to consume the messages but it still no one msg produce into kafka topic. pls advice
