A B C D E F G H I J K M N O P R S T U W
All Classes All Packages

A

abortTransaction() - Method in class com.networknt.kafka.common.FlinkKafkaProducer

AbstractAvroDeserializer - Class in com.networknt.kafka.common

AbstractAvroDeserializer() - Constructor for class com.networknt.kafka.common.AbstractAvroDeserializer

AbstractAvroSerDe - Class in com.networknt.kafka.common

AbstractAvroSerDe() - Constructor for class com.networknt.kafka.common.AbstractAvroSerDe

AbstractAvroSerializer - Class in com.networknt.kafka.common

AbstractAvroSerializer() - Constructor for class com.networknt.kafka.common.AbstractAvroSerializer

add(E) - Method in class com.networknt.kafka.common.CircularFifoQueue

Adds the given element to this queue.

AvroConverter - Class in com.networknt.kafka.common

AvroConverter() - Constructor for class com.networknt.kafka.common.AvroConverter

AvroDecoder - Class in com.networknt.kafka.common

AvroDecoder() - Constructor for class com.networknt.kafka.common.AvroDecoder

AvroDeserializer - Class in com.networknt.kafka.common

AvroDeserializer() - Constructor for class com.networknt.kafka.common.AvroDeserializer

AvroDeserializer(boolean) - Constructor for class com.networknt.kafka.common.AvroDeserializer

AvroSchemaUtils - Class in com.networknt.kafka.common

AvroSchemaUtils() - Constructor for class com.networknt.kafka.common.AvroSchemaUtils

AvroSerializer - Class in com.networknt.kafka.common

AvroSerializer() - Constructor for class com.networknt.kafka.common.AvroSerializer

B

beginTransaction() - Method in class com.networknt.kafka.common.FlinkKafkaProducer

build() - Method in class com.networknt.kafka.common.EventId.Builder

C

CircularFifoQueue<E> - Class in com.networknt.kafka.common

CircularFifoQueue is a first-in first-out queue with a fixed size that replaces its oldest element if full.

CircularFifoQueue() - Constructor for class com.networknt.kafka.common.CircularFifoQueue

Constructor that creates a queue with the default size of 32.

CircularFifoQueue(int) - Constructor for class com.networknt.kafka.common.CircularFifoQueue

Constructor that creates a queue with the specified size.

CircularFifoQueue(Collection<? extends E>) - Constructor for class com.networknt.kafka.common.CircularFifoQueue

Constructor that creates a queue from the specified collection.

clear() - Method in class com.networknt.kafka.common.CircularFifoQueue

Clears this queue.

clearDerived() - Method in class com.networknt.kafka.common.EventId.Builder

Clears the value of the 'derived' field.

clearId() - Method in class com.networknt.kafka.common.EventId.Builder

Clears the value of the 'id' field.

clearNonce() - Method in class com.networknt.kafka.common.EventId.Builder

Clears the value of the 'nonce' field.

close() - Method in class com.networknt.kafka.common.FlinkKafkaProducer

close() - Method in class com.networknt.kafka.common.JsonPOJODeserializer

close() - Method in class com.networknt.kafka.common.JsonPOJOSerializer

close(Duration) - Method in class com.networknt.kafka.common.FlinkKafkaProducer

com.networknt.kafka.common - package com.networknt.kafka.common

Command - Interface in com.networknt.kafka.common

Command is similar to the request in the request/response but it is asynchronous through Kafka.

commitTransaction() - Method in class com.networknt.kafka.common.FlinkKafkaProducer

CONFIG_NAME - Static variable in class com.networknt.kafka.common.KafkaConsumerConfig

CONFIG_NAME - Static variable in class com.networknt.kafka.common.KafkaProducerConfig

CONFIG_NAME - Static variable in class com.networknt.kafka.common.KafkaStreamsConfig

CONFIG_NAME - Static variable in class com.networknt.kafka.common.SchemaRegistryConfig

