diff --git a/src/main/java/com/sngular/kloadgen/sampler/KafkaProducerSampler.java b/src/main/java/com/sngular/kloadgen/sampler/KafkaProducerSampler.java index c9ee3eac..fdbd905e 100644 --- a/src/main/java/com/sngular/kloadgen/sampler/KafkaProducerSampler.java +++ b/src/main/java/com/sngular/kloadgen/sampler/KafkaProducerSampler.java @@ -21,13 +21,11 @@ import com.sngular.kloadgen.loadgen.BaseLoadGenerator; import com.sngular.kloadgen.model.HeaderMapping; import com.sngular.kloadgen.randomtool.generator.StatelessGeneratorTool; -import com.sngular.kloadgen.serializer.AvroSerializer; import com.sngular.kloadgen.serializer.EnrichedRecord; import com.sngular.kloadgen.util.ProducerKeysHelper; import com.sngular.kloadgen.util.PropsKeysHelper; import io.apicurio.registry.serde.Legacy4ByteIdHandler; import io.apicurio.registry.serde.SerdeConfig; -import org.apache.commons.lang3.SerializationException; import org.apache.commons.lang3.StringUtils; import org.apache.jmeter.config.Arguments; import org.apache.jmeter.protocol.java.sampler.AbstractJavaSamplerClient; diff --git a/src/main/java/com/sngular/kloadgen/util/ProducerKeysHelper.java b/src/main/java/com/sngular/kloadgen/util/ProducerKeysHelper.java index 69b9af58..8db1873a 100644 --- a/src/main/java/com/sngular/kloadgen/util/ProducerKeysHelper.java +++ b/src/main/java/com/sngular/kloadgen/util/ProducerKeysHelper.java @@ -8,7 +8,6 @@ import com.sngular.kloadgen.serializer.AvroSerializer; import com.sngular.kloadgen.serializer.GenericAvroRecordSerializer; -import org.apache.kafka.common.serialization.StringSerializer; public final class ProducerKeysHelper {