diff --git a/taos-ws-py/Cargo.toml b/taos-ws-py/Cargo.toml index 42b76234..2376daba 100644 --- a/taos-ws-py/Cargo.toml +++ b/taos-ws-py/Cargo.toml @@ -14,7 +14,7 @@ anyhow = "1" log = "0.4" serde_json = "1" shadow-rs = "0.20.0" -taos = { version = "0.8.12", default-features = false, features = ["optin", "ws-rustls"] } +taos = { version = "0.10.15", default-features = false, features = ["optin", "ws-rustls"] } chrono = "0.4" [build-dependencies] diff --git a/taos-ws-py/src/consumer.rs b/taos-ws-py/src/consumer.rs index 93306c01..852e19e6 100644 --- a/taos-ws-py/src/consumer.rs +++ b/taos-ws-py/src/consumer.rs @@ -120,6 +120,8 @@ impl Consumer { ))?; } + builder.set("enable.auto.commit", "true"); + builder.set("experimental.snapshot.enable", "false"); const KEYS: &[&str] = &[ "client.id", "auto.offset.reset",