Skip to content

Tag: apache-kafka

Debezium flush timeout and OutOfMemoryError errors with MySQL

Using Debezium 0.7 to read from MySQL but getting flush timeout and OutOfMemoryError errors in the initial snapshot phase. Looking at the logs below it seems like the connector is trying to write too many messages in one go: Wonder what the correct settings are for sizeable databases (>50GB). I didn’t have this issue with smaller databases. Simply increasing

Kafka message ordering in partition while producer retry

According to producer configs, there are: retries and Suppose that retries > 0 and > 1. Can messages arrive out of order within ONE partition of topic (e.g. if first message has retries, but second message delivered to broker with the first attempt)? Or do out of order only happen across several partitions of topic, but within partition