Достать сообщение из kafka по timestamp
Пытаюсь вычитать сообщение по timestamp. На методе .seek вылетает исключение "No current assignment for partition...". consumer подписывается на топик методом .subscribe…
Вопросы по тегу: apache-kafka
- -2 ▲1 ответ.
- 2 ▲1 ответ.
kafkajs disconnect занимает много времени
Использую либу kafkajs для автотестов. При вызове await consumer.disconnect() - команда выполняется около 5ти секунд, есть какие-то варианты безопасного и быстрого дисконнекта?
- 1 ▲1 ответ.
Как получить сообщения из топика Kafka?
Написал типичную функцию для получения и обработки сообщений из топика Kafka. В качестве инструментов использую язык Python и модуль Confluent Kafka. При использовании метода poll…
- 1 ▲0 ответ.
Clickhouse заходит в кафку по порту отличному от указанного в настройках
В конфиге не указан порт, а только креды на подключение. В таблице clickhous'а указан порт, который нужен для доступа к топику kafka, я там выставил порт 9093. /etc/clickhouse-ser…
- 0 ▲1 ответ.
Какие подходы используете для иницилизации "нулевого" состояния для нового микросервиса в экосистеме Kafka?
Стандартная EDA архитектура с Kafka. События удаляются через какое-то время (пусть будет неделя). Собственно, каждый микросервис по получении событий собирает копию тех данных, ко…
- 1 ▲0 ответ.
Как передать в топик Kafka финальный groupBy()
Прошу Вас помочь разобраться с KafkaStreams. Есть код, который делает обычный groupBy(): public static void createGroupByStream(final StreamsBuilder builder) { KStream<String, …
- 1 ▲0 ответ.
Удаляются кластеры в kafka tool 2.0.1
Каждое утро при входе в кафка тул, обнаруживаю, что все коннекты удалены. Приходится заново подключаться вручную. Можно как-то решить эту проблему?
- 0 ▲1 ответ.
Распределение сообщений в партициях кафки
Начинаю использовать Кафку в проекте и не могу разобраться в нескольких вопросах. Каждый топик в Кафке разбит на партиции и продюсеры при записи событий с key=null в топик в класс…
- 1 ▲0 ответ.
Сериализация даты как timestamp при записи в кафку
У меня есть json, и в нем есть поле с датой startDt=2023-01-17T08:59:42.522476Z[UTC], когда я кладу json в кафку, то данное поле принимает там значение 1673945982.817186000, нужно…