오류모음집/kafka (1) 썸네일형 리스트형 aiokafka.errors.IllegalStateError: IllegalStateError: Subscription to topics, partitions and pattern are mutually exclusive 발생 경위: consumer에서 특정 partition을 소모하려고 할때 발생 코드는 다음과 같다 @handle_kafka_errors async def initialize(self) -> None: """Kafka 소비자 및 생산자 연결 초기화""" if self.consumer_topic: self.consumer = AIOKafkaConsumer( self.conuser_topic, bootstrap_servers=self.bootstrap_servers, group_id=self.group_id, auto_offset_reset="lates.. 이전 1 다음
