A C D E G H I K L M N O P R S U W

A

AbstractKafkaProtobufDeserializer<T extends com.google.protobuf.Message> - Class in io.confluent.kafka.serializers.protobuf

AbstractKafkaProtobufDeserializer() - Constructor for class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufDeserializer

AbstractKafkaProtobufSerializer<T extends com.google.protobuf.Message> - Class in io.confluent.kafka.serializers.protobuf

AbstractKafkaProtobufSerializer() - Constructor for class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

autoRegisterSchema - Variable in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

C

close() - Method in class io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializer

close() - Method in class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializer

configure(KafkaProtobufDeserializerConfig, Class<T>) - Method in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufDeserializer

Sets properties for this deserializer without overriding the schema registry client itself.

configure(KafkaProtobufSerializerConfig) - Method in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

configure(Map<String, ?>, boolean) - Method in class io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializer

configure(KafkaProtobufDeserializerConfig, boolean) - Method in class io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializer

configure(Map<String, ?>, boolean) - Method in class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializer

createDeserializer(Deserializer) - Method in class io.confluent.kafka.formatter.protobuf.ProtobufMessageFormatter

createSerializer(Serializer) - Method in class io.confluent.kafka.formatter.protobuf.ProtobufMessageReader

D

DERIVE_TYPE_CONFIG - Static variable in class io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializerConfig

DERIVE_TYPE_DOC - Static variable in class io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializerConfig

deriveType - Variable in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufDeserializer

deserialize(byte[]) - Method in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufDeserializer

Deserializes the payload without including schema information for primitive types, maps, and arrays.

deserialize(boolean, String, Boolean, byte[]) - Method in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufDeserializer

deserialize(boolean, String, Boolean, Headers, byte[]) - Method in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufDeserializer

deserialize(String, byte[]) - Method in class io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializer

deserialize(String, Headers, byte[]) - Method in class io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializer

deserializerConfig(Map<String, ?>) - Method in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufDeserializer

deserializerConfig(Properties) - Method in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufDeserializer

deserializeWithSchemaAndVersion(String, boolean, Headers, byte[]) - Method in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufDeserializer

E

equals(Object) - Method in class io.confluent.kafka.serializers.protobuf.ProtobufSchemaAndValue

G

getProvider() - Method in class io.confluent.kafka.formatter.protobuf.ProtobufMessageFormatter

getProvider() - Method in class io.confluent.kafka.formatter.protobuf.ProtobufMessageReader

getSchema() - Method in class io.confluent.kafka.serializers.protobuf.ProtobufSchemaAndValue

getValue() - Method in class io.confluent.kafka.serializers.protobuf.ProtobufSchemaAndValue

H

hashCode() - Method in class io.confluent.kafka.serializers.protobuf.ProtobufSchemaAndValue

I

idCompatStrict - Variable in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

init(Properties) - Method in class io.confluent.kafka.formatter.protobuf.ProtobufMessageFormatter

init(Properties) - Method in class io.confluent.kafka.formatter.protobuf.ProtobufMessageReader

io.confluent.kafka.formatter.protobuf - package io.confluent.kafka.formatter.protobuf

io.confluent.kafka.schemaregistry.protobuf.utils - package io.confluent.kafka.schemaregistry.protobuf.utils

io.confluent.kafka.serializers.protobuf - package io.confluent.kafka.serializers.protobuf

K

KafkaProtobufDeserializer<T extends com.google.protobuf.Message> - Class in io.confluent.kafka.serializers.protobuf

KafkaProtobufDeserializer() - Constructor for class io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializer

Constructor used by Kafka consumer.

KafkaProtobufDeserializer(SchemaRegistryClient) - Constructor for class io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializer

KafkaProtobufDeserializer(SchemaRegistryClient, Map<String, ?>) - Constructor for class io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializer

KafkaProtobufDeserializer(SchemaRegistryClient, Map<String, ?>, Class<T>) - Constructor for class io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializer

KafkaProtobufDeserializerConfig - Class in io.confluent.kafka.serializers.protobuf

KafkaProtobufDeserializerConfig(Map<?, ?>) - Constructor for class io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializerConfig

KafkaProtobufSerializer<T extends com.google.protobuf.Message> - Class in io.confluent.kafka.serializers.protobuf

KafkaProtobufSerializer() - Constructor for class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializer

Constructor used by Kafka producer.

KafkaProtobufSerializer(SchemaRegistryClient) - Constructor for class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializer

KafkaProtobufSerializer(SchemaRegistryClient, Map<String, ?>) - Constructor for class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializer

KafkaProtobufSerializer(SchemaRegistryClient, Map<String, ?>, int) - Constructor for class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializer

KafkaProtobufSerializerConfig - Class in io.confluent.kafka.serializers.protobuf

KafkaProtobufSerializerConfig(Map<?, ?>) - Constructor for class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializerConfig

L

latestCompatStrict - Variable in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

M

main(String[]) - Static method in class io.confluent.kafka.schemaregistry.protobuf.utils.MavenConfigGenerator

