[ https://issues.apache.org/jira/browse/FLINK-1811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14390518#comment-14390518 ]
ASF GitHub Bot commented on FLINK-1811: --------------------------------------- GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/558 [FLINK-1811] Allow passing custom buffer sizes and timeouts to Persisten... ...tKafkaSource You can merge this pull request into a Git repository by running: $ git pull https://github.com/rmetzger/flink kafka_config Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/558.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #558 ---- commit 180aee978c2933b27ae9b26e17ab15b4c99cf4cb Author: Robert Metzger <rmetz...@apache.org> Date: 2015-04-01T13:16:17Z [FLINK-1811] Allow passing custom buffer sizes and timeouts to PersistentKafkaSource ---- > 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)