@@ -20,27 +20,27 @@ class KafkaMessageDelivererTest : FunSpec({
2020 }
2121
2222 test("successful send → Success ") {
23- val producer = MockProducer (true, StringSerializer (), StringSerializer ())
23+ val producer = MockProducer (true, null, StringSerializer (), StringSerializer ())
2424 val deliverer = KafkaMessageDeliverer (producer)
2525 deliverer.deliver(entry()) shouldBe DeliveryResult .Success
2626 }
2727
2828 test("retriable exception (NetworkException ) → RetriableFailure ") {
29- val producer = MockProducer (true, StringSerializer (), StringSerializer ())
29+ val producer = MockProducer (true, null, StringSerializer (), StringSerializer ())
3030 producer.sendException = NetworkException ("broker down")
3131 val deliverer = KafkaMessageDeliverer (producer)
3232 deliverer.deliver(entry()).shouldBeInstanceOf<DeliveryResult .RetriableFailure >()
3333 }
3434
3535 test("permanent exception (AuthenticationException ) → PermanentFailure ") {
36- val producer = MockProducer (true, StringSerializer (), StringSerializer ())
36+ val producer = MockProducer (true, null, StringSerializer (), StringSerializer ())
3737 producer.sendException = AuthenticationException ("bad credentials")
3838 val deliverer = KafkaMessageDeliverer (producer)
3939 deliverer.deliver(entry()).shouldBeInstanceOf<DeliveryResult .PermanentFailure >()
4040 }
4141
4242 test("permanent exception (RecordTooLargeException ) → PermanentFailure ") {
43- val producer = MockProducer (true, StringSerializer (), StringSerializer ())
43+ val producer = MockProducer (true, null, StringSerializer (), StringSerializer ())
4444 producer.sendException = RecordTooLargeException ("too big")
4545 val deliverer = KafkaMessageDeliverer (producer)
4646 deliverer.deliver(entry()).shouldBeInstanceOf<DeliveryResult .PermanentFailure >()
0 commit comments