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)