A B C D E F G H I K L N O P Q R S T
All Classes All Packages

A

abort(TransactionalProducer.KafkaTransactionState) - Method in class com.networknt.kafka.producer.TransactionalProducer

addressToPartition(String) - Static method in class com.networknt.kafka.producer.TransactionalProducer

allAsList(List<CompletableFuture<T>>) - Static method in class com.networknt.kafka.producer.CompletableFutures

Returns a CompletableFuture which will complete after all futures have completed, and when complete, will contain the value of all futures.

B

beginTransaction() - Method in class com.networknt.kafka.producer.TransactionalProducer

C

catchingCompose(CompletableFuture<T>, Class<E>, Function<? super E, ? extends CompletableFuture<T>>) - Static method in class com.networknt.kafka.producer.CompletableFutures

Returns a new CompletableFuture that is completed when future is complete, catching the given exceptionClass.

close() - Method in interface com.networknt.kafka.producer.LightProducer

This method is called by a shutdown hook to close the producer if it is not null.

close() - Method in class com.networknt.kafka.producer.SidecarProducer

close() - Method in class com.networknt.kafka.producer.TransactionalProducer

com.networknt.kafka.producer - package com.networknt.kafka.producer

commit(TransactionalProducer.KafkaTransactionState) - Method in class com.networknt.kafka.producer.TransactionalProducer

CompletableFutures - Class in com.networknt.kafka.producer

config - Static variable in class com.networknt.kafka.producer.SidecarProducer

create(Optional<Integer>, Optional<ByteString>, Optional<ByteString>) - Static method in class com.networknt.kafka.producer.SerializedKeyAndValue

createKafkaProducer() - Method in class com.networknt.kafka.producer.GuaranteeProducerHandler

currentTransaction() - Method in class com.networknt.kafka.producer.TransactionalProducer

D

drain(BlockingQueue<E>, Collection<? super E>, int, long, TimeUnit) - Static method in class com.networknt.kafka.producer.TransactionalProducer

Drains the queue as BlockingQueue.drainTo(Collection, int), but if the requested numElements elements are not available, it will wait for them up to the specified timeout.

E

equals(Object) - Method in class com.networknt.kafka.producer.ProduceResult

equals(Object) - Method in class com.networknt.kafka.producer.RegisteredSchema

equals(Object) - Method in class com.networknt.kafka.producer.SerializedKeyAndValue

equals(Object) - Method in class com.networknt.kafka.producer.TransactionalProducer.TransactionHolder

F

failedFuture(Throwable) - Static method in class com.networknt.kafka.producer.CompletableFutures

Returns a CompletableFuture that is completed exceptionally with the given exception.

fromRecordMetadata(RecordMetadata) - Static method in class com.networknt.kafka.producer.ProduceResult

G

getFormat() - Method in class com.networknt.kafka.producer.RegisteredSchema

getKey() - Method in class com.networknt.kafka.producer.SerializedKeyAndValue

getOffset() - Method in class com.networknt.kafka.producer.ProduceResult

getPartitionId() - Method in class com.networknt.kafka.producer.ProduceResult

getPartitionId() - Method in class com.networknt.kafka.producer.SerializedKeyAndValue

getProducer() - Method in interface com.networknt.kafka.producer.NativeLightProducer

Return the Kafka Producer instance so that it can be used to produce message to a Kafka topic.

getProducer() - Method in class com.networknt.kafka.producer.SidecarProducer

getSchema() - Method in class com.networknt.kafka.producer.RegisteredSchema

getSchema(String, Optional<EmbeddedFormat>, Optional<String>, Optional<SubjectNameStrategy>, Optional<Integer>, Optional<Integer>, Optional<String>, boolean) - Method in interface com.networknt.kafka.producer.SchemaManager

Returns a schema matching the parameter options.

getSchema(String, Optional<EmbeddedFormat>, Optional<String>, Optional<SubjectNameStrategy>, Optional<Integer>, Optional<Integer>, Optional<String>, boolean) - Method in class com.networknt.kafka.producer.SchemaManagerImpl

getSchemaId() - Method in class com.networknt.kafka.producer.RegisteredSchema

getSchemaVersion() - Method in class com.networknt.kafka.producer.RegisteredSchema

getSerializeKeySize() - Method in class com.networknt.kafka.producer.ProduceResult

getSerializeValueSize() - Method in class com.networknt.kafka.producer.ProduceResult

