Skip to content

Kafka Producer Adapter doesn't process re-queued measurements #78

Description

@vijayjadhav7

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

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions