class KafkaRecordCoder extends StructuredCoder<KafkaRecord<K, V>> {

  public static <K, V> KafkaRecordCoder<K, V> of(Coder<K> keyCoder, Coder<V> valueCoder) {
    return new KafkaRecordCoder<>(keyCoder, valueCoder);
  }

  public  KafkaRecordCoder(Coder<K> keyCoder, Coder<V> valueCoder);

}