Я создал потребитель kafka, используя 'kafka-node', для файла события consumer

Spring Cloud Stream Kafka с включенной транзакцией и динамическим пунктом назначения.У меня есть...

Ошибка при запуске проекта весенней загрузки kafka. пружинный ботинок: 2.1.2. ВЫПУСК Версия Spring...

Какая разница? Можно ли использовать термины KafkaConsumer и KafkaListener взаимозаменяемо?

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

Допустим, я звоню poll() только один раз с некоторым тайм-аутом вместо while(true) {...poll...}...

Существует ли минимальная скорость сообщения в Гбит / с, необходимая для выбора Kafka для потоковой...

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

Любой параметр в Kafka Connect, чтобы указать, с какого раздела специально читать сообщения.По сути...

Мне нужно записать время, затраченное потребителем на весеннюю кафку.Так как метод kafkaListener...

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

У меня есть KafkaConsumer, где регистрируется следующая ошибка Heartbeat thread failed due to...

Мы используем Spring Cloud Stream для Kafka и ищем семантику «Однажды». У нас есть одно решение,...

Я работаю над загрузочным приложением Spring с spring kafka, которое прослушивает отдельную тему...

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

Я пытаюсь прочитать данные JSON из Kafka, используя следующий код: @source(type = 'kafka'...

В моем понимании, когда я хочу отправить фильм (4 ГБ) брокеру Kafka, один производитель отправит...

У меня есть потребитель kakfa, для которого enable.auto.commit имеет значение false . Всякий раз,...

Я использую семантику ровно один раз, предоставленную kafka. Поэтому мой продюсер пишет сообщение в...

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

Я хочу обработать тему при запуске приложения, используя Confluent dotnet client .Предположим...

У меня есть два кластера Kafka, IP-адреса для которых я динамически выбираю из базы данных. Я...

Я использую пружинный каркас и кафку с 6 потребительскими нитками.После того, как 2 потока одной...

В моем случае я создал соединитель JDBC kafka, извлек данные из таблицы оракулов и успешно отправил...

У меня есть asticsearch kafka-connect соединитель , использующий некоторые темы. Со следующей...