A C D F G H I K L M P R S T V W

A

AvroConsumer - Class in com.tibco.messaging.kafka.samples

AvroConsumer() - Constructor for class com.tibco.messaging.kafka.samples.AvroConsumer

AvroConverter - Class in com.tibco.messaging.kafka.avro

AvroConverter() - Constructor for class com.tibco.messaging.kafka.avro.AvroConverter

AvroDeserializer - Class in com.tibco.messaging.kafka.avro

AvroDeserializer() - Constructor for class com.tibco.messaging.kafka.avro.AvroDeserializer

AvroDeserializer.AvroDeserializerInputStream - Class in com.tibco.messaging.kafka.avro

AvroProducer - Class in com.tibco.messaging.kafka.samples

AvroProducer() - Constructor for class com.tibco.messaging.kafka.samples.AvroProducer

AvroSerDe - Class in com.tibco.messaging.kafka.avro

AvroSerDe() - Constructor for class com.tibco.messaging.kafka.avro.AvroSerDe

AvroSerDeConfig - Class in com.tibco.messaging.kafka.avro

AvroSerializer - Class in com.tibco.messaging.kafka.avro

AvroSerializer() - Constructor for class com.tibco.messaging.kafka.avro.AvroSerializer

C

close() - Method in class com.tibco.messaging.kafka.avro.AvroSerDe

com.tibco.messaging.kafka.avro - package com.tibco.messaging.kafka.avro

com.tibco.messaging.kafka.samples - package com.tibco.messaging.kafka.samples

com.tibco.messaging.schema.model - package com.tibco.messaging.schema.model

com.tibco.messaging.schema.registry - package com.tibco.messaging.schema.registry

CompatibilityBoolean - Class in com.tibco.messaging.schema.model

CompatibilityString - Class in com.tibco.messaging.schema.model

CompatibilityString(String) - Constructor for class com.tibco.messaging.schema.model.CompatibilityString

configure(Map<String, ?>, boolean) - Method in class com.tibco.messaging.kafka.avro.AvroConverter

configure(Map<String, ?>, boolean, SchemaRegistryCache) - Method in class com.tibco.messaging.kafka.avro.AvroSerDe

configure(Map<String, ?>, boolean) - Method in class com.tibco.messaging.kafka.avro.AvroSerDe

D

deleteSubject(String) - Method in class com.tibco.messaging.schema.registry.SchemaRegistryCache

deleteSubject(String) - Method in interface com.tibco.messaging.schema.registry.SchemaRegistryService

deleteSubjectVersion(String, String) - Method in interface com.tibco.messaging.schema.registry.SchemaRegistryService

deserialize(String, byte[]) - Method in class com.tibco.messaging.kafka.avro.AvroDeserializer

F

fromConnectData(String, Schema, Object) - Method in class com.tibco.messaging.kafka.avro.AvroConverter

G

getCanonical() - Method in class com.tibco.messaging.schema.model.SchemaHash

getCompatibility() - Method in class com.tibco.messaging.schema.model.CompatibilityString

getDouble(int, String, String) - Method in class com.tibco.messaging.kafka.samples.TibAux

getFlag(int, String, String) - Method in class com.tibco.messaging.kafka.samples.TibAux

getGlobalCompatibility() - Method in interface com.tibco.messaging.schema.registry.SchemaRegistryService

getId() - Method in class com.tibco.messaging.schema.model.Schema

getId() - Method in class com.tibco.messaging.schema.model.SchemaID

getInt(int, String, String) - Method in class com.tibco.messaging.kafka.samples.TibAux

getIsCompatible() - Method in class com.tibco.messaging.schema.model.CompatibilityBoolean

getName() - Method in class com.tibco.messaging.schema.model.SchemaReference

getReferences() - Method in class com.tibco.messaging.schema.model.SchemaString

getSchema() - Method in class com.tibco.messaging.schema.model.Schema

getSchema() - Method in class com.tibco.messaging.schema.model.SchemaHash

getSchema() - Method in class com.tibco.messaging.schema.model.SchemaString

getSchema(int) - Method in class com.tibco.messaging.schema.registry.SchemaRegistryCache

getSchema(String, int) - Method in class com.tibco.messaging.schema.registry.SchemaRegistryCache

getSchema(String) - Method in class com.tibco.messaging.schema.registry.SchemaRegistryCache

getSchema(SchemaID) - Method in interface com.tibco.messaging.schema.registry.SchemaRegistryService

getSchema(String, String) - Method in interface com.tibco.messaging.schema.registry.SchemaRegistryService

getSchema(String, SchemaString) - Method in interface com.tibco.messaging.schema.registry.SchemaRegistryService

getSchema(String) - Method in interface com.tibco.messaging.schema.registry.SchemaRegistryService

getSchemaHash(Schema, List<SchemaReference>) - Method in class com.tibco.messaging.schema.registry.SchemaRegistryCache

getSchemaHash(Schema) - Method in class com.tibco.messaging.schema.registry.SchemaRegistryCache

