Skip to content

Commit

Permalink
Add config test
Browse files Browse the repository at this point in the history
  • Loading branch information
loicgreffier committed Jan 2, 2025
1 parent 8bfd2ad commit 8b67ba7
Show file tree
Hide file tree
Showing 2 changed files with 55 additions and 3 deletions.
Original file line number Diff line number Diff line change
@@ -0,0 +1,37 @@
package com.michelin.ns4kafka.integration;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;

import com.michelin.ns4kafka.integration.container.KafkaIntegrationTest;
import com.michelin.ns4kafka.property.ManagedClusterProperties;
import io.micronaut.test.extensions.junit5.annotation.MicronautTest;
import jakarta.inject.Inject;
import java.util.List;
import org.junit.jupiter.api.Test;

@MicronautTest
public class ConfigIntegrationTest extends KafkaIntegrationTest {

@Inject
List<ManagedClusterProperties> managedClusterProperties;

@Test
void shouldHaveDefaultTimeouts() {
assertNotNull(managedClusterProperties.getFirst());

assertEquals(15000, managedClusterProperties.getFirst().getTimeout().getAcl().getCreate());
assertEquals(15001, managedClusterProperties.getFirst().getTimeout().getAcl().getDelete());
assertEquals(15002, managedClusterProperties.getFirst().getTimeout().getAcl().getDescribe());

assertEquals(15003, managedClusterProperties.getFirst().getTimeout().getTopic().getAlterConfigs());
assertEquals(15004, managedClusterProperties.getFirst().getTimeout().getTopic().getCreate());
assertEquals(15005, managedClusterProperties.getFirst().getTimeout().getTopic().getDescribeConfigs());
assertEquals(15006, managedClusterProperties.getFirst().getTimeout().getTopic().getDelete());
assertEquals(15007, managedClusterProperties.getFirst().getTimeout().getTopic().getList());

assertEquals(15008, managedClusterProperties.getFirst().getTimeout().getUser().getAlterQuotas());
assertEquals(15009, managedClusterProperties.getFirst().getTimeout().getUser().getAlterScramCredentials());
assertEquals(15010, managedClusterProperties.getFirst().getTimeout().getUser().getDescribeQuotas());
}
}
21 changes: 18 additions & 3 deletions src/test/resources/application-test.yml
Original file line number Diff line number Diff line change
Expand Up @@ -23,11 +23,26 @@ ns4kafka:
- "userGroup"
managed-clusters:
test-cluster:
provider: SELF_MANAGED
manage-users: true
manage-acls: true
manage-topics: true
manage-connectors: true
manage-users: true
manage-topics: true
timeout:
acl:
create: 15000
delete: 15001
describe: 15002
topic:
alter-configs: 15003
create: 15004
describe-configs: 15005
delete: 15006
list: 15007
user:
alter-quotas: 15008
alter-scram-credentials: 15009
describe-quotas: 15010
provider: SELF_MANAGED
config:
bootstrap.servers: "localhost:9092" # Replaced by Testcontainers
sasl.mechanism: "PLAIN"
Expand Down

0 comments on commit 8b67ba7

Please sign in to comment.