아래 코드는 Kafka 기반 메시지 통신을 이용해 A2A(Agent-to-Agent) 방식의 상호작용을 구현한 가장 기본적인 예제입니다. Producer 에이전트는 특정 사건(event)을 브로커에 발행하고, Consumer 에이전트는 자신이 구독하는 토픽에서 이 이벤트를 감지하여 후속 작업을 자율적으로 실행합니다.
# producer.py (발행 에이전트)
from kafka import KafkaProducer
import json
producer = KafkaProducer(
bootstrap_servers=['localhost:9092'],
value_serializer=lambda v: json.dumps(v).encode('utf-8'),
)
event = {
"event_type": "analysis.completed",
"document_id": "rfp-001",
"summary": "전략 추출 완료"
}
producer.send("a2a-events", event)
producer.flush()
print("이벤트 발행 완료")