спасибо, будем пробовать

Добрый день, кто работал с Kafka-REST
WARN Property bootstrap.servers is not valid (kafka.utils.VerifiableProperties:87)
https://github.com/confluentinc/kafka-rest/issues/425

кто знает как победить?

тикет естЬ, но за 2 года в него так и не ответили

Всем привет,
у кого есть пример spring-kafka, кто как использует kafka в Spring Framework?
Ранее уже работал с этим, но довольно сложно все получилось, особенно с этими конфигами. Вот такую обертку даже написал - что мне кажется какой-то ошибкой, было бы здорово если покажут как надо - https://pastebin.com/DPQ3Mycr.

а мой блог чем плох?

https://www.confluent.io/blog/spring-for-apache-kafka-deep-dive-part-2-apache-kafka-spring-cloud-stream/ мб оно

Я вот про вот это скорее https://www.confluent.io/blog/schema-registry-avro-in-spring-boot-application-tutorial

У кого-то уже есть опыт настройки mirror maker 2 на неравнозначные кластера? 3 nodes -> 1\2 nodes
системные топики *.internal создались на обоих кластерах, но репликация не происходит.
настраиваю по схеме https://cwiki.apache.org/confluence/display/KAFKA/KIP-382%3A+MirrorMaker+2.0#KIP-382:MirrorMaker2.0-RunningadedicatedMirrorMakercluster

Ребятки, у меня есть кафка стримовое приложение с настроенным static membership. Оно вроде нормально работает. Но периодически оно уходит в цикл ребалансов. Почему это может происходить? Таймауты вроде большие достаточно. Ноды не перезагружаются.

# specify any number of cluster aliases
clusters = source, target

# enable and configure individual replication flows
source->target.enabled = true
source->target.topics = mirroring-test-topic

Ну, и конечно # connection information for each cluster
source.bootstrap.servers =
target.bootstrap.servers =

Привет! Можно ли организовать очереди на кафке для следующего кейса? В течении дня периодически подсчитываются данные статистики и отправляются в очередь. Консюмер читает очередь и берет только последнюю версию данных за этот день. Данные - это массив записей (несколько млн). Из этой последней версии статистики по дню консюмер забирает данные батчами по 1000 шт. Также может быть что в очередь попадают данные по нескольким дням - в любом случае нужно брать последнюю версию каждого дня

имею ввиду репликацию между серверами, где в одном 3 ноды, а в другом 1 нода

Ну да. Если каждый кластер в отдельности правильно настроен, то все должно работать

Еще важно, где запускается сам репликатор

я запускаю на той же тачке, в которую собираюсь лить данные

а какая разница?

Видны ли ему advertised hosts