你的延时计算逻辑实际上是写入发送到接收之间的时间间隔，你要仔细分析一下写入，发送，接收和读入哪块的延时比较高，根据不同的情况调不同的参数

从错误上来看应该是zookeeper的机器安装kerberos的配置有问题 再仔细检查一下 大多数情况是集群的hostname问题

我们的集群有时候也这样，提交了任务找不到日志，跟踪下是偶尔发生还是经常发生吧，有的时候显示是UNASSIGNED 但是可能已经执行完了

pd.read_csv就可以指定从第几行开始读 设置skiprows参数

当然可以啊

是找不到文件吗？

理解是对的 没问题

数据安全一个是kerberos认证 一个是自己做一套权限系统 这两个都要用

网能通吗 能ping通吗

zk都是自己安装的，或者说自己维护的，只需要把zk的端口配置到模板即可

1、comsumer 非正常的rebalancing（重新分配分区）才会导致无法消费，如果不出现rebalancing，消息是不会重复消费或无法消费的。
2、当leader crash的时候，follower还没有同步到任何数据，而且这个follower被选举为新的leader的话，这样消息就会丢失。
3、kafka就是很好的选择啊，很多大公司这种场景都有kafka

from kafka import KafkaConsumer

consumer = KafkaConsumer('test',
bootstrap_servers=['172.21.10.136:9092'])

for message in consumer:
print ("%s:%d:%d: key=%s value=%s" % (message.topic, message.partition,
message.offset, message.key,

那篇文章？什么场景？解决什么问题？