Я использую Spring и Spring Kafka для пакетной службы, которая собирает данные из Kafka до тех пор,...
У меня есть ситуация (не спрашивать), где у меня есть информация о смещении (тема, раздел,...
Не удается создать тему Кафки в следующих сценариях: Узел кластера Кафка: 4 Коэффициент репликации:...
Я использую kafka 1.0.1-kafka-3.1.0-SNAPSHOT из CDH (дистрибутив cloudera для hadoop) На моем...
У меня есть несколько групп потребителей, каждая из которых имеет 1 потребителя. Скажем, Тема T1 и...
Могу ли я создать потребителя кафки для чтения ФИКСИРОВАННОГО (скажем, 100) количества сообщений в...
Я пытаюсь получить последнее смещение от потребителя Кафки.Я делаю следующие 2 шага consumer
Я использую конвейер данных, так что я читаю данные из sql db в тему kafka через jdbc connect. Я...
У нас есть 1 тема с 3 разделами с одним потребителем.Мы используем данные в виде пакетов (25),...
Я читал о безопасности kafka и, похоже, ACKL - это путь для установки безопасной kafka.Но мой...
Я использую pykafka для потребления сообщения, и теперь я используюалансированный_консумер для...
Я новичок в Kakfa и учусь создавать и потреблять сообщения в и из темы Kafka. Я использую...
Контекст: У нас есть требование, когда мне нужно захватить конкретную транзакцию с использованием...
Я смотрю на исходный код KafkaConsumer здесь .Посмотрев на исходный код (который находится в Java,...
Не могу сделать ни один пример компиляции, не говоря уже о работе.Что я делаю неправильно?Запущено...
Привет! У меня есть данные о потребителях кафки.Следующая команда дает мне тайм-аут команды группы...
Мой проект реализует мультитенантность на уровне Kafka, используя отдельную тему для каждого...
Я пытаюсь написать потребительский код Kafka, используя Scala. У меня есть кластер Kafka (сервер A)...
Я хочу, чтобы мой потребитель kafka слушал сервер kafka только с 8:00 до 20:00.Он не должен слушать...
В настоящее время я разработал код, который будет отображать тему, раздел и смещение журнала.Но в...
Предположим, что у меня задание таймера выполняется бесконечно долго, которое перебирает все группы...
В моем проекте camus используется долгое время и никогда не обновляется.В проекте camus...
Я встречаю странную вещь о восстановлении баланса Кафки.Если я увеличу разделы по теме, на которую...
Я читаю из темы Кафки и фиксирую смещения чтения. Могу ли я каким-то образом, используя тот же...
У нас есть сообщения, которые являются зависимыми.скажем, у нас есть 4 сообщения M1, M2, M1_update1...