From f581f07fbb70b9fa25f79de83e5ad3508cfdd927 Mon Sep 17 00:00:00 2001 From: John Axe Date: Thu, 9 May 2024 07:25:47 -0300 Subject: [PATCH] feat: add silent option --- .../kafka/request/builder/KafkaAvro4sRequestBuilder.scala | 5 +---- .../org/galaxio/gatling/kafka/request/builder/Sender.scala | 4 +--- 2 files changed, 2 insertions(+), 7 deletions(-) diff --git a/src/main/scala/org/galaxio/gatling/kafka/request/builder/KafkaAvro4sRequestBuilder.scala b/src/main/scala/org/galaxio/gatling/kafka/request/builder/KafkaAvro4sRequestBuilder.scala index 579f4e5..c7ed196 100644 --- a/src/main/scala/org/galaxio/gatling/kafka/request/builder/KafkaAvro4sRequestBuilder.scala +++ b/src/main/scala/org/galaxio/gatling/kafka/request/builder/KafkaAvro4sRequestBuilder.scala @@ -4,10 +4,7 @@ import com.softwaremill.quicklens.ModifyPimp import io.gatling.core.action.builder.ActionBuilder import org.galaxio.gatling.kafka.actions.KafkaRequestAvro4sActionBuilder -import scala.reflect.ClassTag - -case class KafkaAvro4sRequestBuilder[K: ClassTag, V: ClassTag](attributes: Avro4sAttributes[K, V]) - extends RequestBuilder[K, V] { +case class KafkaAvro4sRequestBuilder[K, V](attributes: Avro4sAttributes[K, V]) extends RequestBuilder[K, V] { def build: ActionBuilder = KafkaRequestAvro4sActionBuilder(attributes) diff --git a/src/main/scala/org/galaxio/gatling/kafka/request/builder/Sender.scala b/src/main/scala/org/galaxio/gatling/kafka/request/builder/Sender.scala index 190e76a..e4a4099 100644 --- a/src/main/scala/org/galaxio/gatling/kafka/request/builder/Sender.scala +++ b/src/main/scala/org/galaxio/gatling/kafka/request/builder/Sender.scala @@ -4,8 +4,6 @@ import com.sksamuel.avro4s.{FromRecord, RecordFormat, SchemaFor} import io.gatling.core.session.Expression import org.apache.kafka.common.header.Headers -import scala.reflect.ClassTag - trait Sender[K, V] { def send(requestName: Expression[String], payload: Expression[V]): RequestBuilder[Nothing, V] @@ -23,7 +21,7 @@ trait Sender[K, V] { object Sender extends LowPriorSender { - implicit def Avro4sSender[K: ClassTag, V: ClassTag](implicit + implicit def Avro4sSender[K, V](implicit schema: SchemaFor[V], format: RecordFormat[V], fromRecord: FromRecord[V],