Skip to content

Kafka fixes part1#8876

Closed
filimonov wants to merge 2 commits intoClickHouse:masterfrom
filimonov:kafka_fixes_part1
Closed

Kafka fixes part1#8876
filimonov wants to merge 2 commits intoClickHouse:masterfrom
filimonov:kafka_fixes_part1

Conversation

@filimonov
Copy link
Copy Markdown
Contributor

@filimonov filimonov commented Jan 28, 2020

I hereby agree to the terms of the CLA available at: https://yandex.ru/legal/cla/?lang=en

Changelog category (leave one):

  • Bug Fix

Changelog entry (a user-readable short description of the changes that goes to CHANGELOG.md):
Don't commit polled batch partially as it can lead to holes in data.
Test and fix for flush by time and by block size.

Detailed description / Documentation draft:
The 'hole' in data can appear when polled batch contains data from more than one partition and in committed partially - it seems like rdkafka doesn't expect that bulk polled at once will be committed in parts (quite logical actually).

@filimonov filimonov added altinity pr-bugfix Pull request with bugfix, not backported by default comp-message-queues Message queue integrations (Kafka, RabbitMQ, NATS table engines for stream ingestion/egress). labels Jan 28, 2020
@filimonov filimonov mentioned this pull request Jan 30, 2020
@filimonov
Copy link
Copy Markdown
Contributor Author

Superseded by #8917.

@filimonov filimonov closed this Jan 30, 2020
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

comp-message-queues Message queue integrations (Kafka, RabbitMQ, NATS table engines for stream ingestion/egress). pr-bugfix Pull request with bugfix, not backported by default

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant