This commit is contained in:
iliax 2023-05-05 10:17:25 +04:00
parent 1b3c131255
commit 121260afdb
2 changed files with 3 additions and 3 deletions

View file

@ -185,7 +185,7 @@ public class AclsService {
}
//Write, Describe, Create permission on topics, Write, Describe on transactionalIds
//IDEMPOTENT_WRITE of cluster if idempotent is enabled
//IDEMPOTENT_WRITE on cluster if idempotent is enabled
private List<AclBinding> createProducerBindings(CreateProducerAclDTO request) {
List<AclBinding> bindings = new ArrayList<>();
bindings.addAll(

View file

@ -180,7 +180,7 @@ class AclsServiceTest {
).block();
//Write, Describe, Create permission on topics, Write, Describe on transactionalIds
//IDEMPOTENT_WRITE of cluster if idempotent is enabled (true)
//IDEMPOTENT_WRITE on cluster if idempotent is enabled (true)
Collection<AclBinding> createdBindings = (Collection<AclBinding>) createdCaptor.getValue();
assertThat(createdBindings)
.hasSize(6)
@ -225,7 +225,7 @@ class AclsServiceTest {
).block();
//Write, Describe, Create permission on topics, Write, Describe on transactionalIds
//IDEMPOTENT_WRITE of cluster if idempotent is enabled (false)
//IDEMPOTENT_WRITE on cluster if idempotent is enabled (false)
Collection<AclBinding> createdBindings = (Collection<AclBinding>) createdCaptor.getValue();
assertThat(createdBindings)
.hasSize(5)