Package org.springframework.cloud.stream.binder.kafka.streams

Class KafkaStreamsMessageConversionDelegate

java.lang.Object
org.springframework.cloud.stream.binder.kafka.streams.KafkaStreamsMessageConversionDelegate
public class KafkaStreamsMessageConversionDelegate extends Object
Delegate for handling all framework level message conversions inbound and outbound on KStream. If native encoding is not enabled, then serialization will be performed on outbound messages based on a contentType. Similarly, if native decoding is not enabled, deserialization will be performed on inbound messages based on a contentType. Based on the contentType, a MessageConverter will be resolved.
Author:
Soby Chacko

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.kafka.streams.kstream.KStream
    deserializeOnInbound(Class<?> valueClass, org.apache.kafka.streams.kstream.KStream<?,?> bindingTarget)
    Deserialize incoming KStream based on content type.
    org.apache.kafka.streams.kstream.KStream
    serializeOnOutbound(org.apache.kafka.streams.kstream.KStream<?,?> outboundBindTarget)
    Serialize KStream records on outbound based on contentType.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • serializeOnOutbound

      public org.apache.kafka.streams.kstream.KStream serializeOnOutbound(org.apache.kafka.streams.kstream.KStream<?,?> outboundBindTarget)
      Serialize KStream records on outbound based on contentType.
      Parameters:
      outboundBindTarget - outbound KStream target
      Returns:
      serialized KStream

    • deserializeOnInbound

      public org.apache.kafka.streams.kstream.KStream deserializeOnInbound(Class<?> valueClass, org.apache.kafka.streams.kstream.KStream<?,?> bindingTarget)
      Deserialize incoming KStream based on content type.
      Parameters:
      valueClass - on KStream value
      bindingTarget - inbound KStream target
      Returns:
      deserialized KStream