[
https://issues.apache.org/jira/browse/FLUME-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15681100#comment-15681100
]
Jeff Holoman commented on FLUME-3026:
-------------------------------------
The current requirement is that the Kafka version of the broker must be > than
the Kafka version of the client. We should discuss when we want to bump up this
version, as doing so would require users to upgrade their Kafka brokers to .10
or greater. Depending on when we do the next release this may or may not make
sense.
It would be nice to bump the version to greater than 10.1.0 to take advantage
of some things in the new Consumer (like improved heartbeat mechanics).
> Add Kafka 0.10 support for Flume
> ----------------------------------
>
> Key: FLUME-3026
> URL: https://issues.apache.org/jira/browse/FLUME-3026
> Project: Flume
> Issue Type: Improvement
> Components: Channel, Sinks+Sources
> Affects Versions: v1.7.0
> Reporter: Ping Wang
> Attachments: FLUME-3026.patch
>
>
> Kafka 0.10 already released and it introduces some new APIs that not
> compatible with old one. When using Kafka 0.10, the unit test cases will hit
> compilation error:
> ...
> [ERROR]
> /root/flume/flume-ng-sinks/flume-ng-kafka-sink/src/test/java/org/apache/flume/sink/kafka/TestKafkaSink.java:[526,14]
> error: method createTopic in class AdminUtils cannot be applied to given
> types;
> ...
> [ERROR]
> /root/flume/flume-ng-sources/flume-kafka-source/src/test/java/org/apache/flume/source/kafka/TestKafkaSource.java:[23,19]
> error: cannot find symbol
> [ERROR] package kafka.common
> [ERROR]
> /root/flume/flume-ng-sources/flume-kafka-source/src/test/java/org/apache/flume/source/kafka/TestKafkaSource.java:[109,13]
> error: cannot find symbol
> [ERROR] class TestKafkaSource
> [ERROR]
> /root/flume/flume-ng-sources/flume-kafka-source/src/test/java/org/apache/flume/source/kafka/KafkaSourceEmbeddedKafka.java:[134,14]
> error: method createTopic in class AdminUtils cannot be applied to given
> types;
> ...
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
