Еще вопрос, мы используем MockSchemaRegistryClient для тестирования. Выглядит так, что клиент не способен, регистрировать схему сам если ее там нет, т.е. необходимо схему доба...
Привет, кто-нибудь знает как можно выяснить какая последняя версия в io.confluent:kafka-avro-serializer http://packages.confluent.io/maven/?
Всем привет, кто-нибудь использует AWS S3 как kafka source? Если да, то какой connector используете?
Всем привет, кто-нибудь генерировал KSQL команды из уже существующих SQL команд?
Он же только как Sink работает?