Skip to content

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

@vijayjadhav7

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

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions