changed topic names

2026-02-02 17:25:29 +01:00
parent 98244327eb
commit e3d15a1142
1 changed files with 2 additions and 2 deletions
@@ -25,8 +25,8 @@ except ImportError:


 KAFKA_BROKER = 'linkafka01.psi.ch:9092'
-AMOR_EVENTS = 'amor_ev44'
-AMOR_NICOS = 'AMOR_nicosForwarder'
+AMOR_EVENTS = 'amor_detector'
+AMOR_NICOS = 'amor_nicosForwarder'

 class KafkaFrozenData:
    """