Hi,
We have a Hadoop/YARN Cluster with Kafka and Flink/YARN running on the same machines. In Spark (Streaming), there is a PreferBrokers location strategy, so that the executors consume those kafka partitions which are served from the same machines kafka broker. ( https://spark.apache.org/docs/2.4.0/streaming-kafka-0-10-integration.html# locationstrategies ) I wonder if there is such thing in Flink as well? I didn't find anything yet. Best regards Theo Diefenthal
