Skip to content

Commit a35a115

Browse files
authored
Fix encrypted password pull consumer commit mode (#18044) (#18064)
(cherry picked from commit bd952e1)
1 parent 9ad7c19 commit a35a115

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

‎integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/param/IoTDBEncryptedPasswordPullConsumerIT.java‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -150,6 +150,7 @@ private SubscriptionPullConsumer createConsumer(
150150
.encryptedPassword(encryptedPassword)
151151
.consumerId("consumer_" + consumerGroupId)
152152
.consumerGroupId(consumerGroupId)
153+
.autoCommit(false)
153154
.buildPullConsumer();
154155
}
155156

0 commit comments

Comments
 (0)