configure(Map<String, ?>, boolean) - Method in class com.networknt.kafka.common.JsonPOJODeserializer

configure(Map<String, ?>, boolean) - Method in class com.networknt.kafka.common.JsonPOJOSerializer

copyOf(Schema) - Static method in class com.networknt.kafka.common.AvroSchemaUtils

createDecoder(SchemaStore) - Static method in class com.networknt.kafka.common.EventId

Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore.

customDecode(ResolvingDecoder) - Method in class com.networknt.kafka.common.EventId

customEncode(Encoder) - Method in class com.networknt.kafka.common.EventId

D

deserialize(boolean, String, Boolean, byte[], Schema) - Method in class com.networknt.kafka.common.AbstractAvroDeserializer

deserialize(byte[]) - Method in class com.networknt.kafka.common.AbstractAvroDeserializer

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

deserialize(byte[], Schema) - Method in class com.networknt.kafka.common.AbstractAvroDeserializer

Just like single-parameter version but accepts an Avro schema to use for reading

deserialize(String, byte[]) - Method in class com.networknt.kafka.common.AvroDeserializer

deserialize(String, byte[]) - Method in class com.networknt.kafka.common.JsonPOJODeserializer

deserialize(String, byte[], Schema) - Method in class com.networknt.kafka.common.AvroDeserializer

Pass a reader schema to get an Avro projection

E

element() - Method in class com.networknt.kafka.common.CircularFifoQueue

equals(Object) - Method in class com.networknt.kafka.common.NonRecordContainer

Event - Interface in com.networknt.kafka.common

Base interface for event sourcing events

EventId - Class in com.networknt.kafka.common

EventId() - Constructor for class com.networknt.kafka.common.EventId

Default constructor.

EventId(String, Long, Boolean) - Constructor for class com.networknt.kafka.common.EventId

All-args constructor.

EventId.Builder - Class in com.networknt.kafka.common

RecordBuilder for EventId instances.

EventNotification - Class in com.networknt.kafka.common

EventNotification(long, String, String, boolean, String, SpecificRecord) - Constructor for class com.networknt.kafka.common.EventNotification

F

FlinkKafkaProducer<K,V> - Class in com.networknt.kafka.common

Wrapper around KafkaProducer that allows to resume transactions in case of node failure, which allows to implement two phase commit algorithm for exactly-once semantic FlinkKafkaProducer.

FlinkKafkaProducer(Properties) - Constructor for class com.networknt.kafka.common.FlinkKafkaProducer

flush() - Method in class com.networknt.kafka.common.FlinkKafkaProducer

fromByteBuffer(ByteBuffer) - Static method in class com.networknt.kafka.common.EventId

Deserializes a EventId from a ByteBuffer.

fromBytes(byte[]) - Method in class com.networknt.kafka.common.AvroDecoder

fromBytes(byte[], Schema) - Method in class com.networknt.kafka.common.AvroDecoder

Pass a reader schema to get an Avro projection

G

generateIdsToAbort() - Method in class com.networknt.kafka.common.TransactionalIdsGenerator

If we have to abort previous transactional id in case of restart after a failure BEFORE first checkpoint completed, we don't know what was the parallelism used in previous attempt.

generateIdsToUse(long) - Method in class com.networknt.kafka.common.TransactionalIdsGenerator

Range of available transactional ids to use is: [nextFreeTransactionalId, nextFreeTransactionalId + parallelism * kafkaProducersPoolSize) loop below picks in a deterministic way a subrange of those available transactional ids based on index of this subtask.

get(int) - Method in class com.networknt.kafka.common.CircularFifoQueue

Returns the element at the specified position in this queue.

get(int) - Method in class com.networknt.kafka.common.EventId

getAcks() - Method in class com.networknt.kafka.common.KafkaProducerConfig

getApp() - Method in class com.networknt.kafka.common.EventNotification