getSubject() - Method in class com.networknt.kafka.producer.RegisteredSchema

getTimestamp() - Method in class com.networknt.kafka.producer.ProduceResult

getTxQueue() - Method in interface com.networknt.kafka.producer.QueuedLightProducer

Get the blocking queue that is used to cache messages so that they can be sent in a batch.

getTxQueue() - Method in class com.networknt.kafka.producer.TransactionalProducer

getValue() - Method in class com.networknt.kafka.producer.SerializedKeyAndValue

GuaranteeProducerHandler - Class in com.networknt.kafka.producer

GuaranteeProducerHandler() - Constructor for class com.networknt.kafka.producer.GuaranteeProducerHandler

H

handleRequest(HttpServerExchange) - Method in class com.networknt.kafka.producer.GuaranteeProducerHandler

hashCode() - Method in class com.networknt.kafka.producer.ProduceResult

hashCode() - Method in class com.networknt.kafka.producer.RegisteredSchema

hashCode() - Method in class com.networknt.kafka.producer.SerializedKeyAndValue

hashCode() - Method in class com.networknt.kafka.producer.TransactionalProducer.TransactionHolder

I

invoke(TransactionalProducer.KafkaTransactionState, String, ProducerRecord<byte[], byte[]>) - Method in class com.networknt.kafka.producer.TransactionalProducer

iterator() - Method in class com.networknt.kafka.producer.KafkaHeadersCarrier

iterator() - Method in class com.networknt.kafka.producer.KafkaProducerRecordCarrier

K

KafkaHeadersCarrier - Class in com.networknt.kafka.producer

KafkaHeadersCarrier(Headers) - Constructor for class com.networknt.kafka.producer.KafkaHeadersCarrier

KafkaProducerRecordCarrier - Class in com.networknt.kafka.producer

KafkaProducerRecordCarrier(ProducerRecord) - Constructor for class com.networknt.kafka.producer.KafkaProducerRecordCarrier

L

lastParallelism - Variable in class com.networknt.kafka.producer.TransactionalProducer.NextTransactionalIdHint

LightProducer - Interface in com.networknt.kafka.producer

A generic Kafka producer that can handle the header propagation with open and close methods to be called from the startup and shutdown hooks.

N

NativeLightProducer - Interface in com.networknt.kafka.producer

nextFreeTransactionalId - Variable in class com.networknt.kafka.producer.TransactionalProducer.NextTransactionalIdHint

NextTransactionalIdHint() - Constructor for class com.networknt.kafka.producer.TransactionalProducer.NextTransactionalIdHint

NextTransactionalIdHint(int, long) - Constructor for class com.networknt.kafka.producer.TransactionalProducer.NextTransactionalIdHint

NoSchemaRecordSerializer - Class in com.networknt.kafka.producer

NoSchemaRecordSerializer(Map<String, Object>) - Constructor for class com.networknt.kafka.producer.NoSchemaRecordSerializer

O

open() - Method in interface com.networknt.kafka.producer.LightProducer

This method is used to create an instance of producer in a startup hook for most of the producers.

open() - Method in interface com.networknt.kafka.producer.QueuedLightProducer

Queued producer will start a background thread to process the queued message in batch and this method can be used to start the thread in a startup hook.

open() - Method in class com.networknt.kafka.producer.SidecarProducer

open() - Method in class com.networknt.kafka.producer.TransactionalProducer

Initializes the connection to Kafka.

P

preCommit(TransactionalProducer.KafkaTransactionState) - Method in class com.networknt.kafka.producer.TransactionalProducer

producer - Variable in class com.networknt.kafka.producer.SidecarProducer

ProduceResult - Class in com.networknt.kafka.producer

ProduceResult() - Constructor for class com.networknt.kafka.producer.ProduceResult

ProduceResult(int, long, Instant, int, int) - Constructor for class com.networknt.kafka.producer.ProduceResult

propagateHeaders(ProducerRecord, HttpServerExchange) - Method in interface com.networknt.kafka.producer.QueuedLightProducer

For each producer, it is responsible for populate the header of the ProducerRecord.

propagateHeaders(ProducerRecord, HttpServerExchange) - Method in class com.networknt.kafka.producer.TransactionalProducer

put(String, String) - Method in class com.networknt.kafka.producer.KafkaHeadersCarrier

put(String, String) - Method in class com.networknt.kafka.producer.KafkaProducerRecordCarrier

Q

