diff --git a/Framework/Backend/kafka/KafkaMessagesConsumer.js b/Framework/Backend/kafka/KafkaMessagesConsumer.js index b9164409c..3ca1ff518 100644 --- a/Framework/Backend/kafka/KafkaMessagesConsumer.js +++ b/Framework/Backend/kafka/KafkaMessagesConsumer.js @@ -1,4 +1,4 @@ -const { LogManager } = require('@aliceo2/web-ui'); +const { LogManager } = require('../log/LogManager.js'); /** * Generic Kafka Message consumer extracting objects according to a protobuf definition diff --git a/Framework/Backend/test/mocha-kafka.js b/Framework/Backend/test/mocha-kafka.js index 342225c48..f83b4fefb 100644 --- a/Framework/Backend/test/mocha-kafka.js +++ b/Framework/Backend/test/mocha-kafka.js @@ -1,5 +1,5 @@ -const { AliEcsEventMessagesConsumer } = require('../index.js'); const { Kafka } = require('kafkajs'); +const { AliEcsEventMessagesConsumer } = require('../kafka/AliEcsEventMessagesConsumer.js'); describe('KAFKA CONSUMERS', () => { it('should successfully create an AliECS event message consumer', async () => {