Я играю с Kafka на своем локальном компьютере, и я добавил следующую конфигурацию темы: bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic topic1 config retention.ms=60000 bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic...

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

Можно ли узнать потребляемое смещение данной группы потребителей через программу Java. Конечно, мы можем узнать об этом, используя приведенную ниже команду группы потребителей. bin/kafka-run-class.sh kafka.admin.ConsumerGroupCommand --describe...

Я пытаюсь настроить два сервера Kafka в кластере из 3 узлов. в то время как уже есть один брокер Kafka (версия 0.8), который уже работает с приложением. и есть зависимость от этой кафки версии 0.8, которую нельзя нарушить/обновить. Теперь для POC...