getApplicationId() - Method in class com.networknt.kafka.common.KafkaStreamsConfig

getAutoCommitIntervalMs() - Method in class com.networknt.kafka.common.KafkaConsumerConfig

getAutoOffsetreset() - Method in class com.networknt.kafka.common.KafkaProducerConfig

getAutoOffsetReset() - Method in class com.networknt.kafka.common.KafkaConsumerConfig

getBatchSize() - Method in class com.networknt.kafka.common.KafkaProducerConfig

getBootstrapServers() - Method in class com.networknt.kafka.common.KafkaConsumerConfig

getBootstrapServers() - Method in class com.networknt.kafka.common.KafkaProducerConfig

getBootstrapServers() - Method in class com.networknt.kafka.common.KafkaStreamsConfig

getBufferMemory() - Method in class com.networknt.kafka.common.KafkaProducerConfig

getClassSchema() - Static method in class com.networknt.kafka.common.EventId

getDecoder() - Static method in class com.networknt.kafka.common.EventId

Return the BinaryMessageDecoder instance used by this class.

getDerived() - Method in class com.networknt.kafka.common.EventId.Builder

Gets the value of the 'derived' field.

getDerived() - Method in class com.networknt.kafka.common.EventId

Gets the value of the 'derived' field.

getEncoder() - Static method in class com.networknt.kafka.common.EventId

Return the BinaryMessageEncoder instance used by this class.

getEpoch() - Method in class com.networknt.kafka.common.FlinkKafkaProducer

getError() - Method in class com.networknt.kafka.common.EventNotification

getEvent() - Method in class com.networknt.kafka.common.EventNotification

getGroupId() - Method in class com.networknt.kafka.common.KafkaConsumerConfig

getId() - Method in class com.networknt.kafka.common.EventId.Builder

Gets the value of the 'id' field.

getId() - Method in class com.networknt.kafka.common.EventId

Gets the value of the 'id' field.

getIsolationLevel() - Method in class com.networknt.kafka.common.KafkaConsumerConfig

getKeyDeserializer() - Method in class com.networknt.kafka.common.KafkaConsumerConfig

getKeyDeSerializer() - Method in class com.networknt.kafka.common.KafkaProducerConfig

getKeySerializer() - Method in class com.networknt.kafka.common.KafkaProducerConfig

getLingerMs() - Method in class com.networknt.kafka.common.KafkaProducerConfig

getMaxInFlightRequestsPerConnection() - Method in class com.networknt.kafka.common.KafkaProducerConfig

getName() - Method in class com.networknt.kafka.common.EventNotification

getNonce() - Method in class com.networknt.kafka.common.EventId.Builder

Gets the value of the 'nonce' field.

getNonce() - Method in class com.networknt.kafka.common.EventId

Gets the value of the 'nonce' field.

getNonce() - Method in class com.networknt.kafka.common.EventNotification

getPrimitiveSchemas() - Static method in class com.networknt.kafka.common.AvroSchemaUtils

getProcessingGuarantee() - Method in class com.networknt.kafka.common.KafkaStreamsConfig

getProducerId() - Method in class com.networknt.kafka.common.FlinkKafkaProducer

getReplicationFactor() - Method in class com.networknt.kafka.common.KafkaStreamsConfig

getRetries() - Method in class com.networknt.kafka.common.KafkaProducerConfig

getSchema() - Method in class com.networknt.kafka.common.EventId

getSchema() - Method in class com.networknt.kafka.common.NonRecordContainer

getSchema(Object) - Static method in class com.networknt.kafka.common.AvroSchemaUtils

getServerUrls() - Method in class com.networknt.kafka.common.SchemaRegistryConfig

getSessionTimeout() - Method in class com.networknt.kafka.common.KafkaProducerConfig

getSpecificData() - Method in class com.networknt.kafka.common.EventId

getTopic() - Method in class com.networknt.kafka.common.KafkaProducerConfig

