у нас есть 3 машины kafka и 3 сервера zookeper , в то время как машины kafka не размещаются...

Мы столкнулись со следующей проблемой при производстве: org.apache.kafka.common.errors

Я использую kafka version kafka_2.12-2.0.0 и получил ошибку ниже после включения аутентификации SSL

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

Я использую kafka connect HDFS-приемник и Hadoop (для HDFS) в docker-compose. Hadoop (namenode и...

Рассмотрим следующий код: @Test(singleThreaded = true) public class KafkaConsumerTest { private...

У него есть сообщение Кафки "Слишком много открытых файлов".Я только что перезапустил очистку, но...

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

У меня есть потребитель Cafka C1 в группе потребителей CG1, подписанный на тему T1. Недавно я...

У нас есть кластер CDH с kafka 0.8.2 и zookeeper 3.4.5, недавно zookeeper постоянно сообщал об...

у нас есть 3 машины kafka и 3 сервера zookeeper kafka1 - 1001 ( broker ID ) kafka2 - 1002 ( broker...

Я использую Spring Kafka и Spring Boot и просто задаюсь вопросом, как настроить моего потребителя,...

Я только начинаю узнавать о теме / разделах Kafka, поэтому у меня есть случай, когда у меня есть 1...

Я бы хотел использовать Alpakka Kafka Connector для записи в тему Kafka из приложения, созданного в...

Я пытаюсь интегрировать Кафку с топологией Герона.Однако я не могу найти никаких примеров с...

У нас есть столбец id для увеличения столбца в kafka-connect.Мне было интересно, если я просто...

У меня следующая проблема: Я получаю сообщения, созданные производителем с задержкой (иногда до...

Я пытаюсь определить ключевых актеров из мира Кафки, с максимально простыми определениями, чтобы...

Скажите, у меня есть тема кафки с 10 разделами.Когда скорость передачи данных увеличивается, я могу...

Я пытаюсь разобрать логи из темы __consumer_offsets в kafka.Идея состоит в том, чтобы найти...

Я запихнул несколько сообщений в кафку-тему.Я изменил время хранения после этого на гораздо более...

Я пытаюсь понять, как глобально уникальные UUID генерируются для схем в реестре схем, но не могу...

Запуск kafka в контейнере и попытка создать новый контейнер pgsql на том же хосте. контейнер pgsql...

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

Согласно статье о мультитенантной кафке на heroku данные шифруются в состоянии покоя на базовых...