diff --git a/eos/kafka_events.py b/eos/kafka_events.py index 7f638e9..a07c143 100644 --- a/eos/kafka_events.py +++ b/eos/kafka_events.py @@ -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: """