Я использую kafka_2.11-2.2.1. У меня ниже настройки в server.properties. message.max.bytes=20971520...

Я пытаюсь проверить состояние транзакции между Kafka и вызовом БД (Postgres), когда в случае сбоя...

Я использую kafka-python в проекте django. Инициализировал производителя в файле settings.py....

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

Я новичок в Spring Cloud Stream и Kafka. Я получаю следующую ошибку от производителя kafka при...

У меня есть функция без сервера, которая пытается отправить некоторые данные в kafka. Иногда это...

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

Я установил Docker на мою Windows 10, а также установил Kafka. Я создал тему " test " внутри...

У меня есть приложение Kerberized с пружинной загрузкой, которое соединяет Кафку, и Кафка не...

Я хотел понять, имея большое количество потребителей по задержке производителей и брокеров. У меня...

Я создаю производителя тем kafka со следующими конфигурациями acks - all max.in.flight.requests.per

Exception Stacktrace: org.springframework.kafka.core.KafkaProducerException: Failed to send; nested...

Я пытаюсь получить оперативные данные из openweathermap.org API с помощью kafka Producer python....

В моем потоковом приложении Scala (2.11) я потребляю данные из одной очереди в IBM MQ и записываю...

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

Цель: Подсчитать все успехи и неудачи производителя Kafka при отправке async . Проблема: Иногда...

Я новичок в Apache Kafka и немного любитель Ubuntu, на котором я его запускаю (Ubuntu 18.04 и Kafka...

У меня есть кластер Apache Kafka с 3-мя брокерами, и я хотел бы определить, когда кластер больше не...

После увеличения времени для session_timeout и request_timeout мой потребитель kafka не получает...

Я бы хотел зарегистрировать оба случая, когда сообщение было либо успешно опубликовано, либо по...

У нас есть микросервисная архитектура в нашем проекте. Существует микросервис, в котором...

У меня есть следующий файл docker-compose: version: '3.1' services: postgres_db: image:...

У меня есть извлечение данных из Cisco Prime API, который, помимо прочего, содержит MAC-адрес точек...

Я устанавливаю новый сервер весенней загрузки с kafka, и создаю KafkaProducer / KafkaConsumer с...

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