mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-12-14 10:22:10 +00:00
f9d81bc774
Simplify and do some refactoring for kafka client settings. Allows to set up separate settings for consumer and producer like: ``` <consumer> ... </consumer> <producer> <kafka_topic> <name>topic_name</name> ... </kafka_topic> </producer> ``` Moreover, this fixes warnings from kafka client like: `Configuration property session.timeout.ms is a consumer property and will be ignored by this producer instance` |
||
---|---|---|
.. | ||
clickhouse_path/format_schemas | ||
configs | ||
__init__.py | ||
kafka_pb2.py | ||
message_with_repeated_pb2.py | ||
social_pb2.py | ||
test_kafka_json.reference | ||
test_kafka_virtual1.reference | ||
test_kafka_virtual2.reference | ||
test.py |