János Benjamin Antal 0e36db5437 Do not check the value of num_messages_read because it is not reliable ... librdkafka usually polls both messages on the first SELECT, but sometimes only one. If it polls only one message first, then it will read two messages before rebalancing at the second SELECT from the table. This means it usually reads a single message twice (thus num_messages_read = 4 is usually fine as 1 discarded message + 3 actually consumed message). But when only one message is read in the first SELECT, then 2 messages are discarded, thus num_messages_read will be 5 as 2 discarded message + 3 actually consumed messages.		2024-07-31 22:09:04 +00:00
..
clickhouse_path/format_schemas	Fix kafka tests	2023-12-29 17:02:46 +00:00
configs	refactore: improve reading several configurations for kafka	2024-03-27 14:53:33 +01:00
__init__.py
kafka_pb2.py	Update black version, run it for the repository	2023-03-24 11:54:38 +01:00
message_with_repeated_pb2.py	Update black version, run it for the repository	2023-03-24 11:54:38 +01:00
social_pb2.py	Update black version, run it for the repository	2023-03-24 11:54:38 +01:00
test_kafka_json.reference
test_kafka_virtual1.reference
test_kafka_virtual2.reference	Update tests	2020-07-31 00:24:14 +03:00
test.py	Do not check the value of num_messages_read because it is not reliable	2024-07-31 22:09:04 +00:00