Re #19358 update decoder for new schema
Showing
- Framework/LiveData/inc/MantidLiveData/Kafka/IKafkaBroker.h 3 additions, 2 deletionsFramework/LiveData/inc/MantidLiveData/Kafka/IKafkaBroker.h
- Framework/LiveData/inc/MantidLiveData/Kafka/KafkaBroker.h 2 additions, 2 deletionsFramework/LiveData/inc/MantidLiveData/Kafka/KafkaBroker.h
- Framework/LiveData/inc/MantidLiveData/Kafka/KafkaTopicSubscriber.h 1 addition, 3 deletions.../LiveData/inc/MantidLiveData/Kafka/KafkaTopicSubscriber.h
- Framework/LiveData/src/Kafka/KafkaBroker.cpp 4 additions, 4 deletionsFramework/LiveData/src/Kafka/KafkaBroker.cpp
- Framework/LiveData/src/Kafka/KafkaEventStreamDecoder.cpp 100 additions, 125 deletionsFramework/LiveData/src/Kafka/KafkaEventStreamDecoder.cpp
- Framework/LiveData/src/Kafka/KafkaTopicSubscriber.cpp 5 additions, 25 deletionsFramework/LiveData/src/Kafka/KafkaTopicSubscriber.cpp
Loading
Please register or sign in to comment