A C D E F G H I J K L N O P R S T U V W

A

AbstractKafkaJsonSchemaDeserializer<T> - Class in io.confluent.kafka.serializers.json

AbstractKafkaJsonSchemaDeserializer() - Constructor for class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaDeserializer

AbstractKafkaJsonSchemaSerializer<T> - Class in io.confluent.kafka.serializers.json

AbstractKafkaJsonSchemaSerializer() - Constructor for class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

allowedTypePackages - Variable in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaDeserializer

autoRegisterSchema - Variable in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

C

close() - Method in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializer

close() - Method in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializer

configure(KafkaJsonSchemaDeserializerConfig, Class<T>) - Method in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaDeserializer

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

configure(KafkaJsonSchemaSerializerConfig) - Method in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

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

configure(KafkaJsonSchemaDeserializerConfig, boolean) - Method in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializer

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

createDeserializer(Deserializer) - Method in class io.confluent.kafka.formatter.json.JsonSchemaMessageFormatter

createSerializer(Serializer) - Method in class io.confluent.kafka.formatter.json.JsonSchemaMessageReader

D

DEFAULT_PROPERTY_INCLUSION - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

DEFAULT_PROPERTY_INCLUSION_DOC - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

deserialize(byte[]) - Method in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaDeserializer

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.json.AbstractKafkaJsonSchemaDeserializer

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

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

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

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

deserializerConfig(Properties) - Method in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaDeserializer

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

E

equals(Object) - Method in class io.confluent.kafka.serializers.json.JsonSchemaAndValue

F

FAIL_INVALID_SCHEMA - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

FAIL_INVALID_SCHEMA - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

FAIL_INVALID_SCHEMA_DEFAULT - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

FAIL_INVALID_SCHEMA_DEFAULT - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

FAIL_INVALID_SCHEMA_DOC - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

FAIL_INVALID_SCHEMA_DOC - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

FAIL_UNKNOWN_PROPERTIES - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

FAIL_UNKNOWN_PROPERTIES - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

FAIL_UNKNOWN_PROPERTIES_DEFAULT - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

FAIL_UNKNOWN_PROPERTIES_DEFAULT - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

FAIL_UNKNOWN_PROPERTIES_DOC - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

FAIL_UNKNOWN_PROPERTIES_DOC - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

failUnknownProperties - Variable in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

G

getProvider() - Method in class io.confluent.kafka.formatter.json.JsonSchemaMessageFormatter

getProvider() - Method in class io.confluent.kafka.formatter.json.JsonSchemaMessageReader

getSchema() - Method in class io.confluent.kafka.serializers.json.JsonSchemaAndValue

getValue() - Method in class io.confluent.kafka.serializers.json.JsonSchemaAndValue

H

hashCode() - Method in class io.confluent.kafka.serializers.json.JsonSchemaAndValue

I

idCompatStrict - Variable in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

io.confluent.kafka.formatter.json - package io.confluent.kafka.formatter.json

io.confluent.kafka.serializers.json - package io.confluent.kafka.serializers.json

J

JSON_INDENT_OUTPUT - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

JSON_INDENT_OUTPUT_DEFAULT - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

JSON_INDENT_OUTPUT_DOC - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

JSON_KEY_TYPE - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

JSON_KEY_TYPE_DEFAULT - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

JSON_KEY_TYPE_DOC - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

JSON_VALUE_TYPE - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

JSON_VALUE_TYPE_DEFAULT - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

JSON_VALUE_TYPE_DOC - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

JsonSchemaAndValue - Class in io.confluent.kafka.serializers.json

JsonSchemaAndValue(JsonSchema, Object) - Constructor for class io.confluent.kafka.serializers.json.JsonSchemaAndValue

JsonSchemaMessageFormatter - Class in io.confluent.kafka.formatter.json

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

JsonSchemaMessageFormatter() - Constructor for class io.confluent.kafka.formatter.json.JsonSchemaMessageFormatter

Constructor needed by kafka console consumer.

JsonSchemaMessageReader - Class in io.confluent.kafka.formatter.json

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

JsonSchemaMessageReader() - Constructor for class io.confluent.kafka.formatter.json.JsonSchemaMessageReader

Constructor needed by kafka console producer.

K

KafkaJsonSchemaDeserializer<T> - Class in io.confluent.kafka.serializers.json

Generic JSON deserializer.

KafkaJsonSchemaDeserializer() - Constructor for class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializer

Constructor used by Kafka consumer.

KafkaJsonSchemaDeserializer(SchemaRegistryClient) - Constructor for class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializer

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

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

KafkaJsonSchemaDeserializerConfig - Class in io.confluent.kafka.serializers.json

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

KafkaJsonSchemaSerializer<T> - Class in io.confluent.kafka.serializers.json

KafkaJsonSchemaSerializer() - Constructor for class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializer

Constructor used by Kafka producer.

KafkaJsonSchemaSerializer(SchemaRegistryClient) - Constructor for class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializer

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

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

KafkaJsonSchemaSerializerConfig - Class in io.confluent.kafka.serializers.json

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

L

latestCompatStrict - Variable in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

N

normalizeSchema - Variable in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

O

objectMapper - Variable in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaDeserializer

objectMapper() - Method in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaDeserializer

objectMapper - Variable in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

objectMapper() - Method in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

ONEOF_FOR_NULLABLES - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

ONEOF_FOR_NULLABLES_DEFAULT - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

ONEOF_FOR_NULLABLES_DOC - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

oneofForNullables - Variable in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

P

propagateSchemaTags - Variable in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

R

readFrom(String, ParsedSchema) - Method in class io.confluent.kafka.formatter.json.JsonSchemaMessageReader

S

scanPackages - Variable in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

SCHEMA_SCAN_PACKAGES - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

SCHEMA_SCAN_PACKAGES_DOC - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

SCHEMA_SPEC_VERSION - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

SCHEMA_SPEC_VERSION_DEFAULT - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

SCHEMA_SPEC_VERSION_DOC - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

serialize(String, T) - Method in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializer

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

serializeImpl(String, T, JsonSchema) - Method in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

serializeImpl(String, String, Headers, T, JsonSchema) - Method in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

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

specVersion - Variable in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

T

type - Variable in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaDeserializer

TYPE_ALLOWED_PACKAGES - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

TYPE_ALLOWED_PACKAGES_DEFAULT - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

TYPE_ALLOWED_PACKAGES_DOC - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

TYPE_PROPERTY - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

TYPE_PROPERTY_DEFAULT - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

TYPE_PROPERTY_DOC - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig

typeProperty - Variable in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaDeserializer

U

useSchemaId - Variable in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

V

validate - Variable in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaDeserializer

validate - Variable in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

validateJson(T, JsonSchema) - Method in class io.confluent.kafka.serializers.json.AbstractKafkaJsonSchemaSerializer

W

WRITE_DATES_AS_ISO8601 - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

WRITE_DATES_AS_ISO8601_DEFAULT - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

WRITE_DATES_AS_ISO8601_DOC - Static variable in class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializerConfig

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

A C D E F G H I J K L N O P R S T U V W