Я управляю кластером 4 брокеров Kafka в Kubernetes.Коэффициент репликации равен 3, а ISR равен 2....

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

Насколько я понимаю, разделы и потребители связаны соотношением 1: 1, в котором один пользователь...

Я новичок в Kafka и пробовал пакет Kafka-Python. Мне удалось настроить простого производителя и...

У меня есть несколько списков, которые я хочу отправить через производителя Kafka. listA [1,2,3]...

Я использую локальный сервер KSQL (последняя версия Confluent Platform), пытаюсь подключиться к...

Я пытаюсь отправить несколько .mp4 файлов в виде сообщений потока kafka. Я пытался использовать тот...

Я новичок в Kafka и установил kafka в Windows 10, используя шаги в https://kafka.apache

Я пытаюсь настроить SSL для REST API Kafka Connect (2.11-2.1.0). Проблема Я попробовал две...

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

Я следовал рекомендациям https://github.com/abajwa-hw/ambari-flink-service.git.. Я подтвердил в...

Мы используем версию spring kafka (2.1.5.RELEASE). После нашего тестирования производительности при...

У меня есть приложение на Python, которое читает из 2 тем. Один из них похож на пакетный процесс...

Я работаю над масштабированием кластера kafka в Prod. Confluent предоставляет простой способ...

После обновления нашей конфлюэнтной кафки с 3.3.2 до 5.1.4 невозможно запустить брокер с...

Существует ли какая-либо опция или конфигурация, которая облегчит одному потребителю Kafka...

Я новичок в Kafka и пытаюсь создать библиотеку-обертку на Java и Go (использует Confluent /...

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

Я пытаюсь пройтись по исходному коду Apache Camel, чтобы определить источник ошибки.Я продолжаю...

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

Я сделал инкрементную синхронизацию данных с помощью kafka connect.Теперь я хочу добиться того же с...

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

Мне нужно получать последнее смещение для всех разделов темы каждые N секунд (для целей...

Я хочу иметь пул потребителей и повторно использовать каждого потребителя. Это правильно?...

Я использую пружинную кафку с идемпотентной конфигурацией производителя: это мои реквизиты...