nyx/tests/dynamic_fixtures/message_handler/kafka_python/benign.py

10 lines
215 B
Python
Raw Permalink Normal View History

2026-06-05 10:16:30 -05:00
"""Phase 20 (Track M.2) — Kafka Python benign control."""
import os
import shlex
_NYX_ADAPTER_MARKER = "from kafka import KafkaConsumer"
def handler(message):
os.system("echo " + shlex.quote(str(message)))