Streams - retry configuration publishing changelog updates?

2018-01-23 Thread dan bress
I'm seeing this timeout in my Kafka Streams application logs: Caused by: org.apache.kafka.common.errors.TimeoutException: Expiring 7 record(s) for my-table-changelog-18: 30011 ms has passed since last append What kind of retries to I get by default publishing to changelogs? I have these producer

Expiring record(s) for topic: 30011 ms has passed since last append

2018-01-25 Thread Dan Bress
Hi, I'm running an app on Kafka Streams 1.0.0, and in the past day a lot of nodes are failing and I see this in the log. These appear to be failures when attempting to update the changelog. Any ideas on what I should do to work around this? Should I configure separate retry and timeouts for the