Спецификация канала Spring Cloud Stream для потребителя / производителя
Я пытаюсь установить свойства в Conusmer/Producer с Kafka Stream/@StreamListener Kstream, но не могу заставить его работать;
spring.cloud.stream.kafka.streams.bindings.channel.consumer|producer.**configuration**.x
Свойства, которые меня больше всего интересуют
- key.serializer | десериализатор
- значение. сериализатору | десериализатор
- 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