mirror of
https://github.com/elicpeter/nyx.git
synced 2026-06-09 19:45:13 +02:00
10 lines
215 B
Python
10 lines
215 B
Python
|
|
"""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)))
|