Я только начал использовать Spring Boot Stream с Kafka. Я создал производителя и потребителя. Мне...

Я пытаюсь выполнить настройку kafka в IntelliJ. но до этого согласно инструкции я клонировал...

Есть метод poll для опроса ConsumerRecords, но он не может указать размер записи, как опросить...

Я пытаюсь настроить приложение Spring Boot с клиентом Kafka для использования SSL. Мои файлы...

Я использую следующий докер, создающий фрагмент: connect: image:...

Версия брокера Kafka kafka_2.11-0.10.2.1 Мои клиенты используют пакет kafka-clients (0.10.2.0) из...

Я уже немного об этом разбираюсь и наткнулся на множество разных статей и постов на эту тему. Из...

Я не могу удалить тему кафки, она помечена для удаления, но никогда не удаляется. Я запускаю...

Каким образом можно архивировать сообщения Kafka, например, если мы хотим отправить конкретное...

Мне нужно написать клиент, который будет вставлять события в kafka. Мне нужно вставить несколько...

Я получил это сообщение: WorkerSinkTask{id=hdfs-test-0} Sink task finished initialization and start...

Я запускаю штормовую банку в кластере, где я настроил hadoop, kafka, штормовую группу когда я...

Я использую пакет 'no-kafka' npm (для nodejs), У меня 2 проблемы: мое приложение начинается с...

Прежде чем присоединить потребителей к новой теме, я создаю новую тему и выдаю первое сообщение в...

Когда я получаю сообщение производителя консоли kafka, создаю несколько сообщений и затем запускаю...

Для того чтобы отключить сеть фабрики гиперледжеров с заказчиками Kafka-Zookeeper, какие компоненты...

В настоящее время у меня возникают проблемы при настройке службы Kafka в gitlab CI для запуска...

У меня есть данные JSON с отметкой времени, как это a = {'key1':'value'...

Я новичок в kafka и у меня есть вопрос, можно ли подключиться к производителю kafka с помощью...

Я разработал потребителя Kafka на python, используя библиотеку python-kafka на моем локальном...

Я пытаюсь настроить брокера Kafka с поддержкой SSL, но когда я пытаюсь поместить сообщение в тему,...

Давайте предположим, что у меня есть Kafka Cluster из 3 брокеров и 3 zookeeper. У меня есть одна...

У нас есть 9 микросервисов, которые создают 32 тем (2 из них с начала, 30 из них из внутренних),...

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

У меня есть пакетное задание, которое заполняет данные в теме Кафки. Каждое сообщение имеет данные...