apache-kafka

1зной

1ответ

KafkaMessageListenerContainer перерабатывает сообщение, если есть исключение servicedown

Мы хотим, чтобы слушатель Spring Kafka был настроен таким образом, что, если какая-либо внешняя служба недоступна, мы не хотим потерять сообщение, которое потребляется от Kafka. мы хотим вернуть его о

spring apache-kafka spring-kafka 2016-12-27

---

2зной

2ответ

Медленный производитель при работе Кафки потребителя и производителя от того же виртуальной машины Java

Я использую Кафка 0,8 и весенне-интеграционного Кафка 1.2.0.RELEASE У меня есть 2 темы именованной первичные и вторичные. Мне нужно потреблять из основной темы, и после некоторой обработки необходимо

java apache-kafka spring-kafka 2016-12-27

---

1зной

1ответ

Невозможно скомпилировать потребителя Kafka в Scala

Я хочу потреблять сообщения из темы Кафки с помощью Scala 2.10.6 и Spark 1.6.2. Для Кафки Я использую эту зависимость: <dependency> <groupId>org.apache.spark</groupId> <artifactId>spark-stre

scala apache-spark apache-kafka spark-streaming 2016-12-28

---

0зной

2ответ

Как написать фильтр Logstash для фильтрации kafka тем

Я хочу использовать kafka как входной и logstash как вывод. Я напишу несколько тем в logstash и хочу фильтровать по темам. Я попытался написать код: input { kafka { bootstrap_servers => "lo

apache-kafka logstash 2016-12-28

---

1зной

1ответ

Настройка Kafka Multi Node «Необоснованная длина» в журналах Zookeeper

У меня есть настройка нескольких узлов для kafka, все, кажется, работает хорошо и не отображает журналы ошибок, если я не пытаюсь нажимать сообщение одному производителю. Я получаю сообщение: " Bootst

apache-kafka nodes apache-zookeeper distributed 2016-12-28

---

4зной

4ответ

понимание потребительская группа ID

Я сделал свежую установку Apache Kafka 0.10.1.0. Я смог отправить/получить сообщения в командной строке. При использовании примера производителя/потребителя Java я не могу узнать group.id параметр «Пр

apache-kafka kafka-consumer-api 2016-12-29

---

1зной

2ответ

Плагин пользовательского ввода Logstash для вызова класса java

Я написал специальный фильтр-плагин для logstash для вызова класса java. Требование: Входной плагин: чтение из очереди Пользовательский плагин: Для каждого сообщения в очереди вызвать класс Java **Cod

java ruby apache-kafka logstash logstash-configuration 2016-12-29

---

0зной

1ответ

Кафка Клиент Api вопросы

Может кто-нибудь помочь мне с ниже queries.I я использую Кафка-клиенты-0.10.1.1 (Single Node Single Broker) По умолчанию значение auto.create.topics.enable - это правда. 1.I Посылает сообщение на тему

apache-kafka kafka-consumer-api kafka-producer-api 2016-12-29

---