kafka-consumer-api

0зной

1ответ

Я искал пакеты для узла, как это: https://www.npmjs.com/package/kafka и https://www.npmjs.com/package/no-kafka Мой вопрос: Есть ли эти пакеты делает node.js подписаться на Кафку все время? или Мне нуж

1зной

1ответ

Как подписаться на тему в apache kafka из приложения java?

Это потребитель для Apache Kafka и он не получает сообщения из темы «тест» package com.kafka; import java.util.Arrays; import java.util.Properties; import org.apache.kafka.clients.consumer.Consum

6зной

1ответ

Как обрабатывать ошибки и не совершать при использовании Kafka Streams DSL

Для потоков Kafka, если мы используем API-интерфейс более низкого уровня, мы можем управлять фиксацией или нет. Поэтому, если в нашем коде возникают проблемы, и мы не хотим передавать это сообщение. В

2зной

1ответ

Spark Streaming - пакетный интервал против времени обработки

У нас есть Spark Streaming application, работающий на кластере YARN. Он получает сообщения от Kafka topics. Фактически наше время обработки больше, чем интервал между партиями. Batch Interval : 1 Minu

0зной

1ответ

Как удалить тему, которая запускается в многоуровневом многоуровневом кластере HA kafka

Я установил kafka версию 2.11-0.10.1.0 в многоуровневую многокластерную среду. В kafka server.properties я уже добавил delete.enable.topic = true в все 3 машины. Я использую команду для удаления темы

0зной

1ответ

Спарк Direct Streaming - потреблять такое же сообщение в нескольких потребителей

Как потреблять Kakfa topic messages в нескольких потребителей с помощью Direct Stream approach? Возможно ли это? Поскольку подход Direct Stream не имеет концепции Consumer Group. Что происходит, если