getSchemaHash(SchemaString) - Method in interface com.tibco.messaging.schema.registry.SchemaRegistryService

getSchemaID(String, int) - Method in class com.tibco.messaging.schema.registry.SchemaRegistryCache

getSchemaID(String, Schema) - Method in class com.tibco.messaging.schema.registry.SchemaRegistryCache

getSha256() - Method in class com.tibco.messaging.schema.model.SchemaHash

getString(int, String, String) - Method in class com.tibco.messaging.kafka.samples.TibAux

getSubject() - Method in class com.tibco.messaging.schema.model.Schema

getSubject() - Method in class com.tibco.messaging.schema.model.SchemaReference

getSubjectCompatibility(String) - Method in interface com.tibco.messaging.schema.registry.SchemaRegistryService

getSubjects() - Method in interface com.tibco.messaging.schema.registry.SchemaRegistryService

getSubjectVersions(String) - Method in interface com.tibco.messaging.schema.registry.SchemaRegistryService

getVersion() - Method in class com.tibco.messaging.schema.model.Schema

getVersion() - Method in class com.tibco.messaging.schema.model.SchemaReference

H

HTTPS_CONNECTION_TRUST_EVERYONE - Static variable in class com.tibco.messaging.kafka.avro.AvroSerDeConfig

HTTPS_CONNECTION_USE_SPECIFIED_TRUST_FILE - Static variable in class com.tibco.messaging.kafka.avro.AvroSerDeConfig

HTTPS_CONNECTION_USE_SPECIFIED_TRUST_STRING - Static variable in class com.tibco.messaging.kafka.avro.AvroSerDeConfig

humanReadableDuration(Duration) - Static method in class com.tibco.messaging.kafka.samples.TibAux

I

isKey - Variable in class com.tibco.messaging.kafka.avro.AvroSerDe

isSchemaCompatible(SchemaString, String, String) - Method in interface com.tibco.messaging.schema.registry.SchemaRegistryService

K

keySubjectName - Variable in class com.tibco.messaging.kafka.avro.AvroSerDe

L

LATEST_VERSION - Static variable in class com.tibco.messaging.schema.registry.SchemaRegistryCache

M

main(String[]) - Static method in class com.tibco.messaging.kafka.samples.AvroConsumer

main(String[]) - Static method in class com.tibco.messaging.kafka.samples.AvroProducer

main(String[]) - Static method in class com.tibco.messaging.kafka.samples.TibConsumer

main(String[]) - Static method in class com.tibco.messaging.kafka.samples.TibProducer

P

PROPERTY_PASSWORD_PASSWORD - Static variable in class com.tibco.messaging.kafka.avro.AvroSerDeConfig

PROPERTY_STRING_FIELD_NAME_DECODER - Static variable in class com.tibco.messaging.kafka.avro.AvroSerDeConfig

PROPERTY_STRING_KEY_SUBJECT_NAME - Static variable in class com.tibco.messaging.kafka.avro.AvroSerDeConfig

PROPERTY_STRING_REALMSERVERS - Static variable in class com.tibco.messaging.kafka.avro.AvroSerDeConfig

PROPERTY_STRING_SCHEMA_REGISTRATION_STRATEGY - Static variable in class com.tibco.messaging.kafka.avro.AvroSerDeConfig

PROPERTY_STRING_SCHEMA_REGISTRY_URL - Static variable in class com.tibco.messaging.kafka.avro.AvroSerDeConfig

PROPERTY_STRING_TRUST_FILE - Static variable in class com.tibco.messaging.kafka.avro.AvroSerDeConfig

PROPERTY_STRING_TRUST_PEM_STRING - Static variable in class com.tibco.messaging.kafka.avro.AvroSerDeConfig

PROPERTY_STRING_TRUST_TYPE - Static variable in class com.tibco.messaging.kafka.avro.AvroSerDeConfig

PROPERTY_STRING_USERNAME - Static variable in class com.tibco.messaging.kafka.avro.AvroSerDeConfig

PROPERTY_STRING_VALUE_SUBJECT_NAME - Static variable in class com.tibco.messaging.kafka.avro.AvroSerDeConfig

putSchema(String, String) - Method in class com.tibco.messaging.schema.registry.SchemaRegistryCache

putSchema(String, String, List<SchemaReference>) - Method in class com.tibco.messaging.schema.registry.SchemaRegistryCache

putSchema(String, Schema) - Method in class com.tibco.messaging.schema.registry.SchemaRegistryCache

putSchema(String, Schema, List<SchemaReference>) - Method in class com.tibco.messaging.schema.registry.SchemaRegistryCache

putSchema(String, SchemaString) - Method in interface com.tibco.messaging.schema.registry.SchemaRegistryService

R

readPassword(String, String) - Static method in class com.tibco.messaging.kafka.samples.TibAux

run() - Method in class com.tibco.messaging.kafka.samples.TibConsumer

run() - Method in class com.tibco.messaging.kafka.samples.TibProducer

