C D I K S

C

close() - Method in class io.confluent.kafka.streams.serdes.protobuf.KafkaProtobufSerde

configure(Map<String, ?>, boolean) - Method in class io.confluent.kafka.streams.serdes.protobuf.KafkaProtobufSerde

D

deserializer() - Method in class io.confluent.kafka.streams.serdes.protobuf.KafkaProtobufSerde

I

io.confluent.kafka.streams.serdes.protobuf - package io.confluent.kafka.streams.serdes.protobuf

K

KafkaProtobufSerde<T extends com.google.protobuf.Message> - Class in io.confluent.kafka.streams.serdes.protobuf

A schema-registry aware serde (serializer/deserializer) for Apache Kafka's Streams API that can be used for reading and writing data in Protocol Buffers format.

KafkaProtobufSerde() - Constructor for class io.confluent.kafka.streams.serdes.protobuf.KafkaProtobufSerde

KafkaProtobufSerde(Class<T>) - Constructor for class io.confluent.kafka.streams.serdes.protobuf.KafkaProtobufSerde

KafkaProtobufSerde(SchemaRegistryClient) - Constructor for class io.confluent.kafka.streams.serdes.protobuf.KafkaProtobufSerde

For testing purposes only.

KafkaProtobufSerde(SchemaRegistryClient, Class<T>) - Constructor for class io.confluent.kafka.streams.serdes.protobuf.KafkaProtobufSerde

For testing purposes only.

S

serializer() - Method in class io.confluent.kafka.streams.serdes.protobuf.KafkaProtobufSerde

C D I K S