apache-kafka

0зной

1ответ

Почему прокси-сервер Kafka REST, работающий на порту 443, предупреждает о нелегальном символе 0x16?

Я изменил конфигурацию kafka.rest.properties, установив listeners=http://0.0.0.0:443. В настоящее время на выполнение sudo bin/kafka-rest-start ./etc/kafka-rest/kafka-rest.properties Я не подвожу эту

0зной

1ответ

Как потребитель Кафки выбирает, из какой темы в следующий опрос?

Предположим, у меня есть потребитель, подписанный на несколько тем. Какая тема выбрана, когда я делаю опрос? Я использую RdKafka .Net для клиента. Есть ли способ повлиять, какая тема выбрана?

0зной

1ответ

Как создать группу потребителей kafka в Голанге?

Доступная библиотека: sarama (или ее расширение sarama-cluster), однако пример группы потребителей не предоставляется, а не в sarama и не в sarama-cluster. Я не понимаю API. Могу ли я привести пример

0зной

1ответ

Как взломать процесс выбора лидера раздела kafka

Я собираюсь настроить кластер kafka для нашей интенсивной системы обмена сообщениями. В настоящее время мы установили два кластера kafka, один из которых базируется в Лондоне (LD), как основной, так и

0зной

1ответ

Kafka - Consumer Full Data Refresh

По многим причинам потребителю необходимо выполнить полное обновление данных, это может быть связано с сбоем данных или новым потребителем на посадке. Мне было интересно, как потребитель может выполни