apache-kafka

0зной

1ответ

Работа с Kafka Spark-Streaming. Возможность читать и обрабатывать данные, отправленные от Продюсера. У меня есть сценарий здесь, давайте предположим, что продюсер создает сообщения, а Consumer отключа

0зной

1ответ

Каков наилучший подход для сохранения двух кластеров kafka в Sync

Мне нужно настроить два кластера kafka в двух разных центрах обработки данных (DC), которые имеют одинаковые темы и конфигурацию. причина в том, что связь между двумя центрами данных является неприятн

2зной

2ответ

Флинк не совершает смещения в kafka

У меня есть работа по потоку flink, которая считывает данные с kafka и просто регистрирует ее. Я включил контрольно-пропускные пункты. Я не вижу замеченных смещений в kafka, вместо этого я становлюсь

0зной

1ответ

Совместимость с Spring Kafka 1.1.3-SNAPSHOT с Kafka 0.10.1.1

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

0зной

1ответ

Как разрешить зависимость org.apache.kafka.clients.producer.Producer в проекте maven как производитель java для apache kafka

Это контроллер для моего веб-приложения java. упаковка com.proj.controller; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping;

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 машины. Я использую команду для удаления темы