Потоки на самом деле не настроены для поддержки подобного варианта использования, хотя это часто обсуждается под заголовком «асинхронная обработка», и мы хотели бы разработать его в будущем.
ПравильноТеперь, если вы действительно хотите использовать Streams, лучше всего было бы обернуть логику сохранения БД внутри собственного процессора или преобразователя, который также буферизует записи и отправляет пакеты, когда этого достаточно.
ОднакоЕсли вам действительно нужно просто «скопировать» данные из темы в БД, вы можете получить больше пользы от использования Connector или даже непосредственно от Kafka Consumer.
Надеюсь, это поможет!