kafka-consumer-api

0зной

1ответ

Как читать записи из Кафки с использованием Kafka-Stream через интервал

Я хочу использовать в Kafka-Stream потребителя для чтения записей из Kafka, есть возможность читать записи за каждый интервал? например, каждые 1 минуту?

1зной

1ответ

Невозможно отключить ручные комманды в сообщении Kafka с помощью Spring-integration-kafka в приложении Spring-Boot

Поскольку я новичок в kafka, моя группа использует Spring-Integration-kafka: 2.0.0.RELEASE в приложении Spring-boot. Я смог использовать kafka сообщение с моим KafkaConsumer на основе этого примера he

1зной

2ответ

Производитель/потребитель командной строки Kafka имеет 1 секунду латентности

Я делаю тестовый прогон с Kafka, используя производителя и потребителя командной строки. Я бегу это в одном окне терминала bin/kafka-console-producer.sh --broker-list localhost:9092 --topic tag7 и э

1зной

1ответ

Поведение потребительской синхронизации Kafka

В настоящее время я изучаю kafka как новичок для простой проблемы. Там будет один Производитель толкая сообщение одному из Темы но будет быть п числа Потребительского искрового применения массаж данны

0зной

2ответ

Как отправить kafka соответствующие данные в другую тему

Как нажимать соответствующие данные между темой 1 и темой 2 в другой теме 3? при отправке сообщений от производителя к потребителю?

1зной

3ответ

Флинк с Kafka как источник

Я пытаюсь прочитать данные из темы kafka, в потоке Flink. Я пытаюсь запустить следующий пример кода, который существует в качестве примера на странице APACHE FLiNK 1.1.3 Документация: разъем Apache Ка

0зной

1ответ

Kafka Потребитель по разделам

Привет, группы потребителей, можно сказать потребителю только чтение определенного раздела? От того, что я читал и видел до сих пор, это не похоже на это или я что-то пропустил?