Process and punctuate contract

Hi What is the contract around Processor.process and punctuate. When will Kafka streams commit the offset After the process method is called successfully or not until punctuate is called? Regards Toby

Get broker metrics timeout

Hi all， we have a cluster with 10 brokers, and our kafka version is 0.9.0.1，we repeatedly get our metric data such as offlinePartition metric from each broker with 2 minutes gap to achieve the goal of cluster’s monitor. but accidental timeout occurs when we get data from some of brokers.

left join between PageViews(KStream) & UserProfile (KTable)

Hello all - I'm trying to run the sample PageView Kafka streams example, (ref - https://github.com/apache/kafka/tree/0.11.0/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview ) and have a question .. There is a leftJoin between PageView (Kstream) and UserProfile(Ktable) as s

Get Broker metrics timeout

Hi all， we have a cluster with 10 brokers, and our kafka version is 0.9.0.1，we repeatedly get our metric data such as offlinePartition metric from each broker with 2 minutes gap to achieve the goal of cluster’s monitor. but accidental timeout occurs when we get data from some of brokers.