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()); }