From 892d42e22bd0345a147240962ea84d7a07ca25dd Mon Sep 17 00:00:00 2001 From: Florian Hussonnois Date: Fri, 22 Mar 2024 23:03:59 +0100 Subject: [PATCH] fix(provider/aiven): fix regression on ACLs creation (#392) Fix: #392 --- .../extension/aiven/change/acl/KafkaAclEntryChangeHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/providers/jikkou-provider-aiven/src/main/java/io/streamthoughts/jikkou/extension/aiven/change/acl/KafkaAclEntryChangeHandler.java b/providers/jikkou-provider-aiven/src/main/java/io/streamthoughts/jikkou/extension/aiven/change/acl/KafkaAclEntryChangeHandler.java index fcd922a5a..0c0334cd4 100644 --- a/providers/jikkou-provider-aiven/src/main/java/io/streamthoughts/jikkou/extension/aiven/change/acl/KafkaAclEntryChangeHandler.java +++ b/providers/jikkou-provider-aiven/src/main/java/io/streamthoughts/jikkou/extension/aiven/change/acl/KafkaAclEntryChangeHandler.java @@ -41,7 +41,7 @@ public List> handleChanges(@NotNull List executeAsync( change, - () -> api.deleteKafkaAclEntry(getEntry(change, KafkaAclEntry.class).id())) + () -> api.addKafkaAclEntry(getEntry(change, KafkaAclEntry.class))) ) .collect(Collectors.toList()); }