{"repo":"factorhouse/kpow-streams-agent","free":true,"listed":false,"github":"https://github.com/factorhouse/kpow-streams-agent","clone":"git clone https://github.com/factorhouse/kpow-streams-agent.git","description":"Monitor Kafka Streams applications with Kpow","language":"Java","stars":11,"topics":["kafka","streams","kafka-streams","monitoring","java","agent","metrics"],"license":"Apache-2.0","category":"analytics","readme_excerpt":"Kpow Streams Agent This repository contains the Kpow Streams Agent. Use this agent to integrate your Kafka Streams applications with Kpow and unlock the following features: See summaries of Kafka Streams activity for your Kafka cluster(s). Monitor Kafka Streams metrics (e.g Streams State, Stream-Thread, State Store, RocksDB, etc). Visualise Kafka Streams topologies in the Kpow Workflows UI. Aggregate and Expose Kafka Streams metrics via Kpow Prometheus Endpoints (for alerting, etc). See the Kpow Kafka Streams Feature Guide for full documentation. See the Kpow Kafka Streams Spring Word Count Example for an integration of Spring, Kafka, and Kpow. --- --- --- Prerequisites The Kpow Streams Agent requires a running instance of Kpow. Evaluate Kpow with the Kpow Local repository or see our Quick Start guide. Installation The Kpow Stream Agent can be found on Maven Central. Include the agent as a dependency in your Kafka Streams application. Integration In your application, just before you start your KafkaStreams instance: Create a new io.factorhouse.kpow.StreamsRegistry instance. Register your KafkaStreams and Topology instances with the StreamsRegistry. The StreamsRegistry is a single-threaded process that performs these actions once every minute : Capture metadata about each registered Kafka Streams application. Produce snapshots to the Kpow internal oprtr snapshot state topic. The StreamsRegistry does not talk directly to Kpow . Kpow reads streams data from the snapshot topic. M","default_branch":null,"files":null,"tree":[],"storefront":"/r/factorhouse","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/factorhouse/kpow-streams-agent/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}