Я пытаюсь установить потребителя Kafka, используя spring-kaka-2.2.0 и spring-boot-2.1.0, но у меня...
У меня есть потребитель Kafka, который я создаю по расписанию.Он пытается использовать все новые...
Учитывая название темы, номер раздела и смещение, как я могу прочитать только одну запись из темы?...
Перекрестная публикация здесь с https://issues.apache.org/jira/browse/KAFKA-7925, так как никто еще...
Я использую стоковый поисковый коннектор kafka-коннектора для индексации сообщений из нескольких...
У меня есть две службы, которые должны общаться через Kafka.Давайте назовем первый сервис...
В database есть две таблицы.Например: макеты (Id, VenueId, Description) и Venues (Id, Adress,...
При тестировании кафки с верблюдом я столкнулся с проблемой.Я использовал Embedded kafka с...
Таким образом, вопрос прост, но я не могу найти ответ в течение долгого времени. У меня есть...
Исключение разъединения с одним из брокеров kafka как-то отключает весь кластер connect-prod...
Тесты загрузчика kafka не выполняются с журналом WARNING: LBM jar file ABI version 6.11 does not...
Я пытаюсь запустить приложение весенней загрузки с весенним облачным потоком и кафкой, используя...
Мы используем пружину Кафка.Я слушаю несколько тем в моем потребительском приложении (один сервер,...
Я пытаюсь отразить тему kafka от поставщика в контейнере в экземпляре ec2 для потребителя, и...
У меня проблема с работой.У нас есть Кафка, которая работает на кластере HDP.Уже несколько дней...
Я пытаюсь удалить тему Кафки __Consumer_offset, так как это вызывает много недоразумений у моих...
Я хочу запретить клиентам kafka создавать свои собственные группы потребителей и вместо этого...
В моем конкретном случае использования мы собираемся ежедневно получать 1000 ГБ данных.Если я...
Как вставить данные файла json в тему kafka, используя kafka-console -roduction?Может ли каждый...
Сценарий, который я пытаюсь сделать, выглядит следующим образом: 1- Поток TAILDIR Источник читает...
Я пытаюсь начать настройку Kafka с JMX в Windows, но добавив KAFKA_OPTS не работает в Windows
У меня есть два вида записей журнала в server.log Первый вид: WARN Сброс первого грязного смещения...
Я использую flink для чтения из kafka и записи в redis. Для теста я просто хочу прочитать первые 10...
При поиске записи dns (?) Во время инициации производителя kafka я наблюдаю очень странную...
Я использую ReplyingKafkaTemplate.Класс DefaultKafkaConsumerFactory использует одного потребителя...