Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

1.  New ProducerConfig to support Composable Serializer

Configuration

KeyDescriptionTypeDefaultRequired
value.serializersList of serializers class that implements the `org.apache.kafka.common.serialization.Serializer` interface in order. The first serializer is `Serializer<T>` while the remaining serializers must be `Serializer<byte[]>`. Can't be configured with value.serializer at the same time.List<Serializer>NoneNo, If not exist the code will fail back to value.serializer. Can't exist with  value.serializer
key.serializersList of serializers class that implements the `org.apache.kafka.common.serialization.Serializer` interface in order. The first serializer is `Serializer<T>` while the remaining serializers must be `Serializer<byte[]>`.  Can't be configured with key.serializer at the same time.List<Serializer>NoneNo, If not exist the code will fail back to key.serializer. Can't exist with key.serializer


2. New ConsumerConfig to support Composable Deserializer

Configuration

KeyDescriptionTypeDefaultRequired
value.deserializersList of deserializer classes that implements the `org.apache.kafka.common.serialization.Deserializer` interface in order. The last deserializer must be `Deserializer<T>` while the rest must be `Deserializer<byte[]>`.  Can't be configured with value.deserializer at the same time.List<Deserialzer>NoneNo, If not exist the code will fail back to value.deserializer. Can't exist with value.deserializer
key.deserializersList of deserializer classes that implements the `org.apache.kafka.common.serialization.Deserializer` interface in order. The last deserializer must be `Deserializer<T>` while the rest must be `Deserializer<byte[]>`. Can't be configured with key.deserializer at the same time.List<Deserialzer>NoneNo, If not exist the code will fail back to key.deserializer. Can't exist with key.deserializer

3. org.apache.kafka.common.serialization.largemessage.Serializer<byte[]>

...