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