Talat UYARER
Talat UYARER
@manusa Could you take a look my pr ? I tested on GKE cluster. There is no issue. It works as expected.
Hey @rohanKanojia Let me update my pr. We started using my implementation for older version of fabric8. I will send an update commit in this week.
I actually have rebased version with current master. I can push before https://github.com/fabric8io/kubernetes-client/pull/4702 @shawkins In addition to this last month I implement AWS EKS support also.
Hey @ashkaps I created a pr for this issue. I had similar issue. It solved my issue. fyi #75
@je-ik Could you review this ? Do you see any issue with this PR ?
@je-ik `maxParallelism` beyond the number of partitions in Kafka, you're basically giving workers extra splits that they don't need for that Kafka topic. This means each worker ends up using...
@je-ik Because Metrics are creating when Flink's open function but because they are not getting update at advance time. Flink does not receive updated metrics. My code change make metrics...