Package com.networknt.kafka.producer
-
Interface Summary Interface Description LightProducer A generic Kafka producer that can handle the header propagation with open and close methods to be called from the startup and shutdown hooks.NativeLightProducer QueuedLightProducer Queued producer that can cache multiple messages in a queue and send them in a batch for maximum throughput.SchemaManager A manager for Schema Registryschemas. -
Class Summary Class Description CompletableFutures GuaranteeProducerHandler KafkaHeadersCarrier KafkaProducerRecordCarrier NoSchemaRecordSerializer ProduceResult RegisteredSchema SchemaManagerImpl SchemaRecordSerializer SerializedKeyAndValue SidecarProducer 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.ThroughputProducerHandler 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.TransactionalProducer TransactionalProducer.NextTransactionalIdHint Keep information required to deduce next safe to use transactional id.TransactionalProducer.TransactionHolder<KafkaTransactionState> Adds metadata (currently only the start time of the transaction) to the transaction object.