From cdf39ca03e3e651b4175a9c7da620d6e8abcbb1f Mon Sep 17 00:00:00 2001
From: Terje Sannum <terje.sannum@nav.no>
Date: Wed, 24 Oct 2018 14:56:25 +0200
Subject: [PATCH] initial commit

---
 .gitignore                   |  1 +
 README.md                    |  8 +++++++
 pom.xml                      | 45 ++++++++++++++++++++++++++++++++++++
 src/main/java/TopicTest.java | 26 +++++++++++++++++++++
 4 files changed, 80 insertions(+)
 create mode 100644 .gitignore
 create mode 100644 README.md
 create mode 100644 pom.xml
 create mode 100644 src/main/java/TopicTest.java

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..2f7896d
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1 @@
+target/
diff --git a/README.md b/README.md
new file mode 100644
index 0000000..9419ecf
--- /dev/null
+++ b/README.md
@@ -0,0 +1,8 @@
+# kafka-adminclient-test
+
+Simple test of Kafka AdminClient (create topic)
+
+Run with:
+```
+mvn compile exec:java -Dexec.args="bootstrap-string topic-name" -Djava.security.auth.login.config=jaas-config-file
+```
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..5d12557
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,45 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <properties>
+    <java.version>1.8</java.version>
+    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+  </properties>
+
+  <groupId>test</groupId>
+  <artifactId>topictest</artifactId>
+  <packaging>jar</packaging>
+  <version>1.0</version>
+
+  <dependencies>
+    <dependency>
+      <groupId>org.apache.kafka</groupId>
+      <artifactId>kafka-clients</artifactId>
+      <version>2.0.0</version>
+    </dependency>
+  </dependencies>
+  <build>
+    <finalName>${project.artifactId}</finalName>
+    <plugins>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-compiler-plugin</artifactId>
+        <version>3.5.1</version>
+        <configuration>
+          <source>${java.version}</source>
+          <target>${java.version}</target>
+        </configuration>
+      </plugin>
+      <plugin>
+        <groupId>org.codehaus.mojo</groupId>
+        <artifactId>exec-maven-plugin</artifactId>
+        <version>1.6.0</version>
+        <configuration>
+          <mainClass>TopicTest</mainClass>
+          <cleanupDaemonThreads>false</cleanupDaemonThreads>
+        </configuration>
+      </plugin>
+    </plugins>
+  </build>
+</project>
diff --git a/src/main/java/TopicTest.java b/src/main/java/TopicTest.java
new file mode 100644
index 0000000..6149266
--- /dev/null
+++ b/src/main/java/TopicTest.java
@@ -0,0 +1,26 @@
+import java.util.Collections;
+import java.util.Properties;
+import org.apache.kafka.clients.admin.AdminClient;
+import org.apache.kafka.clients.admin.AdminClientConfig;
+import org.apache.kafka.clients.admin.CreateTopicsResult;
+import org.apache.kafka.clients.admin.KafkaAdminClient;
+import org.apache.kafka.clients.admin.NewTopic;
+
+public class TopicTest {
+
+  public static void main(String args[]) throws Exception {
+    String bootstrap = args[0];
+    String topic = args[1];
+    System.out.println("Creating topic "+topic+" on "+bootstrap);
+    Properties config = new Properties();
+    config.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrap);
+    config.put(AdminClientConfig.CLIENT_ID_CONFIG, "topics-test");
+    config.put(AdminClientConfig.SECURITY_PROTOCOL_CONFIG, "SASL_SSL");
+    config.put("sasl.mechanism", "PLAIN");
+    AdminClient admin = KafkaAdminClient.create(config);
+    NewTopic newTopic = new NewTopic(topic, 1, (short)1);
+    CreateTopicsResult result = admin.createTopics(Collections.singleton(newTopic));
+    result.values().get(topic).get();
+  }
+
+}