Package com.networknt.kafka.producer

Class GuaranteeProducerHandler

java.lang.Object

com.networknt.kafka.producer.GuaranteeProducerHandler

All Implemented Interfaces:

com.networknt.handler.LightHttpHandler, io.undertow.server.HttpHandler

public class GuaranteeProducerHandler
extends Object
implements com.networknt.handler.LightHttpHandler

Field Summary

Fields inherited from interface com.networknt.handler.LightHttpHandler

AUDIT_CONFIG_NAME, AUDIT_ON_ERROR, AUDIT_STACK_TRACE, auditConfig, auditOnError, auditStackTrace, CONFIG_NAME, ERROR_NOT_DEFINED

Constructor Summary

Constructors

Constructor	Description
GuaranteeProducerHandler()

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.clients.producer.KafkaProducer<byte[],byte[]>	createKafkaProducer()
void	handleRequest(io.undertow.server.HttpServerExchange exchange)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.networknt.handler.LightHttpHandler

setExchangeStatus, setExchangeStatus, setExchangeStatus

Constructor Detail

GuaranteeProducerHandler

public GuaranteeProducerHandler()

Method Detail

handleRequest

public void handleRequest(io.undertow.server.HttpServerExchange exchange)
                   throws Exception

Specified by:

handleRequest in interface io.undertow.server.HttpHandler

Throws:

Exception

createKafkaProducer

public org.apache.kafka.clients.producer.KafkaProducer<byte[],byte[]> createKafkaProducer()