Hi All, I have a custom partitioner to distribute the data across partitions in my cluster.
My setup looks like below Version - 3.7.0 Kafka - 3 broker setup Partition count - 10 Stream server pods - 2 Stream threads in each pod - 10 Deployed in Kubernetes Custom partitioner on producer end. I am doing a groupbykey . Is it correct to use it when I have custom partitioner on producer end ? I recently migrated to 3.7 from 3.5.1 . I am observing that partitions are not evenly distributed across my 2 stream pods. Also my remote query is failing with host being unavailable. But if I restart streams it works fine for a certain time and again starts erroring out. Am I doing something wrong? Regards