Package com.networknt.kafka.producer

Class ThroughputProducerHandler

java.lang.Object

com.networknt.kafka.producer.ThroughputProducerHandler

public class ThroughputProducerHandler
extends Object

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. There are two running modes to choose from: throughput and guarantee. If you want to the highest throughput, you can use the TransactionalProducer and rely on the consumer to let you know if any message is missed. If you want to guarantee the delivery, then you need to choose the guarantee so that the partition and offset will be returned after the Kafka action.

Author:

Steve Hu

Constructor Summary

Constructors

Constructor	Description
ThroughputProducerHandler()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ThroughputProducerHandler

public ThroughputProducerHandler()