程序包 com.sh.wf.mq.kafka

类 KafkaMQBase

java.lang.Object

com.sh.wf.mq.kafka.KafkaMQBase

直接已知子类:

KafkaMQConsumer, KafkaMQProducer

public class KafkaMQBase
extends Object

Description:

Title:首亨软件 - 聚天平台

字段概要

字段

修饰符和类型	字段	说明
static final String	AUTH
static final String	AUTH_IGNORE
static final String	DEFAULT_GROUP_ID
static final String	DEFAULT_TOPIC
protected String	topic

构造器概要

构造器

构造器	说明
KafkaMQBase()

方法概要

修饰符和类型	方法	说明
protected void	checkPropBase(Properties prop)	检查公共权限
String	getBootstrapServers()
protected void	setPropValue(Properties prop, String key, Object value)

从类继承的方法 java.lang.Object

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

字段详细资料

DEFAULT_TOPIC

public static final String DEFAULT_TOPIC

另请参阅:

• 常量字段值

DEFAULT_GROUP_ID

public static final String DEFAULT_GROUP_ID

另请参阅:

• 常量字段值

AUTH_IGNORE

public static final String AUTH_IGNORE

另请参阅:

• 常量字段值

AUTH

public static final String AUTH

另请参阅:

• 常量字段值

topic

protected String topic

构造器详细资料

KafkaMQBase

public KafkaMQBase()

方法详细资料

setPropValue

protected void setPropValue(Properties prop,
 String key,
 Object value)

getBootstrapServers

public String getBootstrapServers()

checkPropBase

protected void checkPropBase(Properties prop)

检查公共权限

参数:

prop -