public class ProtoConverter<T extends com.google.protobuf.Message> extends Object implements org.apache.kafka.connect.storage.Converter
Constructor and Description |
---|
ProtoConverter(com.google.protobuf.Parser<T> parser) |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs,
boolean isKey) |
byte[] |
fromConnectData(String topic,
org.apache.kafka.connect.data.Schema schema,
Object value) |
org.apache.kafka.connect.data.SchemaAndValue |
toConnectData(String topic,
byte[] bytes) |
public ProtoConverter(com.google.protobuf.Parser<T> parser)
public void configure(Map<String,?> configs, boolean isKey)
configure
in interface org.apache.kafka.connect.storage.Converter
public byte[] fromConnectData(String topic, org.apache.kafka.connect.data.Schema schema, Object value)
fromConnectData
in interface org.apache.kafka.connect.storage.Converter
public org.apache.kafka.connect.data.SchemaAndValue toConnectData(String topic, byte[] bytes)
toConnectData
in interface org.apache.kafka.connect.storage.Converter
Copyright © 2020 Red Hat. All rights reserved.