Florian Hussonnois created KAFKA-4819:
-----------------------------------------
Summary: Expose states of active tasks to public API
Key: KAFKA-4819
URL: https://issues.apache.org/jira/browse/KAFKA-4819
Project: Kafka
Issue Type: New Feature
Components: streams
Affects Versions: 0.10.2.0
Reporter: Florian Hussonnois
Priority: Minor
In Kafka 0.10.1.0 the toString method of KafkaStreams class has been
implemented mainly to ease topologies debugging. Also, the streams Metrics has
been exposed to public API.
But currently theres is no way to monitor kstreams tasks states, assignments or
consumed offsets.
I propose to expose the states of active tasks to the public API KafkaStreams.
For instance, an application can expose a REST API to get the global state of a
kstreams topology.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
