Monitoring streams

2019-07-08 Thread Brian Putt
Hello, We have multiple stream services that we're looking to monitor when they've been disconnected from the broker so that we can restart the services. I've looked at https://issues.apache.org/jira/browse/KAFKA-6520 and am wondering if anyone has suggestions on what we can do today to help ensu

Re: Kafka streams issue

2019-06-12 Thread Brian Putt
Sax wrote: > Does the application transit to RUNNING state? Also check > `KafkaStreams#localThreadsMetadata()` what tasks are assigned? > > You might also enable DEBUG logs for > `org.apache.kafka.clients.consumer.**` classes to see if the consumer > sends fetch request to the br

Re: Kafka streams issue

2019-06-11 Thread Brian Putt
plication rebalance correctly? > - Does it start processing? > - Anything in the logs about the status of the application? > > > -Matthias > > On 6/10/19 6:19 PM, Brian Putt wrote: > > Hello, > > > > I'm working with the kafka streams api and am runni

Kafka streams issue

2019-06-10 Thread Brian Putt
Hello, I'm working with the kafka streams api and am running into issues where I subscribe to multiple topics and the consumer just hangs. It has a unique application.id and I can see in kafka that the consumer group has been created, but when I describe the group, I'll get: consumer group X has n