getTransactionalId() - Method in class com.networknt.kafka.common.FlinkKafkaProducer

getTransactionalIdExpirationMs() - Method in class com.networknt.kafka.common.KafkaProducerConfig

getTransactionCoordinatorId() - Method in class com.networknt.kafka.common.FlinkKafkaProducer

getTransactionId() - Method in class com.networknt.kafka.common.KafkaProducerConfig

getTransactionTimeoutMs() - Method in class com.networknt.kafka.common.KafkaProducerConfig

getValue() - Method in class com.networknt.kafka.common.NonRecordContainer

getValueDeserializer() - Method in class com.networknt.kafka.common.KafkaConsumerConfig

getValueDeSerializer() - Method in class com.networknt.kafka.common.KafkaProducerConfig

getValueSerializer() - Method in class com.networknt.kafka.common.KafkaProducerConfig

H

hasCustomCoders() - Method in class com.networknt.kafka.common.EventId

hasDerived() - Method in class com.networknt.kafka.common.EventId.Builder

Checks whether the 'derived' field has been set.

hashCode() - Method in class com.networknt.kafka.common.NonRecordContainer

hasId() - Method in class com.networknt.kafka.common.EventId.Builder

Checks whether the 'id' field has been set.

hasNonce() - Method in class com.networknt.kafka.common.EventId.Builder

Checks whether the 'nonce' field has been set.

I

idSize - Static variable in class com.networknt.kafka.common.AbstractAvroSerDe

initTransactions() - Method in class com.networknt.kafka.common.FlinkKafkaProducer

isAtFullCapacity() - Method in class com.networknt.kafka.common.CircularFifoQueue

Returns true if the capacity limit of this queue has been reached, i.e.

isAutoRegisterSchema() - Method in class com.networknt.kafka.common.SchemaRegistryConfig

isCleanUp() - Method in class com.networknt.kafka.common.KafkaStreamsConfig

isEmpty() - Method in class com.networknt.kafka.common.CircularFifoQueue

Returns true if this queue is empty; false otherwise.

isEnableAutoCommit() - Method in class com.networknt.kafka.common.KafkaConsumerConfig

isEnableAutoCommit() - Method in class com.networknt.kafka.common.KafkaProducerConfig

isEnableIdempotence() - Method in class com.networknt.kafka.common.KafkaProducerConfig

isInjectCallerId() - Method in class com.networknt.kafka.common.KafkaProducerConfig

isInjectOpenTracing() - Method in class com.networknt.kafka.common.KafkaProducerConfig

isSuccess() - Method in class com.networknt.kafka.common.EventNotification

iterator() - Method in class com.networknt.kafka.common.CircularFifoQueue

Returns an iterator over this queue's elements.

J

JsonPOJODeserializer<T> - Class in com.networknt.kafka.common

JsonPOJODeserializer() - Constructor for class com.networknt.kafka.common.JsonPOJODeserializer

Default constructor needed by Kafka

JsonPOJOSerializer<T> - Class in com.networknt.kafka.common

JsonPOJOSerializer() - Constructor for class com.networknt.kafka.common.JsonPOJOSerializer

Default constructor needed by Kafka

K

KafkaConsumerConfig - Class in com.networknt.kafka.common

KafkaConsumerConfig() - Constructor for class com.networknt.kafka.common.KafkaConsumerConfig

KafkaProducerConfig - Class in com.networknt.kafka.common

A Kafka setting configuration file.

KafkaProducerConfig() - Constructor for class com.networknt.kafka.common.KafkaProducerConfig

KafkaStreamsConfig - Class in com.networknt.kafka.common

KafkaStreamsConfig() - Constructor for class com.networknt.kafka.common.KafkaStreamsConfig

M

MAGIC_BYTE - Static variable in class com.networknt.kafka.common.AbstractAvroSerDe

MAX_SCHEMAS_PER_SUBJECT_DEFAULT - Static variable in class com.networknt.kafka.common.AbstractAvroSerDe

