Offset commit failed on partition - The request timed out

2019-04-17 Thread Matt Veitas
We have been seeing a number of timeouts for offset commits: `Offset commit failed on partition mytopic-12 at offset 16578269: The request timed out.`. These failed requests are sporadic and not causing a problem "yet", but we would rather like to understand what could the causes of something like

Bay area Kafka Meetup hosted by Confluent at Palo Alto, Monday 6pm, April 29, 2019

2019-04-17 Thread Guozhang Wang
Hello folks, The Confluent engineering team would like to invite you all to attend the first-ever Confluent hosted Bay Area Kafka® meetup on Monday 6pm, at Confluent's Palo Alto HQ. *RSVP and Register* (if you intend to attend in person): https://www.meetup.com/KafkaBayArea/events/260657485/ plea

Re: Using processor API via DSL

2019-04-17 Thread Alessandro Tagliapietra
So I've started with a new app with the archetype:generate as in https://kafka.apache.org/22/documentation/streams/tutorial I've pushed a sample repo here: https://github.com/alex88/kafka-test The avro schemas are a Metric with 2 fields: timestamp and production and a MetricList with a list of rec