Skip to content

Commit

Permalink
feat: add silent option
Browse files Browse the repository at this point in the history
  • Loading branch information
jigarkhwar committed May 9, 2024
1 parent be1a6f0 commit f581f07
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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]
Expand All @@ -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],
Expand Down

0 comments on commit f581f07

Please sign in to comment.