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

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

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