Add protocol dto classes #5

src/main/java/com/github/nginate/kafka/KafkaClusterClient.java

@@ -1,7 +1,7 @@
 package com.github.nginate.kafka;
 
 import com.github.nginate.kafka.core.ClusterMetadata;
-import com.github.nginate.kafka.protocol.Partition;
+import com.github.nginate.kafka.dto.Partition;
 
 import java.io.Closeable;
 import java.net.InetAddress;

src/main/java/com/github/nginate/kafka/core/ClusterMetadata.java

@@ -1,8 +1,8 @@
 package com.github.nginate.kafka.core;
 
-import com.github.nginate.kafka.protocol.KafkaNode;
-import com.github.nginate.kafka.protocol.Partition;
-import com.github.nginate.kafka.protocol.TopicPartition;
+import com.github.nginate.kafka.dto.KafkaNode;
+import com.github.nginate.kafka.dto.Partition;
+import com.github.nginate.kafka.dto.TopicPartition;
 import lombok.Synchronized;
 
 import javax.annotation.concurrent.ThreadSafe;

src/main/java/com/github/nginate/kafka/protocol/KafkaNode.java → src/main/java/com/github/nginate/kafka/dto/KafkaNode.java

@@ -1,4 +1,4 @@
-package com.github.nginate.kafka.protocol;
+package com.github.nginate.kafka.dto;
 
 import lombok.AllArgsConstructor;
 import lombok.Builder;

src/main/java/com/github/nginate/kafka/protocol/Partition.java → src/main/java/com/github/nginate/kafka/dto/Partition.java

@@ -1,4 +1,4 @@
-package com.github.nginate.kafka.protocol;
+package com.github.nginate.kafka.dto;
 
 import lombok.AllArgsConstructor;
 import lombok.Builder;

src/main/java/com/github/nginate/kafka/protocol/TopicPartition.java → src/main/java/com/github/nginate/kafka/dto/TopicPartition.java

@@ -1,4 +1,4 @@
-package com.github.nginate.kafka.protocol;
+package com.github.nginate.kafka.dto;
 
 import lombok.AllArgsConstructor;
 import lombok.Builder;

src/main/java/com/github/nginate/kafka/exceptions/ApiException.java

@@ -0,0 +1,13 @@
+package com.github.nginate.kafka.exceptions;
+
+public class ApiException extends KafkaException {
+    private static final long serialVersionUID = 2342116151549303556L;
+
+    public ApiException(String message) {
+        super(message);
+    }
+
+    public ApiException(String message, Throwable cause) {
+        super(message, cause);
+    }
+}

src/main/java/com/github/nginate/kafka/protocol/ApiKeys.java

@@ -0,0 +1,26 @@
+package com.github.nginate.kafka.protocol;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+public enum ApiKeys {
+    PRODUCE(0, "produce"),
+    FETCH(1, "fetch"),
+    LIST_OFFSETS(2, "list_offsets"),
+    METADATA(3, "metadata"),
+    LEADER_AND_ISR(4, "leader_and_isr"),
+    STOP_REPLICA(5, "stop_replica"),
+    OFFSET_COMMIT(8, "offset_commit"),
+    OFFSET_FETCH(9, "offset_fetch"),
+    CONSUMER_METADATA(10, "consumer_metadata"),
+    JOIN_GROUP(11, "join_group"),
+    HEARTBEAT(12, "heartbeat");
+
+    /** the perminant and immutable id of an API--this can't change ever */
+    private final int id;
+    /** an english description of the api--this is for debugging and can change */
+    private final String name;
+
+}

src/main/java/com/github/nginate/kafka/protocol/Type.java

@@ -0,0 +1,5 @@
+package com.github.nginate.kafka.protocol;
+
+public enum Type {
+    INT8, INT16, INT32, INT64, STRING, BYTES
+}