Этот класс был добавлен в Kafka 1.0.0 - KAFKA-5650
К счастью, более новые библиотеки Kafka Streams обратно совместимы с брокерами 0.11.0 (при условии, что именно поэтому вы выбрали эту версию)
Я заметил, что ваше имя класса - "test jdbc", поэтому я бы предложил использовать существующий продукт Kafka Connect JDBC, а не начинать его заново.
Я хотел преобразовать данные входящего потока, используя функцию kstream.transform (), а затем передать преобразованные данные в таблицу базы данных Oracle VIA JdbcSinkConnector
Возможно, вы захотите попробовать сделать или использовать Simple Message Transform (SMT) вместо этого. Позвольте соединителю JdbcSink обрабатывать получение записей из Kafka для вас, а конфигурация свойств для Соединителя находится в отдельном месте и может использоваться повторно, а не специфично для вашего кода.
Интерфейс Преобразование имеет один метод apply(), который позволяет преобразовать сообщение так, как вы хотите, что по сути является той же концепцией, что и kstream.map(...).to("topic"), но пункт назначения не является отдельной темой Кафки