You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Florian Hussonnois (JIRA)" <ji...@apache.org> on 2017/02/28 21:26:45 UTC

[jira] [Created] (KAFKA-4819) Expose states of active tasks to public API

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)