KafkaMQConsumer

嵌套类
限定符和类型	类和说明
`static class`	`KafkaMQConsumer.ConsumerPropBuilder`

字段概要
- 从类继承的字段 com.sh.wf.mq.kafka.KafkaMQBase
  AUTH, AUTH_IGNORE, DEFAULT_GROUP_ID, DEFAULT_TOPIC

所有方法静态方法实例方法具体方法
限定符和类型	方法和说明
`void`	`close()`
`org.apache.kafka.clients.consumer.KafkaConsumer<java.lang.String,java.lang.String>`	`connect(java.util.Properties prop)`
`static KafkaMQConsumer`	`getInstance(java.lang.String topic)`
`org.apache.kafka.clients.consumer.ConsumerRecords<java.lang.String,java.lang.String>`	`getMessage(java.time.Duration timeout)` 获取一次消息列表
`static void`	`main(java.lang.String[] args)`
`void`	`subscribe(KafkaMQCallBack callback)`
`void`	`subscribe(KafkaMQConsumer.ConsumerPropBuilder builder, KafkaMQCallBack callback)`
`boolean`	`subscribe(java.util.Properties prop, KafkaMQCallBack callback)` 订阅消息

从类继承的方法 java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

public static KafkaMQConsumer getInstance(java.lang.String topic)

public org.apache.kafka.clients.consumer.KafkaConsumer<java.lang.String,java.lang.String> connect(java.util.Properties prop)

public void subscribe(KafkaMQCallBack callback)

public void subscribe(KafkaMQConsumer.ConsumerPropBuilder builder,
                      KafkaMQCallBack callback)

public boolean subscribe(java.util.Properties prop,
                         KafkaMQCallBack callback)

订阅消息

public org.apache.kafka.clients.consumer.ConsumerRecords<java.lang.String,java.lang.String> getMessage(java.time.Duration timeout)

获取一次消息列表

public static void main(java.lang.String[] args)

类 KafkaMQConsumer