Skip to content

Java messageconsumer

dennis zhuang edited this page May 30, 2013 · 10 revisions

在消息生产者发送消息成功后,消息就存储在服务端的数据目录里(服务端dataPath配置的目录),按照topic-partition的目录格式存储。接下来,消息的消费者就需要消费这些消息,这一节就是讲述如何消费某个topic下的消息。 #配置消费者

#创建消费者

#订阅Topic

#处理消息

##并发处理

##回滚消息

##错误处理

##中断处理

##拒绝处理器

##offset管理

#关闭

Clone this wiki locally