S

Schema - Class in com.tibco.messaging.schema.model

Schema(String, int, int, String) - Constructor for class com.tibco.messaging.schema.model.Schema

SchemaHash - Class in com.tibco.messaging.schema.model

SchemaHash(String, String, String) - Constructor for class com.tibco.messaging.schema.model.SchemaHash

SchemaID - Class in com.tibco.messaging.schema.model

SchemaID(int) - Constructor for class com.tibco.messaging.schema.model.SchemaID

SchemaReference - Class in com.tibco.messaging.schema.model

SchemaReference(String, String, int) - Constructor for class com.tibco.messaging.schema.model.SchemaReference

SchemaReference(SchemaReference) - Constructor for class com.tibco.messaging.schema.model.SchemaReference

schemaRegistrationStrategy - Variable in class com.tibco.messaging.kafka.avro.AvroSerDe

SchemaRegistryCache - Class in com.tibco.messaging.schema.registry

SchemaRegistryCache(String[]) - Constructor for class com.tibco.messaging.schema.registry.SchemaRegistryCache

SchemaRegistryCache(String[], String, String, String, String, String) - Constructor for class com.tibco.messaging.schema.registry.SchemaRegistryCache

SchemaRegistryCache.Compatibility - Enum in com.tibco.messaging.schema.registry

SchemaRegistryHTTPClient - Class in com.tibco.messaging.schema.registry

SchemaRegistryHTTPClient() - Constructor for class com.tibco.messaging.schema.registry.SchemaRegistryHTTPClient

SchemaRegistryService - Interface in com.tibco.messaging.schema.registry

SchemaString - Class in com.tibco.messaging.schema.model

SchemaString(String) - Constructor for class com.tibco.messaging.schema.model.SchemaString

SchemaString(String, SchemaReference[]) - Constructor for class com.tibco.messaging.schema.model.SchemaString

serialize(String, Object) - Method in class com.tibco.messaging.kafka.avro.AvroSerializer

setCanonical(String) - Method in class com.tibco.messaging.schema.model.SchemaHash

setCompatibility(String) - Method in class com.tibco.messaging.schema.model.CompatibilityString

setGlobalCompatibility(CompatibilityString) - Method in interface com.tibco.messaging.schema.registry.SchemaRegistryService

setId(int) - Method in class com.tibco.messaging.schema.model.Schema

setId(Integer) - Method in class com.tibco.messaging.schema.model.SchemaID

setIsCompatible(boolean) - Method in class com.tibco.messaging.schema.model.CompatibilityBoolean

setName(String) - Method in class com.tibco.messaging.schema.model.SchemaReference

setSchema(String) - Method in class com.tibco.messaging.schema.model.Schema

setSha256(String) - Method in class com.tibco.messaging.schema.model.SchemaHash

setSubject(String) - Method in class com.tibco.messaging.schema.model.Schema

setSubject(String) - Method in class com.tibco.messaging.schema.model.SchemaHash

setSubject(String) - Method in class com.tibco.messaging.schema.model.SchemaReference

setSubjectCompatibility(String, CompatibilityString) - Method in interface com.tibco.messaging.schema.registry.SchemaRegistryService

setVersion(int) - Method in class com.tibco.messaging.schema.model.Schema

setVersion(int) - Method in class com.tibco.messaging.schema.model.SchemaReference

T

TibAux - Class in com.tibco.messaging.kafka.samples

TibAux(String[], String) - Constructor for class com.tibco.messaging.kafka.samples.TibAux

TibConsumer - Class in com.tibco.messaging.kafka.samples

TibConsumer(String[]) - Constructor for class com.tibco.messaging.kafka.samples.TibConsumer

TibProducer - Class in com.tibco.messaging.kafka.samples

TibProducer(String[]) - Constructor for class com.tibco.messaging.kafka.samples.TibProducer

toConnectData(String, byte[]) - Method in class com.tibco.messaging.kafka.avro.AvroConverter

toString() - Method in class com.tibco.messaging.schema.model.CompatibilityBoolean

toString() - Method in class com.tibco.messaging.schema.model.CompatibilityString

toString() - Method in class com.tibco.messaging.schema.model.SchemaHash

toString() - Method in class com.tibco.messaging.schema.model.SchemaID

toString() - Method in class com.tibco.messaging.schema.model.SchemaReference

toString() - Method in class com.tibco.messaging.schema.model.SchemaString

trustStoreToPEMString(String, String) - Static method in class com.tibco.messaging.kafka.samples.TibAux

V

valueOf(String) - Static method in enum com.tibco.messaging.schema.registry.SchemaRegistryCache.Compatibility

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.tibco.messaging.schema.registry.SchemaRegistryCache.Compatibility

Returns an array containing the constants of this enum type, in the order they are declared.

valueSubjectName - Variable in class com.tibco.messaging.kafka.avro.AvroSerDe

W

work() - Method in class com.tibco.messaging.kafka.samples.TibProducer

A C D F G H I K L M P R S T V W