Class Hierarchy
- java.lang.Object
- io.cloudevents.core.message.impl.BaseBinaryMessageReader (implements io.cloudevents.core.message.MessageReader)
- io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl<HK,
HV> - io.cloudevents.kafka.impl.KafkaBinaryMessageReaderImpl
- io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl<HK,
- io.cloudevents.kafka.CloudEventDeserializer (implements org.apache.kafka.common.serialization.Deserializer<T>)
- io.cloudevents.kafka.CloudEventMessageDeserializer (implements org.apache.kafka.common.serialization.Deserializer<T>)
- io.cloudevents.kafka.CloudEventMessageSerializer (implements org.apache.kafka.common.serialization.Serializer<T>)
- io.cloudevents.kafka.CloudEventSerializer (implements org.apache.kafka.common.serialization.Serializer<T>)
- io.cloudevents.kafka.impl.KafkaHeaders
- io.cloudevents.kafka.KafkaMessageFactory
- io.cloudevents.kafka.impl.KafkaProducerMessageWriterImpl<K>
- io.cloudevents.kafka.impl.KafkaSerializerMessageWriterImpl
- io.cloudevents.kafka.PartitionKeyExtensionInterceptor (implements org.apache.kafka.clients.producer.ProducerInterceptor<K,
V>)
- io.cloudevents.core.message.impl.BaseBinaryMessageReader (implements io.cloudevents.core.message.MessageReader)