Module io.cloudevents.kafka
Package io.cloudevents.kafka.impl

Class KafkaSerializerMessageWriterImpl

java.lang.Object
io.cloudevents.kafka.impl.KafkaSerializerMessageWriterImpl
All Implemented Interfaces:
io.cloudevents.core.message.MessageWriter<io.cloudevents.rw.CloudEventWriter<byte[]>,byte[]>, io.cloudevents.core.message.StructuredMessageWriter<byte[]>, io.cloudevents.rw.CloudEventContextWriter, io.cloudevents.rw.CloudEventWriter<byte[]>, io.cloudevents.rw.CloudEventWriterFactory<io.cloudevents.rw.CloudEventWriter<byte[]>,byte[]>
public final class KafkaSerializerMessageWriterImpl extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    KafkaSerializerMessageWriterImpl(Headers headers)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    KafkaSerializerMessageWriterImpl
    create(io.cloudevents.SpecVersion version)
     
    byte[]
    end()
     
    byte[]
    end(io.cloudevents.CloudEventData value)
     
    byte[]
    setEvent(io.cloudevents.core.format.EventFormat format, byte[] value)
     
    io.cloudevents.kafka.impl.BaseKafkaMessageWriterImpl<byte[]>
    withContextAttribute(String name, String value)
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface io.cloudevents.rw.CloudEventContextWriter

    withContextAttribute, withContextAttribute, withContextAttribute, withContextAttribute, withContextAttribute, withContextAttribute

    Methods inherited from interface io.cloudevents.core.message.MessageWriter

    writeBinary, writeStructured, writeStructured

  • Constructor Details

    • KafkaSerializerMessageWriterImpl

      public KafkaSerializerMessageWriterImpl(Headers headers)

  • Method Details

    • create

      public KafkaSerializerMessageWriterImpl create(io.cloudevents.SpecVersion version)

    • end

      public byte[] end()

    • withContextAttribute

      public io.cloudevents.kafka.impl.BaseKafkaMessageWriterImpl<byte[]> withContextAttribute(String name, String value) throws io.cloudevents.rw.CloudEventRWException
      Specified by:
      withContextAttribute in interface io.cloudevents.rw.CloudEventContextWriter
      Throws:
      io.cloudevents.rw.CloudEventRWException

    • end

      public byte[] end(io.cloudevents.CloudEventData value) throws io.cloudevents.rw.CloudEventRWException
      Specified by:
      end in interface io.cloudevents.rw.CloudEventWriter<R>
      Throws:
      io.cloudevents.rw.CloudEventRWException

    • setEvent

      public byte[] setEvent(io.cloudevents.core.format.EventFormat format, byte[] value) throws io.cloudevents.rw.CloudEventRWException
      Specified by:
      setEvent in interface io.cloudevents.core.message.StructuredMessageWriter<R>
      Throws:
      io.cloudevents.rw.CloudEventRWException