2016-12-29 4 views
1

Может ли кто-нибудь сказать мне разницу между баночками 1 и 2. Я пытаюсь написать клиент kafka, чтобы вытащить данные у брокеров с использованием API опроса (long timeout) на KafkaConsumer с 1, но реализация, похоже, автоматически сгенерирована (см. Ниже). Любые мысли о том, что такое правильная банка.Что такое подходящий контейнер Apache Kafka Client

public Map<String, ConsumerRecords<K,V>> poll(long timeout) { 
    return null; 
} 
+0

Параметр '_2.9.2' суффикс на 2-м говорит вам версию Scala был скомпилирован против. Поскольку Scala не всегда совместима с обратной связью, они предлагают баннеры для различных версий Scala (см. Https://kafka.apache.org/downloads.html). Никогда не видел одного без суффикса, а зависимости для 1-го не перечисляют зависимости Scala, которые кажутся подозрительными, поэтому не уверены, что с ним связано. –

ответ

1

У Kafka есть клиенты, доступные на многих языках программирования. Только Java-клиенты поддерживаются как часть основного проекта Kafka. Вы можете узнать больше о clients.

Вы должны использовать 1-ую баночку писать Кафка интересов потребителей т.е.

<dependency> 
    <groupId>org.apache.kafka</groupId> 
    <artifactId>kafka-clients</artifactId> 
    <version>0.8.2.0</version> 
</dependency> 
+0

Здравствуйте, @ravthiru, Спасибо за ответ. Вы знаете ответ на мой второй вопрос в API опроса(). Почему у java-клиента есть сгенерированный код? Благодаря! – useful

+0

IRRC, клиенты попали в собственную банку в Kafka 0.9 - если Kafka 0.8.2 вам нужно использовать зависимость от ядра Kafka. –

+1

Можете ли вы предоставить конфигурацию maven для основной банки, о которой вы говорите? Не знаете, какой из https://mvnrepository.com/artifact/org.apache.kafka является правильным? – useful

Смежные вопросы