From 56a2ffa46bd0620012acb674d3505fb32b5bda8f Mon Sep 17 00:00:00 2001
From: Leopold Schabel <leo@nexantic.com>
Date: Wed, 3 Nov 2021 16:59:57 +0100
Subject: [PATCH] Remove unused KafkaState

---
 transport/kafka/kafka.go | 8 --------
 1 file changed, 8 deletions(-)

diff --git a/transport/kafka/kafka.go b/transport/kafka/kafka.go
index 5e2d86b..76f8fa2 100644
--- a/transport/kafka/kafka.go
+++ b/transport/kafka/kafka.go
@@ -17,14 +17,6 @@ import (
 	log "github.com/sirupsen/logrus"
 )
 
-type KafkaState struct {
-	FixedLengthProto bool
-	producer         sarama.AsyncProducer
-	topic            string
-	hashing          bool
-	keying           []string
-}
-
 type KafkaDriver struct {
 	kafkaTLS   bool
 	kafkaSASL  bool