kafka-producer-api

0зной

1ответ

Одиночный писатель на раздел, чтобы получить ровно одну семантику на стороне производителя Kafka

Чтобы получить ровно один раз семантику на стороне производителя, Kafka предлагает иметь 1. Использовать single-writer per partition и каждый раз, когда вы получаете сетевую ошибку, проверьте последне

2зной

2ответ

Как настроить Apache Kafka для получения данных через Интернет?

Я настроил 2 Kafka с базовыми настройками на двух разных серверах по сети в Великобритании, а другой в Индии, и мой сценарий очень прост, Великобритания является издателем, а Индия - потребителем, но

1зной

3ответ

kafka java производитель застрял в создании сообщения

Я реализую apache kafka производитель, используя java api. Apache Kafka установлен на локальном хосте. Zookeeper также работает, но все же функция manufacturer.send() застревает в сообщении, и сообщен

0зной

2ответ

Почему Kafka Producer ack = все так медленно при отправке синхронных сообщений

У меня есть приложение Kafka version : 0.9.0.1, которое синхронно отправляет сообщения с ack=all. С помощью этой настройки я получаю сообщение в секунду прибл. 75. Когда я перехожу на ack=1, я увеличи

3зной

1ответ

Исправлена ошибка, связанная с тем, что некоторые временные смещения узлов Kafka не синхронизированы.

У нас есть работа с искровым потоком, которая читается из API Gnip и отправляет твиты в кластер Kafka. Кластер Kafka устанавливается с использованием диспетчера Cloudera. Иногда диспетчер cloudera пок

0зной

2ответ

Apache Kafka: Time Out Exception w/Spark Streaming

Фон: Я использую программу Spark Streaming в Скале с Kafka. Мое намерение состоит в том, чтобы прочитать файл в Kafka и опубликовать эти сообщения в приложении Spark Streaming для проведения некоторог

1зной

1ответ

Kafka + Spark Streaming: ClosedChannelException

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

1зной

1ответ

Kafka Перераспределение переназначения Влияние на производительность

У меня есть производственный кластер Kafka с 5 узлами и около 500 тем. Мне нужно расширить кластер, чтобы добавить 2 новых узла, и поскольку Kafka не обеспечивает автоматическое перераспределение данн

0зной

1ответ

Кафка: Проблемы с подключением - Все серверы не удалось обработать запрос»

Setup У нас есть Кафка кластер из 3 узла, обработки сообщений, приходящих через Nginx The Nginx передает его на PHP, который, в свою очередь вилок а. процесс питона и называет KafkaClient, SimpleProdu