Message - Interface in com.networknt.kafka.common

Message is the primary data object send to the Kafka topic with payload the describe the data.

metrics() - Method in class com.networknt.kafka.common.FlinkKafkaProducer

N

newBuilder() - Static method in class com.networknt.kafka.common.EventId

Creates a new EventId RecordBuilder.

newBuilder(EventId) - Static method in class com.networknt.kafka.common.EventId

Creates a new EventId RecordBuilder by copying an existing EventId instance.

newBuilder(EventId.Builder) - Static method in class com.networknt.kafka.common.EventId

Creates a new EventId RecordBuilder by copying an existing Builder.

NonRecordContainer - Class in com.networknt.kafka.common

Wrapper for all non-record types that includes the schema for the data.

NonRecordContainer(Schema, Object) - Constructor for class com.networknt.kafka.common.NonRecordContainer

O

offer(E) - Method in class com.networknt.kafka.common.CircularFifoQueue

Adds the given element to this queue.

P

partitionsFor(String) - Method in class com.networknt.kafka.common.FlinkKafkaProducer

peek() - Method in class com.networknt.kafka.common.CircularFifoQueue

poll() - Method in class com.networknt.kafka.common.CircularFifoQueue

put(int, Object) - Method in class com.networknt.kafka.common.EventId

R

readExternal(ObjectInput) - Method in class com.networknt.kafka.common.EventId

remove() - Method in class com.networknt.kafka.common.CircularFifoQueue

resumeTransaction(long, short) - Method in class com.networknt.kafka.common.FlinkKafkaProducer

Instead of obtaining producerId and epoch from the transaction coordinator, re-use previously obtained ones, so that we can resume transaction after a restart.

S

SCHEMA$ - Static variable in class com.networknt.kafka.common.EventId

schemaRegistry - Variable in class com.networknt.kafka.common.AbstractAvroSerDe

SchemaRegistryConfig - Class in com.networknt.kafka.common

SchemaRegistryConfig() - Constructor for class com.networknt.kafka.common.SchemaRegistryConfig

send(ProducerRecord<K, V>) - Method in class com.networknt.kafka.common.FlinkKafkaProducer

send(ProducerRecord<K, V>, Callback) - Method in class com.networknt.kafka.common.FlinkKafkaProducer

sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, String) - Method in class com.networknt.kafka.common.FlinkKafkaProducer

sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, ConsumerGroupMetadata) - Method in class com.networknt.kafka.common.FlinkKafkaProducer

serialize(Object) - Method in class com.networknt.kafka.common.AvroSerializer

serialize(String, T) - Method in class com.networknt.kafka.common.JsonPOJOSerializer

serializeImpl(Object) - Method in class com.networknt.kafka.common.AbstractAvroSerializer

setAcks(String) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setApp(String) - Method in class com.networknt.kafka.common.EventNotification

setApplicationId(String) - Method in class com.networknt.kafka.common.KafkaStreamsConfig

setAutoCommitIntervalMs(int) - Method in class com.networknt.kafka.common.KafkaConsumerConfig

setAutoOffsetreset(String) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setAutoOffsetReset(String) - Method in class com.networknt.kafka.common.KafkaConsumerConfig

setAutoRegisterSchema(boolean) - Method in class com.networknt.kafka.common.SchemaRegistryConfig

setBatchSize(int) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setBootstrapServers(String) - Method in class com.networknt.kafka.common.KafkaConsumerConfig

setBootstrapServers(String) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setBootstrapServers(String) - Method in class com.networknt.kafka.common.KafkaStreamsConfig

setBufferMemory(long) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setCleanUp(boolean) - Method in class com.networknt.kafka.common.KafkaStreamsConfig

setDerived(boolean) - Method in class com.networknt.kafka.common.EventId.Builder

Sets the value of the 'derived' field.

