apache-kafka

0зной

1ответ

Поведение потребителя Kafka для несуществующего смещения

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

1зной

1ответ

Как Флинк (источник Кафки) управляет смещениями?

Я использую Flink's FlinkKafkaConsumer09, и я задаюсь вопросом, где хранятся запасные части потребителя kafka? Я не могу найти их в Zookeeper или в теме смещения Кафки. Также инструмент kafka-consumer

0зной

1ответ

не может подключиться к Spotify Кафка контейнера, основные проблемы с подключением

спотыкаясь на основы с грузчиком и Кафки, не могу получить соединение клиента , что я сделал до сих пор 1) установленные Докер окна на окна 10. 2) открыть kitematic, и искал kafka, и выбрал spotify ka

4зной

1ответ

Весенняя ботинок для Кафки: как устранить предупреждение; лучшие практики

Мне было предложено, как захватить вывод журнала из приложения Spring Boot, которое выполняется как действие Java от Oozie. Моя первоначальная мысль заключалась в том, что можно было бы редактировать

1зной

1ответ

Использование Kafka вместо Redis для целей очереди

У меня есть небольшой проект, который использует Redis для задач очереди задач. Вот как это работает в принципе. У меня есть два компонента в системе: настольный клиент (может быть более чем один) и н

1зной

2ответ

Кафка Струйные - все экземпляры местный магазин, указывающие на ту же тему

Мы имеем следующую задачу: Мы хотим слушать на определенную Кафки тему и построить это «история» - так что для указанного ключа экстракте некоторые данные, добавьте его к уже существующему списку для

2зной

1ответ

Hbase Table.batch занимает 300 секунд, чтобы вставить 800 000 записей в таблицу

Я читаю json-файл размером 30 мб, обрабатываю для создания семейства столбцов и значений ключей. Затем создайте объект Put, вставьте rowkey и значения в него. Создайте список таких объектов put и вызо