[ https://issues.apache.org/jira/browse/FLINK-1811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Robert Metzger resolved FLINK-1811. ----------------------------------- Resolution: Fixed Fix Version/s: 0.9 Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/79a92a64 > 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 > Fix For: 0.9 > > > 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)