consumer

0зной

2ответ

Как использовать потребитель и поставщик вместо Reflection in java 8

У меня есть два простых класса и используйте шаблон отражения для метода invoke. Я хочу написать программирование модуля. Предположим, у нас есть таблица в базе данных, которые держат название модулей

4зной

1ответ

Тема не может быть найдена при создании сообщений: UNKNOWN_TOPIC_OR_PARTITION

У меня есть кластер kafka с двумя узлами (экземпляры EC2), где каждый узел используется как отдельный брокер. Когда я запускаю производителя на экземпляре лидера с помощью следующей команды: kafka-con

0зной

1ответ

, когда количество сообщений достигает максимального значения retention.bytes, kafka удалит сообщения, смещение будет сброшено до нуля?

Я новичок в kafka, когда мы используем kafka, мы можем установить retention.bytes. скажем, мы установили 1GB, если количество сообщений достигнет 1 ГБ, kafka удалит сообщения. Я хочу спросить, что сме

1зной

1ответ

В чем смысл $ channel-> wait() в RabbitMQ

Я совершенно новый в RabbitMQ. Я работаю с библиотекой php-amqplib с codeigniter и все еще интересуюсь некоторыми знаниями, которых мне не хватает. Почему используется $channel->wait()? Почему он всег

4зной

3ответ

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

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

1зной

1ответ

Подписка метод бросает ошибку при попытке получить доступ к Кафка (0,90 версии) от Кафки (0.10 версии)

Это наша среда разработки 1) Кафка кластер - версия 0,10 2) Спарк кластера - 1,6, который имеет 0,9 Кубки Kafka Мы пытаемся произвести() и потреблять() в режиме искрового кластера. (через spark-submit

0зной

1ответ

Почему этот потребитель (работающий на сервлете) не получает сообщений из темы кафки?

Я установил kafka-consumer на моем сервлете. Я прочитал из моей темы kafka и хочу напечатать последнее значение с помощью doGet-метода сервлета. Но если я посылаю doGet я просто получить «нулевой» наз