Class ProtobufSerdeHeaders

    • Constructor Detail

      • ProtobufSerdeHeaders

        public ProtobufSerdeHeaders​(Map<String,​Object> configs,
                                    boolean isKey)
        Constructor.
        Parameters:
        configs -
        isKey -
    • Method Detail

      • getProtobufTypeName

        public String getProtobufTypeName​(org.apache.kafka.common.header.Headers headers)
      • addProtobufTypeNameHeader

        public void addProtobufTypeNameHeader​(org.apache.kafka.common.header.Headers headers,
                                              String protobufTypeName)