kafkakafka 消费的时候 退出
Posted 九师兄
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了kafkakafka 消费的时候 退出相关的知识，希望对你有一定的参考价值。
1.概述
消费者的poll方法- -般都是 被while( true)语句包含的,那么退出就是一个问题.
- 在另外-个线程使用consumer . wakeup();会抛出WakeupException异 常,该异常不需要去捕获,它会自己发送LeaveGroup request.但是在之后需要手动关闭consumer.
- 总的来说也是方法- -的变型.利用
Runtime.getRuntime ( ) .addShutDownHook (Thread);来调用consumer . wakeup();, ShutDownHook运行在另外一个线程中.当按下ctrl+c的时候触发ShutDownHook中传入的线程，最后运行完结束主程序.
消费者安全退出示例
以上是关于kafkakafka 消费的时候 退出的主要内容，如果未能解决你的问题，请参考以下文章
kafkakafka 查看 GroupCoordinator 以及 kafka Group dead 消费组死掉 以及 GroupCoordinatorRequest 使用
kafkakafka 消费 带有 kerberos认证的服务器
kafkakafka 消费报错 No entry found for connection
KafkaKafka 如果 动态 不停止的情况下 修改 消费组 offset
kafkakafka 控制台 消费 ip 却找 域名 报错 Can‘t resolve address UnresolvedAddressException