Спасибо, эти все ограничения подхода я понимаю. В этом плане, я

специально ушел от map к Transformer,
чтоб хотя бы соединение с внешним источником устанавливать один раз, а не на каждое событие.
И иметь возможность прикрутить кеширование ответов от внешней системы.
Хотелось бы еще, сделать батчевый запрос к внешней системе, но я не нашел аналога Transformer,
который на обработку принимал бы сразу пачку событий. Плохо искал?

Ну раз ты так усилено советуешь мне полностью начать жить в экосистеме кафки.
Задам вопрос и по ней:
Есть у меня поток данных, который надо обогатить информацией, допустим из 10 справочников.
Правильно ли я понимаю, что мне надо будет сделать 10 раз:
streams.selectKey(<ключ справочника>)
На сколько это влияет на производительность?
И второй вопрос selectKey все также не позволяет указать новый Serde ключа?
https://issues.apache.org/jira/browse/KAFKA-4612
И мне все ключи справочников надо приводить к одному типу?

А как часто справочники меняются?