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

Я часто получаю исключения по таймауту по разным причинам у моего продюсера Kafka.В настоящее время...

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

Я использую Kafka 2.1.0 и хочу опубликовать сообщение после подписки.Есть ли способ для...

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

Добрый день, Я хотел бы выяснить, может ли очередь kafka хранить данные в течение нескольких секунд...

У нас есть настройка брокера kafka во внутреннем облаке.Мы находим фактический URL с помощью...

ОШИБКА Обнаружена недопустимая ошибка документа при выполнении пакета 606 из 1 записей.Ошибка была...

Недавно я проверяю код кафки и тестирую.Я обнаружил странный случай: я печатаю байтовый буфер на...

Я использую kafka-connect-elasticsearch с пользовательским конвертером, который расширяет стандарт...

zookeeper.session.timeout.ms: время ожидания сеанса ZooKeeper.Если потребитель не сможет отправить...

Spring-Kafka: При приостановке / возобновлении работы потребителя с использованием метода паузы /...

У меня есть json публикация в одной из моих тем по kafka: { "hash": "ABC",...

Похоже, что AWS Kinesis Firehose - это способ ввода данных (буферизованных вместе) в объект, есть...

Обычно я пытаюсь получить все столбцы, когда использую выражение group by в своем запросе. Создание...

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

В приложении Node js, когда я пытаюсь отправить сообщения на тему Kafka, все собираются в Раздел 0....

У меня следующий сценарий, и я хотел бы понять ожидаемое поведение. Создано Kafka Consumer Kafka...

Здравствуйте, я пишу kafka-потребителя-производителя с использованием весеннего облачного потока

Когда я проверяю на потребительскую задержку, это показывает, что конкретный consumer-id работает с...

Я столкнулся с некоторой проблемой при использовании Кафки.Любая помощь высоко ценится!У меня есть...

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

Мы используем стратегию ручного коммита.Мы настроили компонент, который фиксирует все успешно...

Мы пытаемся скопировать данные из таблицы базы данных в Kafka, используя Confluent JDBC-Source...

Слишком много TCP-соединений находятся в состоянии CLOSE_WAIT в брокере kafka, что вызывает...