diff --git a/onetl/connection/db_connection/kafka/connection.py b/onetl/connection/db_connection/kafka/connection.py index 3a87e2759..1d701d82c 100644 --- a/onetl/connection/db_connection/kafka/connection.py +++ b/onetl/connection/db_connection/kafka/connection.py @@ -47,8 +47,7 @@ "endingOffsetsByTimestamp", "endingOffsets", "startingOffsetsByTimestampStrategy", - "kafka.bootstrap.servers", - "kafka.group.id", + "kafka.*", "topic", ), )