Package io.deephaven.kafka.protobuf

Interface Protocol

All Known Implementing Classes:
Protocol.Impl
public interface Protocol
The serialization / deserialization protocol.
See Also:

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Interface
    Description
    static enum 
    Protocol.Impl
     

  • Method Summary

    Static Methods
    Modifier and Type
    Method
    Description
    static Protocol
    raw()
    The raw Protobuf protocol.
    static Protocol
    serdes()
    The Kafka Protobuf serdes protocol.

  • Method Details

    • serdes

      static Protocol serdes()
      The Kafka Protobuf serdes protocol. The payload's first byte is the serdes magic byte, the next 4-bytes are the schema ID, the next variable-sized bytes are the message indexes, followed by the normal binary encoding of the Protobuf data.
      Returns:
      the Kafka Protobuf serdes protocol
      See Also:

    • raw

      static Protocol raw()
      The raw Protobuf protocol. The full payload is the normal binary encoding of the Protobuf data.
      Returns:
      the raw Protobuf protocol
      See Also: