Robert Metzger created FLINK-1811: ------------------------------------- Summary: Allow users to pass custom buffer sizes and timeouts to PersistentKafkaSource Key: FLINK-1811 URL: https://issues.apache.org/jira/browse/FLINK-1811 Project: Flink Issue Type: Bug Components: Streaming Affects Versions: 0.9 Reporter: Robert Metzger Assignee: Robert Metzger Priority: Minor
Right now, the call to the Kafka's {{SimpleConsumer}} contains hard coded values that users can not change. -- This message was sent by Atlassian JIRA (v6.3.4#6332)