[DevOps] Kafka graceful shutdown 구현하기
```pythonclass KafkaConsumer: def init(self, loop: asyncio.AbstractEventLoop, group_id: str): self.stop_event = asyncio.Event() for sig in (signal.SIGTERM, signal.SIGINT): loop.add_signal_handler(sig, self.stop_event.set)
READ ↗