Так целевая аудитория не такая большая вот и цена соответствующая. Если бы каждая домохозяйка использовала то может и по 1$ в месяц подписка была бы.

​​Если вы по какой-то причине пропустили, то вот вам еще напоминалка.
Long read на блоге Confluent, где ребята рассказывают как работают foreign-key join-s в Kafka Stream. С примерами, картинками (и даже тестами).
На самом деле фича появилась еще в 2.4. И работа была проделана титаническая (см. KIP-213.
Ну если зачисались руки попробовать вот тут можно туториальчик попробовать.
Всем успехов!

Даёшь больше нормальных UI

День добрый!
kafka.security.auth.SimpleAclAuthorizer
пытаюсь удалять ACL
выводит список того что "удаляет" и ничего не делает

... --remove --deny-principal User:* --operation ALL   --group "*"  --topic "*" --force

может кто подскажет что не так?

Выглядит так, что у пользователя, от имени которого пытаетесь удалить правило не супер пользователь или нет разрешения удалять ACL

Перед удалением показывает строку, которую удаляет, если убрать форс?
Попробуй добавить хост в запрос

--allow-host ... , если правильно помню по памяти

да показывает

Добрый день, коллеги! Щас читаю топик из кафка питон скриптом, а как можно метадату получить? интересует timestamp ( you need to use the offsetsForTimes() method.)

Таймстемп сообщений?

да

Если правильно помню, они вместе с сообщениями шли (также как оффсеты, хедеры, и тд)

спасибо щас поищу

Сорян, поспешил с ответом - попробовал, тоже 0 получил по умолчанию

Привет всем, буду благодарен за помощь..

нужны варианты что может быть

Данные тестирования:

1) 4 консюмера в разных окнах терминала - использовался консольный кафка-консумер, общая группа, общий топик

2) продюсер из java кода, он ложит в топик сообщения, равномерно по всем 4 партициям топика

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

подключаются мои 4 консюмера с одной группой, тянут корректно равномерно в первый раз сообщения


ок, кладу снова, и тут что-то клинит, не хотят больше сообщения тянуть

конфигов так таковых и нет, все дефолту там, я из кода консумера, просто указываю топик и группу

в продюсере указал только топик в java коде

Консюмеры корректно партиции между собой распределяют

нужны теории что может быть, почему не работает

Всем привет вопрос странный немного будет, но все таки) есть топик из которого читает мое приложение, преобразует ивент и пушит в другой топик. В первом топике лежит 300к записей и 280к тотал консумер лаг. Во втором топике 150к записей. Тоесть приложение как то смогло вычитать 150к записей из первого топика и отправить во второй, но консумер лаг не уменьшается в чем дело? У меня manual commit, ручками в коде вызываю ack