Kafka

Kafka
git log -- contrib/librdkafka | git name-rev --stdin
ClickHouse version librdkafka version
21.1+ (#18671) 1.6.0-RC3 + snappy fixes + boring ssl
20.13+ (#18053) 1.5.0 + msan fixes + snappy fixes + boring ssl
20.7+ (#12991) 1.5.0 + msan fixes
20.5+ (#11256) 1.4.2
20.2+ (#9000) 1.3.0
19.11+ (#5872) 1.1.0
19.5+ (#4799) 1.0.0
19.1+ (#4025) 1.0.0-RC5
v1.1.54382+ (#2276) 0.11.4

Adjusting librdkafka settings

Adjusting librdkafka settings

Error handling

Error handling

Exactly once semantics

Exactly once semantics

Kafka main parsing loop

Kafka main parsing loop

Kafka parallel consuming

Kafka parallel consuming

Rewind / fast-forward / replay

Rewind / fast-forward / replay

SELECTs from engine=Kafka

SELECTs from engine=Kafka

Last modified 2021.08.12 : General corrections and updates. (5969b688)