Constant Field Values

Contents

• org.cg.*

org.cg.*

org.cg.eventbus.IEventBus

Modifier and Type	Constant Field	Value
public static final String	AUTO_CREATE	"autoCreate"
public static final String	DEFAULT_PRO_ZK_CONNECT	"localhost:2181"
public static final String	ZK_CONNECT	"zookeeper.connect"

org.cg.eventbus.IManager<K,V>

Modifier and Type	Constant Field	Value
public static final String	TOPIC_LIST	"topics"

org.cg.eventbus.IProducer<K,V>

Modifier and Type	Constant Field	Value
public static final String	BROKER_LIST	"bootstrap.servers"
public static final String	BYTE_SERIALIZER_CLASS	"kafka.serializer.DefaultEncoder"
public static final String	DEFAULT_KEY	"default"
public static final String	KEY_SERIALIZER_CLASS	"key.serializer"
public static final String	PARTITION_CLASS	"partitioner.class"
public static final String	PRO_TYPE	"producer.type"
public static final String	PRODUCER_TOPIC	"producer.topic.name"
public static final String	RECOVERY_FILE_PATH	"producer.recovery.file.path"
public static final String	REQUEST_REQUIRED_ACKS	"request.required.acks"
public static final String	STRING_SERIALIZER_CLASS	"kafka.serializer.StringEncoder"
public static final String	TOPIC_PARTITION_NUM	"producer.topic.numPartitions"
public static final String	TOPIC_REPLICATION_FACTOR	"producer.topic.replicationFactor"
public static final String	VALUE_SERIALIZER_CLASS	"value.serializer"

org.cg.eventbus.consumer.IConsumer<K,V>

Modifier and Type	Constant Field	Value
public static final String	COMMIT_INTERVAL	"commit.interval"
public static final String	CONSUMER_LISTENERS	"%s.listeners"
public static final String	CONSUMER_STREAMS	"%s.streams"
public static final String	CONSUMER_THREAD_POOL_SIZE	"thread.pool.size"
public static final String	CONSUMER_TOPICS	"topics"
public static final String	DEFAULT_COMMIT_INTERVAL	"60000"
public static final String	DEFAULT_CONNECTION_TIMEOUT	"100000"
public static final String	DEFAULT_GROUP_ID	"test_group"
public static final String	DEFAULT_SINGLE_TOPIC	"test"
public static final String	DEFAULT_STREAM_THREADS	"1"
public static final String	DEFAULT_SUB_ZK_CONNECT	"localhost:2181"
public static final String	DEFAULT_THREAD_POOL_SIZE	"1000"
public static final int	DEFAULT_ZKCLIENT_CONNECTION_TIMEOUT	30000
public static final String	DEFAULT_ZKCLIENT_SERVER	"localhost:2181"
public static final int	DEFAULT_ZKCLIENT_SESSION_TIMEOUT	30000
public static final String	GROUP_ID	"group.id"
public static final String	KEY_DECODER	"key.decoder"
public static final int	NO_SUCH_BROKER	-1
public static final int	NO_SUCH_TOPIC	-1
public static final String	SINGLE_TOPIC	"single-topic"
public static final String	VALUE_DECODER	"value.decoder"
public static final String	ZKCONNECTION_TIMEOUT	"zk.connectiontimeout.ms"

org.cg.eventbus.producer.AbstractEventProducer<K,V>

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_BROKER_LIST	"localhost:9092"
public static final String	DEFAULT_PARTITION	"kafka.producer.DefaultPartitioner"
public static final String	LEADER_ACK	"1"
public static final String	NO_ACK	"0"
public static final String	PRO_TYPE_ASYNC	"async"
public static final String	QUIT_ON_ERROR	"quit-on-error"
public static final String	REPLICAS_ACK	"-1"

org.cg.eventbus.producer.EventProducerPool<K,V>

Modifier and Type	Constant Field	Value
public static final String	IDLE_SIZE	"idle.size"
public static final String	POOL_SIZE	"pool.size"