Я пытаюсь установить свойства на Conusmer / Producer с Kafka Stream / @ StreamListener Kstream, но не могу заставить его работать;
spring.cloud.stream.kafka.streams.bindings.channel.consumer|producer.**configuration**.x
Свойства, которые меня больше всего интересуют
- key.serializer | deserializer
- value.serializer | deserializer
- partitioner.class
Мой поток таков:
Message Channel--- send TypeInfo @Input(request)--Kstream process @input(request) and @Output(response)---No TypeInfo--Kstream @Input(response)---DeserilaizationError
Я понимаю, что если я могу изменить вышеупомянутые свойства, я должен быть в состоянии достичьчто я пытаюсь сделать, пожалуйста, предложите иначе, ниже приведены версии, которые я использую
<spring.boot.version>2.1.3.RELEASE</spring.boot.version>
<spring.cloud.stream.version>2.1.1.RELEASE</spring.cloud.stream.version>
пример / предложение, которое я нашел об этих свойствах, здесь https://github.com/donalthurley/KafkaConsumeScsAndConfluent/blob/c763a32f0a6ec0099e4fad65f662fb09b06249b6/src/main/resources/application.yml