Hi, I'm planning a distributed system with multiple kafka brokers co located with flink workers. Data processing throughput for historic queries is a main KPI. So I want to make sure all flink workers read local data and not remote. I'm defining my pipelines in beam using java. Is it possible? What are the critical config elements to achieve this? Thank you, Gyorgy
-- György Balogh CTO E [email protected] <[email protected]> M +36 30 270 8342 <+36%2030%20270%208342> A HU, 1117 Budapest, Budafoki út 209. W www.ultinous.com
