public static void createTopic()

in src/main/java/com/epam/eco/commons/kafka/AdminClientUtils.java [150:168]

17 lines of code
2 McCabe index (conditional complexity)


    public static void createTopic(
            AdminClient client,
            String topicName,
            int partitionCount,
            int replicationFactor,
            Map<String, String> config) {
        Validate.notNull(client, "Admin client is null");
        Validate.notBlank(topicName, "Topic name is blank");
        Validate.isTrue(partitionCount > 0, "Partition count is invalid");
        Validate.isTrue(replicationFactor > 0, "Replication factor is invalid");

        NewTopic newTopic = new NewTopic(topicName, partitionCount, (short)replicationFactor);
        if (config != null) {
            newTopic.configs(config);
        }

        completeAndGet(
                client.createTopics(Collections.singletonList(newTopic)).all());
    }