confluent-kafka

4зной

3ответ

Kafka bootstrap-servers vs zookeeper в kafka-console-consumer

Я пытаюсь протестировать один узел Kafka с 3 брокерами & zookeeper. Я хочу проверить с помощью консольных инструментов. Я бег производителя как таковые: kafka-console-producer --broker-list localhost:

apache-kafka consumer confluent-kafka 2017-01-21

---

1зной

1ответ

Изменение лидерства кластера кластера при лидерстве умирает

Далеко ниже вы можете найти файлы docker-compose.yml. Предпосылки: Я старт 3 Zookeeper серверов в качестве кластера с помощью докер-компоновать (DOCKER-compose.yml, 3 Zookeepers), а затем добавить оди

docker docker-compose apache-zookeeper confluent confluent-kafka 2017-01-23

---

0зной

1ответ

Проблемы при запуске kafka connect в распределенном режиме

Мы тестируем соединение kafka в распределенном режиме, чтобы вытащить записи тем из kafka в HDFS. У нас есть две коробки. Один, в котором работают демоны кафки и зокпера. Мы сохранили один экземпляр п

hdfs apache-kafka apache-kafka-connect confluent confluent-kafka 2017-01-26

---

4зной

1ответ

Идеальное значение для настройки конфигурации распределенных задач Kafka Connect?

Я ищу продукт для ионизации и развертывания приложения Kafka Connect. Тем не менее, есть два вопроса, которые у меня есть о задаче task.max, который требуется и имеет большое значение, но детали неясн

amazon-s3 apache-kafka apache-kafka-connect confluent confluent-kafka 2017-01-27

---

1зной

1ответ

Apache Kafka и Avro: org.apache.avro.generic.GenericData $ Запись не может быть отнесена к com.harmeetsingh13.java.Customer

Всякий раз, когда я пытаюсь прочитать сообщение из очереди kafka, я получаю следующее исключение: [error] (run-main-0) java.lang.ClassCastException: org.apache.avro.generic.GenericData$Record cannot b

java apache-kafka kafka-consumer-api kafka-producer-api confluent-kafka 2017-02-13

---

1зной

1ответ

Проблема доступа AWS S3 при использовании qubole/streamx на AWS EMR

Я использую qubole/streamx в качестве разъема для раковины kafka, чтобы потреблять данные в kafka и хранить их в AWS S3. Я создал пользователя на AIM и разрешением AmazonS3FullAccess. Затем установите

amazon-s3 apache-kafka-connect confluent confluent-kafka qubole 2017-02-14

---

0зной

1ответ

Что делает «offsets.topic.compression.codec» в кафке на самом деле?

Совсем недавно мы начали получать MessageSizeTooLargeException в метаданных, поэтому мы включили offsets.topic.compression.codec = 1, чтобы включить сжатие gzip, но общие байты в скорости/сообщениях п

apache-kafka kafka-consumer-api kafka-python confluent-kafka 2017-02-15

---