程序关闭时，关掉kafka的连接， 不然运行long time任务的话，会出现需要等到group重新分配

[LeeC20]

No description provided.

[ydf0509]

加 def __ eixt__ 作用是什么呢？为什么你觉得这个方法会被运行呢？

在 Python 中，exit 方法是上下文管理器协议的一部分。它通常与 with 语句一同使用，目的是在退出上下文时执行清理操作。

这个consumer方法类不是上下文。