akka-kafka

0зной

1ответ

MetaData Response - имя хоста брокера неверно

Я использую SimpleConsumer python-kafka для прослушивания темы в брокерах kafka. Брокер Kafka работает на машине с именем хоста BROKER_HOST. Теперь SimpleConsumer запросы на тему метаданных от брокера

apache-kafka kafka-consumer-api akka-kafka 2015-02-11

---

0зной

1ответ

Изготовитель Kafka с регулируемым количеством сообщений в секунду

Каков наилучший способ написать производитель Apache Kafka с устойчивым, но регулируемым выходом. Пример: Производитель должен отправлять постоянному 1000 сообщений в секунду брокеру. Во время работы

scala akka apache-kafka kafka-producer-api akka-kafka 2015-12-22

---

2зной

1ответ

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

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

scala apache-kafka akka-stream reactive-kafka akka-kafka 2017-01-24

---

1зной

3ответ

производитель Akka поток TCP + Akka поток Кафка не останавливаясь не публиковать сообщения, а не ошибка-ки из

У меня есть следующий поток: Source(IndexedSeq(ByteString.empty)) .via( Tcp().outgoingConnection(bsAddress, bsPort) .via(Framing.delimiter(ByteString("\n"), 256, allowTruncation = true))

scala akka akka-stream akka-kafka 2016-12-14

---