Class AvroSerdeHeaders


  • public class AvroSerdeHeaders
    extends Object
    Author:
    Fabian Martinez
    • Constructor Detail

      • AvroSerdeHeaders

        public AvroSerdeHeaders​(boolean isKey)
    • Method Detail

      • addEncodingHeader

        public void addEncodingHeader​(org.apache.kafka.common.header.Headers headers,
                                      String encoding)
      • getEncoding

        public String getEncoding​(org.apache.kafka.common.header.Headers headers)