Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

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

Open
vijayjadhav7 opened this issue Oct 8, 2021 · 0 comments
Open

Comments

@vijayjadhav7
Copy link

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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant