kafka-consumer-api

3зной

1ответ

Spark Streaming аварийно завершает работу с Kafka Ran из сообщений до достижения исключения в конце исключения

В одном из наших потоковых usecase; одно из наших сенсорных программ отправляет 5 сообщений ~ 20 МБ JSON/Sec в тему Кафки с 50 разделами, когда искровой поток пытается читать сообщения от Kafka, он па

0зной

1ответ

java.lang.ClassCastException: [B не может быть передан в java.lang.String при разборе json [String, String]

Я снова здесь, я пытаюсь прочитать данные из темы kafka_0.9.0.0 с помощью spark streaming_1. 6.1 класс, написанный на scala -2.10.5. Его простая программа я построил в sbt_0.13.12. Когда я запускаю пр

0зной

1ответ

Что такое использование «spark.streaming.blockInterval» в Спарк Streaming DirectAPI

Я хочу, чтобы понять, какую роль играет в "spark.streaming.blockInterval" Спарк Streaming DirectAPI, согласно моему пониманию "spark.streaming.blockInterval" используется для расчета разделов т.е. #pa

2зной

1ответ

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

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

4зной

4ответ

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

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

0зной

1ответ

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

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

0зной

1ответ

Apache Кафка-Исключение: org.apache.kafka.clients.consumer.KafkaConsumer.subscribe (Ljava/Util/Список;) V

Я использую Apache Кафка версии kafka_2.10-0.10.1.0 Во время POC я создали простой производитель и потребитель. Когда я пытаюсь потреблять сообщение получать следующие ошибки: Exception in thread "Thr

2зной

1ответ

Протокол связи Zookeeper

Мне нужно отлаживать обмен данными между моим потребителем kafka и zookeeper с помощью tcpdump. Я прошел через документацию zookeeper, но не смог найти запись о протоколе связи zookeeper. Я получаю сл