Я знаю, это кажется странным, но когда я установил «linger.ms» больше 0, пропускная способность...
Я пытаюсь использовать RecordFilterStrategy без использования аннотации слушателя Kafka....
Я пытаюсь настроить базовый Kafka с K8s.Однако каждый раз, когда я пытаюсь подключиться из...
Я хочу отправить Json Object в мою тему kafka, но столкнулся с некоторой проблемой Я использую pojo...
У меня 4 раздела и 4 потребителя (например, A, B, C, D).Как настроить, какой потребитель будет...
У меня есть 3-узловый кластер Zookeeper версии 3.4.11 и 2-узловый кластер Kafka версии 0.11.3.Мы...
Мне нужно использовать сообщение об ошибке и, в зависимости от причины сбоя, либо повторить попытку...
Я пытаюсь удалить записи kafka из темы, выполнив следующие действия: bin/kafka-delete-records.sh...
Я работаю с Kafka Consumer и подписываюсь только на одну тему.Я хочу вернуть только назначенные...
spring-kafka не может отправить запись в обратном вызове ListenableFuture<SendResult<String,...
Допустим, группа потребителей, имеющая 5 потребителей, подписывается на какую-то тему, которая...
Я пытаюсь сделать релиз, используя gradlew.Я получаю сообщение об ошибке ниже. Кто-нибудь знаком с...
Я следовал за примерами для fs2-kafka .Тем не менее, я довольно застрял на примере для потребителя
Использование Winlogbeats для пересылки сообщений с хоста Windows на кластер Kafka.Установленный...
Можно ли добавить строковое поле в таблицу / поток KSQL, которое будет содержать часть JSON...
асинхронный вызов не работает с Callback (), программа ожидает завершения send () и не выполняет...
У меня есть приложение Java 8, работающее с Apache Kafka 2.11-0.10.1.0.Мне нужно использовать...
У меня есть сценарий, в котором кафка падает случайным образом.Когда я посылаю сообщение Кафке, и...
У меня есть группа с двумя темами.Я пытаюсь сбросить смещение одного из них на 1, но получаю...
У нас есть 10 серверов приложений и 3 кластера kafka для поддержки запросов обмена сообщениями...
Я проектирую топологию Apache Storm (с использованием streamparse), построенную с одним носиком...
Я получаю следующую ошибку при попытке прочитать с Кафки java.lang.IllegalArgumentException:...
У нас есть Node, а приложения Java используют клиенты Kafka. В настоящее время требуется получить...
Я использую Flink и пытаюсь сохранить данные в HDFS.Сценарий таков: сначала данные поступают с...
Привет, я написал приложение-потребитель kafka, использующее python с модулем from kafka import...