kafka-producer-api

0зной

1ответ

Как удалить тему, которая запускается в многоуровневом многоуровневом кластере HA kafka

Я установил kafka версию 2.11-0.10.1.0 в многоуровневую многокластерную среду. В kafka server.properties я уже добавил delete.enable.topic = true в все 3 машины. Я использую команду для удаления темы

apache-kafka kafka-consumer-api kafka-producer-api apache-kafka-connect 2017-02-08

---

2зной

1ответ

Kafka Avro Сериализатор: org.apache.avro.AvroRuntimeException: не открыт

Я использую Apache Kafka с Avro Serializer, используя определенный формат. Я пытаюсь создать свой собственный пользовательский класс и использовать его как значение сообщения kafka. Но когда я пытаюсь

java scala apache-kafka avro kafka-producer-api 2017-02-10

---

1зной

1ответ

Apache Kafka: KafkaProducerActor выбрасывает время ожидания ASK.

Я использую раствор торта Akka client for scala and Kafka. Пока я создаю актер KafkaProducerActor и пытаюсь отправить сообщение с использованием шаблона ask и вернуться в будущее и выполнить некоторые

scala akka apache-kafka kafka-producer-api 2017-02-12

---

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

---

0зной

2ответ

Разрешение отказано в модуле omkafka rsyslog

Я пытаюсь опубликовать сообщения от rsyslog на kafka на удаленной машине с помощью модуля omkafka. My omkafka action is configured as: if $HOSTNAME == 'localhost' then { action(type="omkafka"

apache-kafka kafka-producer-api rsyslog 2017-02-17

---

0зной

1ответ

Как автоматически выбрать файл как вход производителя кафки?

Я только начал изучать Кафку. Я сделал много googlings, но до сих пор не знаю: как я могу автоматически собирать файлы, упавшие в папке, как входные данные производителя и, следовательно, получать пот

apache-kafka kafka-producer-api 2017-02-21

---

0зной

1ответ

Kafka Python Client - Как обрабатывать возможные ошибки соединения/таймаута?

Я пишу приложение Python, которое подключается к очереди Kafka и отправляет сообщение в очередь. У меня есть следующий рабочий код: def send_msg(self, topic, msg): self.producer = KafkaProducer(b

python-3.x kafka-producer-api kafka-python 2017-02-21

---