org.cg.eventbus.consumer

Class ConsumerConfigrator

java.lang.Object

org.cg.eventbus.consumer.ConsumerConfigrator

public class ConsumerConfigrator
extends Object

Author:

yanlinwang

Constructor Summary

Constructors

Constructor and Description
ConsumerConfigrator()

Method Summary

Modifier and Type	Method and Description
static kafka.serializer.Decoder	configKeyDecoder(Properties props)
static Map<String,List<IEventListener>>	configTopicListenersMap(Properties props)
static Map<String,Integer>	configTopicStreamsMap(Properties props)
static kafka.serializer.Decoder	configValueDecoder(Properties props)
static void	validate(Properties props) mandatory properties are: group.id zookeeper.connect key.decoder value.decoder topics (a comma-separated String list)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerConfigrator

public ConsumerConfigrator()

Method Detail

validate

public static void validate(Properties props)
                     throws org.apache.commons.configuration.ConfigurationException

mandatory properties are:

• group.id
• zookeeper.connect
• key.decoder
• value.decoder
• topics (a comma-separated String list)

Parameters:

props - incoming properites

Throws:

org.apache.commons.configuration.ConfigurationException

configKeyDecoder

public static kafka.serializer.Decoder configKeyDecoder(Properties props)

configValueDecoder

public static kafka.serializer.Decoder configValueDecoder(Properties props)

configTopicStreamsMap

public static Map<String,Integer> configTopicStreamsMap(Properties props)
                                                 throws Exception

Throws:

Exception

configTopicListenersMap

public static Map<String,List<IEventListener>> configTopicListenersMap(Properties props)
                                                                throws Exception

Throws:

Exception