You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "James Shaw (Jira)" <ji...@apache.org> on 2023/05/04 08:54:00 UTC

[jira] [Created] (KAFKA-14967) MockAdminClient throws NullPointerException in CreateTopicsResult

James Shaw created KAFKA-14967:
----------------------------------

             Summary: MockAdminClient throws NullPointerException in CreateTopicsResult
                 Key: KAFKA-14967
                 URL: https://issues.apache.org/jira/browse/KAFKA-14967
             Project: Kafka
          Issue Type: Bug
          Components: clients
    Affects Versions: 3.4.0
            Reporter: James Shaw


Calling {{CreateTopicsResult.topicId().get()}} throws {{NullPointerException}}, while {{KafkaAdminClient}} correctly returns the topicId.


Test case to reproduce:

{code:java} 
import org.apache.kafka.clients.admin.Admin;
import org.apache.kafka.clients.admin.CreateTopicsResult;
import org.apache.kafka.clients.admin.MockAdminClient;
import org.apache.kafka.clients.admin.NewTopic;
import org.apache.kafka.common.Node;
import org.apache.kafka.common.Uuid;
import org.junit.jupiter.api.Test;

import java.util.Optional;
import java.util.concurrent.ExecutionException;

import static java.util.Collections.singletonList;

public class MockAdminClientBug {
    @Test
    void shouldNotThrowNullPointerException() throws ExecutionException, InterruptedException {
        Node controller = new Node(0, "mock", 0);
        try (Admin admin = new MockAdminClient(singletonList(controller), controller)) {
            CreateTopicsResult result = admin.createTopics(singletonList(new NewTopic("TestTopic", Optional.empty(), Optional.empty())));
            Uuid topicId = result.topicId("TestTopic").get();
            System.out.println(topicId);
        }
    }
}
{code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)