We've connected a PMU to OpenPDC. And have configured a Kafka Producer Adapter to stream measurements to a Kafka topic.
It works as expected. But when it's not able to connect to the Kafka cluster due to network failure/cluster downtime/etc., it starts storing the measurements in in-memory output queue presumably to process when it reconnects.
But it doesn't process the output queue messages stored in the memory. It only starts streaming the current measurements.
KafkaProducerAdapter config:
Servers=http://kafka-server:9092;
Encoding=UTF-8;
RequeueOnException=True;
InputMeasurementKeys={measurements};
Topic=kafka-topic;
CacheMetadataLocally=False;
ValueFormat=0.######;
SerializeMetadata=False
We've connected a PMU to OpenPDC. And have configured a Kafka Producer Adapter to stream measurements to a Kafka topic.
It works as expected. But when it's not able to connect to the Kafka cluster due to network failure/cluster downtime/etc., it starts storing the measurements in in-memory output queue presumably to process when it reconnects.
But it doesn't process the output queue messages stored in the memory. It only starts streaming the current measurements.
KafkaProducerAdapter config:
Servers=http://kafka-server:9092;
Encoding=UTF-8;
RequeueOnException=True;
InputMeasurementKeys={measurements};
Topic=kafka-topic;
CacheMetadataLocally=False;
ValueFormat=0.######;
SerializeMetadata=False