创建kafka consumer的stop函数 - Programming版

本页内容为未名空间相应帖子的节选和存档，一周内的贴子最多显示50字，超过一周显示500字访问原贴

Programming版 - 创建kafka consumer的stop函数

相关主题
● Kafka consumer启动怎样不读之前的massage	● java 真不适合12306一类的网站
● 问个Java问题	● c++的两大威胁
● javascript里面的done(), next() 函数?	● 傻逼太监懂个屁C＊
● MATLAB function call too slow	● erlang系的东西从来都以量大著称
● 给大家出个多进程的题	● 有专门讲 message server performance 的资料吗
● 二爷看过来。	● redis, kafka
● 发现一个大牛	● Scala的用途
● Cassandra 看测试read也不算慢呢	● Celery in Golang and Scala?

相关话题的讨论汇总
话题: thread话题: 函数话题: consumer话题: 创建

进入Programming版参与讨论

(共1页)

h*****4
发帖数: 4219

consumerConnector 的Interface有shutdown，不过这个shutdown会把目前的
consumerConnector给干掉...
现在想实现一个stop的函数，就是类似于把consumer放入wait的state，等个5分钟左右
，然后如果start被叫了而且这个consumerConnector还活着，就转入running，不然再
创建一个新的...
要实现这个函数，是不是直接搞个新的thread然后把这个consumerConnector给这个
thread，主thread该干嘛干嘛，这个thread就听信干活就好？

(共1页)

进入Programming版参与讨论

相关主题
● Celery in Golang and Scala?	● 给大家出个多进程的题
● zookeeper 这种牛鼻软件都是apache自己的人写的？	● 二爷看过来。
● 大牛们讲讲MQ到底好在哪里？	● 发现一个大牛
● Pinterest陶涛：三个教训和三个发展选择	● Cassandra 看测试read也不算慢呢
● Kafka consumer启动怎样不读之前的massage	● java 真不适合12306一类的网站
● 问个Java问题	● c++的两大威胁
● javascript里面的done(), next() 函数?	● 傻逼太监懂个屁C＊
● MATLAB function call too slow	● erlang系的东西从来都以量大著称

相关话题的讨论汇总
话题: thread话题: 函数话题: consumer话题: 创建

#	版面	帖数(主题数)
-	全站	4871 (796)
1	Military	3777 (569)
2	Stock	341 (51)
3	Joke	117 (17)
4	History	116 (3)
5	Automobile	100 (9)
6	USANews	55 (9)
7	Midlife	45 (1)
8	Headline	41 (41)
9	Dreamer	33 (13)
10	FleaMarket	32 (20)
11	Living	30 (7)

boards

未名新帖统计// 7月16日

历史上的今天