У меня есть тема в кафке как internal.Я создал тему, используя приведенную ниже команду...

У меня локальная настройка Apache Kafka, и на портах 9092 и 9093 есть всего 2 брокера (id - 0 и 1)....

Я пытаюсь запустить Hyperledger Fabric Orderer с Kafka.У меня есть четыре брокера Kafka.Я получаю...

У меня проблема с темами, созданными с использованием AdminClient createTopics.В моем приложении у...

Что произойдет, если я напишу код, как показано ниже, и не установлю временное окно для потоковой...

Он работал нормально, внезапно это всплывающее окно проблемы с 18 декабря, не мог найти никакой...

У меня есть тема, которая имеет довольно большой срок хранения и множество сохраненных данных.Я...

Я пытаюсь написать приложение для приема пищи на GCP с использованием Apache Beam. Я должен...

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

Я хочу собрать данные из Kafka, используя Nifi в Cassandra.Я создал такой поток для этого. Моя...

Вариант использования Цель состоит в том, чтобы идентифицировать входящие события / строки, чтобы...

Попытка понять взаимосвязь между фактором репликации и группой потребителей.Пример: Количество...

Я использую кластер Kafka с 4 узлами, 1 производителем и 1 потребителем.Он работал нормально, пока...

У меня есть класс kafka, он отлично работает, когда SSL не включен, и прекрасно работает, когда SSL...

Я использовал Kafka 0.9 и недавно перешел на Kafka 1.0, но клиент, который я использую, по-прежнему...

Я хочу знать скорость, с которой тема используется.В метрике Кафки-менеджера есть Messages in /sec,...

У нас есть кластер Kafka из 5 брокеров (r5.xlarge).Вчера мы запустили наш производственный снимок...

Я пытаюсь использовать kafka с верблюдом и настраиваю следующий маршрут: public class...

У меня есть один узел Kafka-2.11, установленный в экземпляре EC2, группа безопасности настроена...

Я хотел бы знать, можем ли мы автоматически масштабировать раздел kafka в производственной системе...

Работа на Kafka с аутентификацией Kerberos.Для запуска из eclipse / commandd задайте аргументы vm с...

Я занимаюсь разработкой приложения SpringBoot.Образы докера представляют собой микросервисы, и один...

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

Приведенный ниже потребитель Scala kafka не возвращает никаких событий из вызова poll. Тем не менее...

kafka-console-consumer.bat --bootstrap-server localhost:2181 --topic baeldung kafka-console-producer