org.cg.eventbus.producer

Class ProducerConfigurator

java.lang.Object

org.cg.eventbus.producer.ProducerConfigurator

public class ProducerConfigurator
extends Object

Author:

yanlinwang

Constructor Summary

Constructors

Constructor and Description
ProducerConfigurator()

Method Summary

Modifier and Type	Method and Description
static void	validate(org.apache.commons.configuration.Configuration config) validate required configuration zk.connect: zookeeper connection metadata.broker.list: kafka broker list producer.topic: topic name this producer sending to

Methods inherited from class java.lang.Object

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

Constructor Detail

ProducerConfigurator

public ProducerConfigurator()

Method Detail

validate

public static void validate(org.apache.commons.configuration.Configuration config)
                     throws Exception

validate required configuration zk.connect: zookeeper connection metadata.broker.list: kafka broker list producer.topic: topic name this producer sending to

Parameters:

config -

Throws:

Exception