QueuedLightProducer - Interface in com.networknt.kafka.producer

Queued producer that can cache multiple messages in a queue and send them in a batch for maximum throughput.

R

recoverAndAbort(TransactionalProducer.KafkaTransactionState) - Method in class com.networknt.kafka.producer.TransactionalProducer

recoverAndCommit(TransactionalProducer.KafkaTransactionState) - Method in class com.networknt.kafka.producer.TransactionalProducer

RegisteredSchema - Class in com.networknt.kafka.producer

RegisteredSchema(String, int, int, ParsedSchema) - Constructor for class com.networknt.kafka.producer.RegisteredSchema

run() - Method in class com.networknt.kafka.producer.TransactionalProducer

S

SchemaManager - Interface in com.networknt.kafka.producer

A manager for Schema Registry schemas.

SchemaManagerImpl - Class in com.networknt.kafka.producer

SchemaManagerImpl(SchemaRegistryClient, SubjectNameStrategy) - Constructor for class com.networknt.kafka.producer.SchemaManagerImpl

SchemaRecordSerializer - Class in com.networknt.kafka.producer

SchemaRecordSerializer(SchemaRegistryClient, Map<String, Object>, Map<String, Object>, Map<String, Object>) - Constructor for class com.networknt.kafka.producer.SchemaRecordSerializer

serialize(EmbeddedFormat, JsonNode) - Method in class com.networknt.kafka.producer.NoSchemaRecordSerializer

serialize(EmbeddedFormat, String, Optional<RegisteredSchema>, JsonNode, boolean) - Method in class com.networknt.kafka.producer.SchemaRecordSerializer

SerializedKeyAndValue - Class in com.networknt.kafka.producer

SerializedKeyAndValue(Optional<Integer>, Optional<ByteString>, Optional<ByteString>) - Constructor for class com.networknt.kafka.producer.SerializedKeyAndValue

setKey(Optional<ByteString>) - Method in class com.networknt.kafka.producer.SerializedKeyAndValue

setOffset(long) - Method in class com.networknt.kafka.producer.ProduceResult

setPartitionId(int) - Method in class com.networknt.kafka.producer.ProduceResult

setPartitionId(Optional<Integer>) - Method in class com.networknt.kafka.producer.SerializedKeyAndValue

setSchema(ParsedSchema) - Method in class com.networknt.kafka.producer.RegisteredSchema

setSchemaId(int) - Method in class com.networknt.kafka.producer.RegisteredSchema

setSchemaVersion(int) - Method in class com.networknt.kafka.producer.RegisteredSchema

setSerializeKeySize(int) - Method in class com.networknt.kafka.producer.ProduceResult

setSerializeValueSize(int) - Method in class com.networknt.kafka.producer.ProduceResult

setSubject(String) - Method in class com.networknt.kafka.producer.RegisteredSchema

setTimestamp(Instant) - Method in class com.networknt.kafka.producer.ProduceResult

setValue(Optional<ByteString>) - Method in class com.networknt.kafka.producer.SerializedKeyAndValue

SidecarProducer - Class in com.networknt.kafka.producer

This is the guaranteed producer to ensure that the message is acknowledged from the Kafka brokers before the service is respond to the consumer call.

SidecarProducer() - Constructor for class com.networknt.kafka.producer.SidecarProducer

T

ThroughputProducerHandler - Class in com.networknt.kafka.producer

This is a standard handler that can be used by any service endpoint or in the light-proxy to accept Restful requests and push to a kafka topic.

ThroughputProducerHandler() - Constructor for class com.networknt.kafka.producer.ThroughputProducerHandler

toString() - Method in class com.networknt.kafka.producer.TransactionalProducer.TransactionHolder

TransactionalProducer - Class in com.networknt.kafka.producer

TransactionalProducer() - Constructor for class com.networknt.kafka.producer.TransactionalProducer

TransactionalProducer.NextTransactionalIdHint - Class in com.networknt.kafka.producer

Keep information required to deduce next safe to use transactional id.

TransactionalProducer.TransactionHolder<KafkaTransactionState> - Class in com.networknt.kafka.producer

Adds metadata (currently only the start time of the transaction) to the transaction object.

TransactionHolder(TransactionalProducer.KafkaTransactionState, long) - Constructor for class com.networknt.kafka.producer.TransactionalProducer.TransactionHolder

A B C D E F G H I K L N O P Q R S T
All Classes All Packages