Re: suscribe

See: http://kafka.apache.org/contact On 12/22/16 7:25 PM, em vee wrote: > > signature.asc Description: OpenPGP digital signature

Kafka offset monitoring sounds not support `kafka 0.10.1.0`.

Hi, I am trying to use KafkaOffsetMonitor to monitor kakfa consumer Lag, but I can not see any consumer offset information. so I doubt there may be `KafkaOffsetMonitor` not support `kafka 0.10.1.0`, is anyone running into the issue I am

Re: Common client metrics - per request?

Hi Stevo, Common requests for producers and consumers are only metadata, and for admin clients its request like describe groups are not used in other clients either, so I feel common client metrics per request / response do not cover much of the requests since most of the time most requests wont

Re: Failure metrics

Gaurav, Those two metrics are server-side ones which records when an unexpected exception happens when handling the request. However, if the request even failed to reach the broker at all, they will not be recorded in this metrics. You can take a look at this section of the web site, which

Re: Is it a bad idea to use periods within a consumer group name? "my-service.topic1_consumer_group"

Thanks Praveen. I realized I'd been mis-remembering the warning that I'd been seeing. The limitation is for topic names, not consumer group names: *WARNING: Due to limitations in metric names, topics with a period ('.') or underscore ('_') could collide. To avoid issues it is best to use either,

Re: [ANNOUCE] Apache Kafka 0.10.1.1 Released

>From what i can tell, it looks like the main kafka website is not updated with this release. Download page shows 0.10.1.0 as latest release. The above link for release notes does not work either. Not Found The requested URL /dist/kafka/0.10.1.1/RELEASE_NOTES.html was not found on this server.

Re: can kafka 10 stream API read the topic from a Kafka 9 cluster?

No. All Java clients (including Streams) need to be the same version (or lower) as the brokers they connect to. -hans > On Dec 23, 2016, at 1:03 AM, Sachin Mittal wrote: > > Is Kafka streams 0.10.2.0-SNAPSHOT compatible with 0.10.0.1 broker. > I was facing broker

Re: Heavy traffic between Kafka nodes

How much more data is flowing between the two nodes versus the total ingress rate of the cluster? I would expect inter-broker bandwidth use to be about the same as the ingress rate for the entire cluster since all the data coming into node 1 needs to get replicated to node 2 (for redundancy)

Re: what is the key used for change log topic backed by windowed store

Hi Sachin, The key is a combination of the record key + window start time + a sequence number. The timestamp is 8 bytes and the sequence number is 4 bytes. Thanks, Damian On Thu, 22 Dec 2016 at 15:26 Sachin Mittal wrote: > Hi All, > Our stream is something like > >

Re: Error in kafka-stream example

Hi, Have you tried building the examples with the provided pom.xml? Last i checked it all compiled and worked. Thanks On Thu, 22 Dec 2016 at 16:13 Amrit Jangid wrote: > Hi All, > > I want to try out kafka stream example using this example : > >

Re: can kafka 10 stream API read the topic from a Kafka 9 cluster?

Is Kafka streams 0.10.2.0-SNAPSHOT compatible with 0.10.0.1 broker. I was facing broker connect issue and it just did not work. Thanks Sachin On Fri, Dec 23, 2016 at 4:25 AM, wrote: > Kafka clients (currently) do not work against older Kafka brokers/servers > so you have no