Repository: incubator-beam Updated Branches: refs/heads/master 1963bde44 -> 155409bf6
remove an obsolete comment in KafkaIOTest.java Kafka 10.0 added compatible constructor for ConsumerRecord. It was not present when I wrote this test. https://github.com/apache/kafka/commit/4e557f8ef60d46a8870704655c9a35092f74d125 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1c9d16d7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1c9d16d7 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1c9d16d7 Branch: refs/heads/master Commit: 1c9d16d70ad2bd55b0736ea37f9357029f39ade5 Parents: 1963bde Author: Raghu Angadi <rang...@apache.org> Authored: Thu Jul 7 14:22:41 2016 -0700 Committer: GitHub <nore...@github.com> Committed: Thu Jul 7 14:22:41 2016 -0700 ---------------------------------------------------------------------- .../src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 1 - 1 file changed, 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/1c9d16d7/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java b/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java index 587e3e2..dd93823 100644 --- a/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java +++ b/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java @@ -126,7 +126,6 @@ public class KafkaIOTest { records.put(tp, new ArrayList<ConsumerRecord<byte[], byte[]>>()); } records.get(tp).add( - // Note: this interface has changed in 0.10. may get fixed before the release. new ConsumerRecord<byte[], byte[]>( tp.topic(), tp.partition(),
