Я отправляю данные в тему кафки с несколькими разделами. Например, в 1 теме с 10 разделами я хочу...
Мой кластер Kafka (10 узлов, 5 узлов zk) неожиданно выдал ошибка диска исключение, как показано...
Я хочу запустить схему реестра в ведомом режиме в Kubernetes, я передал переменную окружения master
Я пытаюсь Кафка c # клиентских библиотек.Во-первых, я создал базовое приложение производителя и...
Мы используем spring-kafka (1.3.2.RELEASE) в нашем приложении.Прямо сейчас мы используем...
Я использую kafka connect (конфлюентное распределение) для подключения брокера mqtt к теме kafka...
У нас есть свойство broker.id в файле свойств kafka. Какое значение имеет broker.id и что если мы...
и почему мне интересно, как лучше всего применять логику в ValueMapper или аналогичном для значения...
Я пытаюсь установить образ докера Kafka в Windows 10, но всегда говорится, что «образ операционной...
Я создал поток из Kafka, используя KSQL для темы Kafka, которая уже содержит некоторые сообщения.Но...
Мне нужно использовать записи из раздела Kafka в нескольких потоках с уникальными записями в каждом...
Я новичок в KAFKA и знаю, что этот вопрос неоднократно задавался по поводу переполнения стека, но...
Я пытаюсь настроить кластер Kafka за Traefik, но мои производители и клиенты (которые находятся за...
Я новичок в Linux.В настоящее время я прохожу учебное пособие по настройке Kafka онлайн.В нем...
У меня есть файл, в котором двоичный файл avro добавлен рядом друг с другом.Я хотел бы прочитать...
У меня есть следующий скрипт на python, который извлекает твиты из твиттера и отправляет их в тему...
У меня проблема с производителем кафки.На самом деле я использую Spring Kafka, и отправка сообщений...
Я хочу установить канал связи между nifi и kafka. Четыре процессора в nifi (GenerateFlowFile->...
Попытка выяснить, могу ли я написать модульный тест для @KafkaListener, используя spring-kafka и...
Я работал над нашими микросервисами Spring Boot в течение нескольких месяцев, и совсем недавно я...
Может быть, эта проблема уже сообщена и решена. Я не нашел решения и каких-либо открытых вопросов,...
Из следующего вопроса на странице CrateDB GitHub кажется, что это невозможно, т. Е. Протокол Kafka...
Я отключил автоматическую фиксацию и не фиксирую смещение также от потребителя после прочтения....
Застрял в этой простой проблеме за последние два дня, у меня ничего не получалось. Дело довольно...
я использую zipkin с kafka zipkin.collector.kafka.bootstrap-servers: 172.16.5.147:9092,172.16.5