@bengol 校招要吗

@Buffer2Disk 我测试目的不是这个额，我测试的目的是如果 kafka 断了，consumer 不会报错，只是没有数据了，那如果 consumer 无法输出数据，我怎么知道是 kafka 断了，还是本身就没有数据。

@gongweixin 结果是没有。。

@zoues 恩，测试异常情况下的反应

@diudiu13216 python-kafka

class Kafka_consumer():
def __init__(self, kafkahost, kafkaport, kafkatopic, groupid,flag,offset_value):
self.kafkaHost = kafkahost
self.kafkaPort = kafkaport
self.kafkatopic = kafkatopic
self.groupid = groupid
self.consumer = KafkaConsumer(self.kafkatopic, group_id = self.groupid,
bootstrap_servers = '{kafka_host}:{kafka_port}'.format(
kafka_host=self.kafkaHost,
kafka_port=self.kafkaPort ),enable_auto_commit=flag, auto_offset_reset=offset_value)
def consume_data(self):
try:
for message in self.consumer:
print "partition",message.partition
print "key",message.key
except Exception as e:
print "error",e
这是我的代码，在跑的过程中，故意中断 kafka，并不会报错，但是我又想显示连接中断的信息

@diudiu13216 确定么，好想我这边没有，客户端不回检测到异常额

@h3nng 都挂了

@stcasshern 对，可是如果这样的话，一旦 kafka 挂了，客户端却不知道，好尴尬，有解决方法吗，就是如果 kafka 挂了，客户端会收到相关信息

@BOYPT 我这边没开连接重用所以要等连接释放 60s 下次连接才可以重新开始。

@BOYPT 不不不，我的目的就是测试短链接。😂，故意做的这个实验？

@fuxkcsdn 嗯嗯，对的。只不过我没权限😂。然后我的目标也是测试默认条件下的极限就没改。

@kanchi240 就是短连接才有啊，长连接就没有。短时间大量连接释放，就会导致端口不够用。因为端口来不及被释放

@julyclyde 客户端

@hand515 但是我有个疑问就是，不是所有端口客户端都可以用么，还是说我要去修改这个值，如果我想用其他端口号的话

@kanchi240 不好意思哈，下次提问回注意。问题解决了，因为客户端端口范围是 28000+左右个。

@hand515 对的。刚看到了
  查看 linux 支持的客户端连接端口范围, 也就是 28232 个端口： 
        cat  /proc/sys/net/ipv4/ip_local_port_range
        32768 - 61000

@aip 多谢呢，我准备试着做呢

@aip 哈哈哈，确实没人会去检查呢

最终目标是 1 秒钟能 get 多少次，但是这个时间不好控制，我改为了相同次数 get 所花时间