apache-kafka

2зной

2ответ

Невозможно использовать диспетчер с Apache Kafka

У меня есть машина Ubuntu 16.04, где установлен Apache Kafka. В настоящее время, я могу заставить его работать без сбоев с помощью start_kafka.sh скрипта со следующим содержимым: JMX_PORT=17264 KAFKA_

0зной

1ответ

Kafka ssl Производитель EOFException в то время как Producer.send от облачного литейного цеха

В облачном литейном я могу создать сообщение для не ssl url ("kafkaURL: 9092"). Но он НЕ работает для ssl url («kafkaURL: 9093»). Версия сервера Kafka 0.10.0.1 и версия клиента 0.10.0.0. Вот свойство

2зной

1ответ

Reactive-Kafka Stream Потребитель: Произошли мертвые буквы

Я пытаюсь использовать сообщения от Kafka, используя реактивную библиотеку kkka. Я получаю одно сообщение распечатана и после этого я получил [INFO] [01/24/2017 10:36:52.934] [CommittableSourceConsume

2зной

6ответ

Тестирование топологии Kafka Streams

Я ищу способ протестировать приложение Kafka Streams. Чтобы я мог определять входные события, а тестовый набор показывает мне результат. Возможно ли это без реальной настройки Kafka?

4зной

1ответ

Конфигурация производителя Apache Kafka: VS. VS. request.timeout.ms. свойства «max.block.ms»

Учитывая под синхронной производителю Кафка Properties props = new Properties(); props.put("max.block.ms", 30000); props.put("request.timeout.ms", 30000); props.put("retries", 5); KafkaProducer<S

0зной

1ответ

Как перенести Kafka из старого кластера Zookeeper в новый кластер Zookeeper с другим родительским путем znode

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