Hi everyone, i have a question about kafka-flink. ...
# random
u
Hi everyone, i have a question about kafka-flink. i am using 1.17 flink version in kubernetes enviorment using flink-operator, and i want to know if flink kafka connector guarantee data locality. if there are 3 worker nodes, and 3 kafka brokers in each node and also three task managers with one task slot in each node too. and suppose there is a topic with 2 replicas, in this case, can i assume that each flink taskmanager fetch data from the broker on the same node as the flink taskmanager?