setDerived(boolean) - Method in class com.networknt.kafka.common.EventId

Sets the value of the 'derived' field.

setEnableAutoCommit(boolean) - Method in class com.networknt.kafka.common.KafkaConsumerConfig

setEnableAutoCommit(boolean) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setEnableIdempotence(boolean) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setError(String) - Method in class com.networknt.kafka.common.EventNotification

setEvent(SpecificRecord) - Method in class com.networknt.kafka.common.EventNotification

setGroupId(String) - Method in class com.networknt.kafka.common.KafkaConsumerConfig

setId(String) - Method in class com.networknt.kafka.common.EventId.Builder

Sets the value of the 'id' field.

setId(String) - Method in class com.networknt.kafka.common.EventId

Sets the value of the 'id' field.

setInjectCallerId(boolean) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setInjectOpenTracing(boolean) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setIsolationLevel(String) - Method in class com.networknt.kafka.common.KafkaConsumerConfig

setKeyDeserializer(String) - Method in class com.networknt.kafka.common.KafkaConsumerConfig

setKeyDeSerializer(String) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setKeySerializer(String) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setLingerMs(int) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setMaxInFlightRequestsPerConnection(int) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setName(String) - Method in class com.networknt.kafka.common.EventNotification

setNonce(long) - Method in class com.networknt.kafka.common.EventId.Builder

Sets the value of the 'nonce' field.

setNonce(long) - Method in class com.networknt.kafka.common.EventId

Sets the value of the 'nonce' field.

setNonce(long) - Method in class com.networknt.kafka.common.EventNotification

setProcessingGuarantee(String) - Method in class com.networknt.kafka.common.KafkaStreamsConfig

setReplicationFactor(int) - Method in class com.networknt.kafka.common.KafkaStreamsConfig

setRetries(int) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setServerUrls(List<String>) - Method in class com.networknt.kafka.common.SchemaRegistryConfig

setSessionTimeout(int) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setSuccess(boolean) - Method in class com.networknt.kafka.common.EventNotification

setTopic(String) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setTransactionalIdExpirationMs(int) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setTransactionId(String) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setTransactionTimeoutMs(int) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setValueDeserializer(String) - Method in class com.networknt.kafka.common.KafkaConsumerConfig

setValueDeSerializer(String) - Method in class com.networknt.kafka.common.KafkaProducerConfig

setValueSerializer(String) - Method in class com.networknt.kafka.common.KafkaProducerConfig

size() - Method in class com.networknt.kafka.common.CircularFifoQueue

Returns the number of elements stored in the queue.

T

toByteBuffer() - Method in class com.networknt.kafka.common.EventId

Serializes this EventId to a ByteBuffer.

toJson(SpecificRecord, boolean) - Static method in class com.networknt.kafka.common.AvroConverter

toString() - Method in class com.networknt.kafka.common.EventNotification

TransactionalIdsGenerator - Class in com.networknt.kafka.common

Class responsible for generating transactional ids to use when communicating with Kafka.

TransactionalIdsGenerator(String, int, int, int, int) - Constructor for class com.networknt.kafka.common.TransactionalIdsGenerator

TransactionalKafkaException - Exception in com.networknt.kafka.common

TransactionalKafkaException() - Constructor for exception com.networknt.kafka.common.TransactionalKafkaException

TransactionalKafkaException(String) - Constructor for exception com.networknt.kafka.common.TransactionalKafkaException

TransactionalKafkaException(String, Throwable) - Constructor for exception com.networknt.kafka.common.TransactionalKafkaException

TransactionalKafkaException(Throwable) - Constructor for exception com.networknt.kafka.common.TransactionalKafkaException

U

useSpecificAvroReader - Variable in class com.networknt.kafka.common.AbstractAvroDeserializer

W

writeExternal(ObjectOutput) - Method in class com.networknt.kafka.common.EventId

A B C D E F G H I J K M N O P R S T U W
All Classes All Packages