Repository: beam Updated Branches: refs/heads/master 77a4d3e9d -> 2acdc747a
[BEAM-2720] Update kafka client version to 0.11.0.1 This was supposed to be in earler PR #3612, but it slipped through. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/27684090 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/27684090 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/27684090 Branch: refs/heads/master Commit: 27684090f43ce24810e6a4a4efabee07628c7ae0 Parents: de7cc05 Author: Raghu Angadi <[email protected]> Authored: Wed Oct 18 10:18:15 2017 -0700 Committer: Raghu Angadi <[email protected]> Committed: Wed Oct 18 10:18:15 2017 -0700 ---------------------------------------------------------------------- pom.xml | 2 +- .../kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 1 - 2 files changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/27684090/pom.xml ---------------------------------------------------------------------- diff --git a/pom.xml b/pom.xml index 8e0b4f5..3509407 100644 --- a/pom.xml +++ b/pom.xml @@ -153,7 +153,7 @@ <woodstox.version>4.4.1</woodstox.version> <spring.version>4.3.5.RELEASE</spring.version> <snappy-java.version>1.1.4</snappy-java.version> - <kafka.clients.version>0.10.1.0</kafka.clients.version> + <kafka.clients.version>0.11.0.1</kafka.clients.version> <commons.csv.version>1.4</commons.csv.version> <os-maven-plugin.version>1.5.0.Final</os-maven-plugin.version> http://git-wip-us.apache.org/repos/asf/beam/blob/27684090/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java index 603e62f..af73a8d 100644 --- a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java +++ b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java @@ -1590,7 +1590,6 @@ public class KafkaIO { * consumer. Similar to {@link Read#withConsumerFactoryFn(SerializableFunction)}, a factory * function can be supplied if required in a specific case. * The default is {@link KafkaConsumer}. - * @param consumerFactoryFn */ public Write<K, V> withConsumerFactoryFn( SerializableFunction<Map<String, Object>, ? extends Consumer<?, ?>> consumerFactoryFn) {
