Gábor Hermann created FLINK-1684: ------------------------------------ Summary: Make Kafka connectors read/write a partition the worker is on Key: FLINK-1684 URL: https://issues.apache.org/jira/browse/FLINK-1684 Project: Flink Issue Type: Improvement Components: Streaming Reporter: Gábor Hermann
Kafka connectors could read/write partitions on a different machine. It is a best effort to find the partitions located on the same node as the subtask and read from (or write to) that partition. -- This message was sent by Atlassian JIRA (v6.3.4#6332)