title: Spring Cloud StreamListener @Output KStream Serdes dont seem to work
body: <p>I have a Stream Listener as</p>
  
  <pre><code>@StreamListener(target = "requesti")
  @SendTo("responseo")
  public KStream&lt;UUID,Account&gt; process(KStream&lt;UUID, Account&gt; events) {
      // Predicate&lt;UUID, Event&gt; isAccount = (key, value) -&gt;
      // value.getEntity().getClass().equals(Account.class);
  
      // @formatter:off
      return events
              //.filter(isAccount)
              .peek((key, value) -&gt; {
                  log.debug("Processing {} {}", key, value);
              });
              /*
              .filter(isAccount)
              .map((key, value) -&gt; process(value))
  
              .peek((key, value) -&gt; {
                  log.debug("Processed {} {}", key, value);
              });
              */
      // @formatter:on
  
  }
  </code></pre>
  
  <p>Where the @Input("requesti") config is as follows;</p>
  
  <pre><code>spring.cloud.stream.kafka.streams.bindings.requesti.consumer.application-id=repo-event-consumer
  spring.cloud.stream.bindings.requesti.destination=request
  spring.cloud.stream.bindings.requesti.content-type=application/json
  spring.cloud.stream.bindings.requesti.consumer.header-mode=raw
  </code></pre>
  
  <p>and the @output("responseo") config is as follows</p>
  
  <pre><code>spring.cloud.stream.kafka.streams.bindings.responseo.consumer.application-id=repo-response-producer
  spring.cloud.stream.bindings.responseo.destination=response
  spring.cloud.stream.bindings.responseo.content-type=application/json
  spring.cloud.stream.bindings.responseo.producer.header-mode=raw
  spring.cloud.stream.bindings.responseo.producer.use-native-encoding=true
  spring.cloud.stream.kafka.streams.bindings.responseo.producer.key-serde=org.springframework.kafka.support.serializer.JsonSerde
  spring.cloud.stream.kafka.streams.bindings.responseo.producer.value-serde=org.springframework.kafka.support.serializer.JsonSerde
  </code></pre>
  
  <p>My Processor recieves a request and can send output as well, but the out put is as follows</p>
  
  <p>[Producer clientId=<strong>repo-event-consumer</strong>-49827b40-2357-4af0-8103-228343faa59e-StreamThread-1-producer] Sending record ProducerRecord(topic=response, partition=null, headers=RecordHeaders(headers = [RecordHeader(key = <strong>TypeId</strong>, value = [117, 107, 46, 111, 114, 103, 46, 99, 97, 116, 97, 112, 117, 108, 116, 46, 101, 115, 46, 99, 117, 98, 101, 46, 115, 101, 114, 118, 105, 99, 101, 115, 46, 97, 99, 99, 111, 117, 110, 116, 46, 109, 111, 100, 101, 108, 46, 65, 99, 99, 111, 117, 110, 116])], isReadOnly = true), key=[B@6a5e4294, value=[B@5a0852e1, timestamp=1551093349173) with callback org.apache.kafka.streams.processor.internals.RecordCollectorImpl$1@336dbba5 to topic response partition 2</p>
  
  <p>Few Things i am confused with Producer Record id is not "repo-response-producer" and secondly key-serde/value-serde is not used, in my mind it should have been </p>
  
  <p>Sending record ProducerRecord(topic=request, partition=null, headers=RecordHeaders(headers = [RecordHeader(key = <strong>Key_TypeId</strong>, value = [106, 97, 118, 97, 46, 117, 116, 105, 108, 46, 85, 85, 73, 68]), RecordHeader(key = <strong>TypeId</strong>, value = [117, 107, 46, 111, 114, 103, 46, 99, 97, 116, 97, 112, 117, 108, 116, 46, 101, 115, 46, 99, 117, 98, 101, 46, 115, 101, 114, 118, 105, 99, 101, 115, 46, 97, 99, 99, 111, 117, 110, 116, 46, 109, 111, 100, 101, 108, 46, 65, 99, 99, 111, 117, 110, 116])], isReadOnly = true), key=6f0f50e2-3add-4d22-a370-cac66d016af0, value=Account() with callback org.springframework.kafka.core.KafkaTemplate$$Lambda$582/533392019@85ab964 to topic request partition 2</p>
  
  <p>and the default serdeConfig is   </p>
  
  <pre><code>    spring.cloud.stream.kafka.streams.binder.configuration.default.key.serde=org.springframework.kafka.support.serializer.JsonSerde
  spring.cloud.stream.kafka.streams.binder.configuration.default.value.serde=org.springframework.kafka.support.serializer.JsonSerde
  </code></pre>
  
  <p><a href="https://github.com/zafarale/catapult/invitations" rel="nofollow noreferrer">Repo</a></p>