[ https://issues.apache.org/jira/browse/FLUME-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15873261#comment-15873261 ]
Yoandy Terradas-Otero commented on FLUME-3026: ---------------------------------------------- hi, what are the plans to release support for kafka 0.10? > 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.15#6346)