apache-kafka

0зной

1ответ

Входной плагин Logstash kafka не может читать сообщения с новым пользователем и устанавливать auto_offset_reset на самое раннее

Я использую входной плагин Logstash Kafka для чтения сообщений из темы. Раньше я мог запускать новых потребителей, принадлежащих к новым группам потребителей, и установив auto_offset_reset = самое ран

java apache-kafka logstash kafka-producer-api 2016-12-23

---

0зной

1ответ

Не удается получить доступ к данным в Кафки Спарк Потоковые глобально

Я пытаюсь Потоковые данные из Кафки Спарк JavaPairInputDStream<String, String> directKafkaStream = KafkaUtils.createDirectStream(ssc, String.class, String.class, StringDecoder.

hadoop apache-spark apache-kafka spark-streaming 2016-12-23

---

1зной

1ответ

Spark структурированный дымящийся от kafka - последнее сообщение обработано снова после возобновления с контрольной точки

Я использую новый (и помеченный «альфа») Structured Streaming of Spark 2.0.2 для чтения сообщений из темы кафки и обновления пары Cassandra столы из него: val readStream = sparkSession.readStream

scala apache-spark apache-kafka structured-streaming 2016-12-23

---

1зной

1ответ

Неспособность создать встроенный брокер Kafka

Я пытаюсь использовать kafka's kafka.zk.EmbeddedZookeeper и kafka.server.KafkaServer, возвращенный kafka.utils.TestUtils/createServer, для запуска сервера kafka для тестирования. Но я попадаю в блокпо

scala clojure apache-kafka apache-zookeeper 2016-12-25

---

2зной

1ответ

Как получить список всех тем Kafka в кластере вместе с номером раздела с помощью JAVA

Я работаю над проблемой, которая требует от меня получить список всех тем Kafka, присутствующих в кластере, а также получить их соответствующий номер раздела. Я знаю, что это можно сделать с помощью к

java api apache-kafka 2016-12-26

---

4зной

2ответ

выборы лидера в зоопарке и Кафке

вопрос меня беспокоил долгое время. Я знаю, что выборы лидера существуют в зоопарке. Предположим, что у нас есть кластер Kafka, связанный с ансамблем Zookeeper. Итак, я понимаю, что в ансамбле есть ли

apache-kafka apache-zookeeper master-slave 2016-12-26

---

2зной

1ответ

Kafka Потребитель не потребляет сообщений из всех разделов

Я создал тему Kafka с 10 разделами и пытался использовать сообщения через одного потребителя кафки. Однако потребитель кафки не читает сообщения со всех разделов. Более конкретно, его потребляющие соо

apache-kafka kafka-consumer-api 2016-12-27

---