MavenConfigGenerator - Class in io.confluent.kafka.schemaregistry.protobuf.utils

MavenConfigGenerator() - Constructor for class io.confluent.kafka.schemaregistry.protobuf.utils.MavenConfigGenerator

N

normalizeSchema - Variable in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

O

onlyLookupReferencesBySchema - Variable in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

onlyLookupReferencesBySchema() - Method in class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializerConfig

P

parseMethod - Variable in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufDeserializer

propagateSchemaTags - Variable in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

ProtobufMessageFormatter - Class in io.confluent.kafka.formatter.protobuf

Example To use ProtobufMessageFormatter, first make sure that Zookeeper, Kafka and schema registry server are all started.

ProtobufMessageFormatter() - Constructor for class io.confluent.kafka.formatter.protobuf.ProtobufMessageFormatter

Constructor needed by kafka console consumer.

ProtobufMessageReader - Class in io.confluent.kafka.formatter.protobuf

Example To use ProtobufMessageReader, first make sure that Zookeeper, Kafka and schema registry server are all started.

ProtobufMessageReader() - Constructor for class io.confluent.kafka.formatter.protobuf.ProtobufMessageReader

Constructor needed by kafka console producer.

ProtobufSchemaAndValue - Class in io.confluent.kafka.serializers.protobuf

ProtobufSchemaAndValue(ProtobufSchema, Object) - Constructor for class io.confluent.kafka.serializers.protobuf.ProtobufSchemaAndValue

R

readFrom(String, ParsedSchema) - Method in class io.confluent.kafka.formatter.protobuf.ProtobufMessageReader

REFERENCE_LOOKUP_ONLY_CONFIG - Static variable in class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializerConfig

REFERENCE_LOOKUP_ONLY_DOC - Static variable in class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializerConfig

REFERENCE_SUBJECT_NAME_STRATEGY_CONFIG - Static variable in class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializerConfig

REFERENCE_SUBJECT_NAME_STRATEGY_DOC - Static variable in class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializerConfig

referenceSubjectNameStrategy - Variable in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

referenceSubjectNameStrategyInstance() - Method in class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializerConfig

resolveDependencies(SchemaRegistryClient, boolean, boolean, boolean, Map<AbstractKafkaSchemaSerDe.SubjectSchema, AbstractKafkaSchemaSerDe.ExtendedSchema>, ReferenceSubjectNameStrategy, String, boolean, ProtobufSchema) - Static method in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

Resolve schema dependencies recursively.

resolveDependencies(SchemaRegistryClient, boolean, boolean, boolean, Map<AbstractKafkaSchemaSerDe.SubjectSchema, AbstractKafkaSchemaSerDe.ExtendedSchema>, boolean, ReferenceSubjectNameStrategy, String, boolean, ProtobufSchema) - Static method in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

Resolve schema dependencies recursively.

resolveDependencies(SchemaRegistryClient, boolean, boolean, boolean, boolean, Map<AbstractKafkaSchemaSerDe.SubjectSchema, AbstractKafkaSchemaSerDe.ExtendedSchema>, boolean, ReferenceSubjectNameStrategy, String, boolean, ProtobufSchema) - Static method in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

resolveDependencies(SchemaRegistryClient, boolean, boolean, boolean, boolean, boolean, Map<AbstractKafkaSchemaSerDe.SubjectSchema, AbstractKafkaSchemaSerDe.ExtendedSchema>, boolean, ReferenceSubjectNameStrategy, String, boolean, ProtobufSchema) - Static method in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

Resolve schema dependencies recursively.

S

schemaFormat - Variable in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

serialize(String, T) - Method in class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializer

serialize(String, Headers, T) - Method in class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializer

serializeImpl(String, String, boolean, T, ProtobufSchema) - Method in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

serializeImpl(String, String, boolean, Headers, T, ProtobufSchema) - Method in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

serializerConfig(Map<String, ?>) - Method in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

SKIP_KNOWN_TYPES_CONFIG - Static variable in class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializerConfig

SKIP_KNOWN_TYPES_DOC - Static variable in class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializerConfig

skipKnownTypes - Variable in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

skipKnownTypes() - Method in class io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializerConfig

SPECIFIC_PROTOBUF_KEY_TYPE - Static variable in class io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializerConfig

SPECIFIC_PROTOBUF_KEY_TYPE_DOC - Static variable in class io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializerConfig

SPECIFIC_PROTOBUF_VALUE_TYPE - Static variable in class io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializerConfig

SPECIFIC_PROTOBUF_VALUE_TYPE_DOC - Static variable in class io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializerConfig

specificProtobufClass - Variable in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufDeserializer

U

useSchemaId - Variable in class io.confluent.kafka.serializers.protobuf.AbstractKafkaProtobufSerializer

W

writeTo(String, Boolean, Headers, byte[], PrintStream) - Method in class io.confluent.kafka.formatter.protobuf.ProtobufMessageFormatter

A C D E G H I K L M N O P R S U W