src/test/java/com/github/themeetgroup/kafka/connect/rabbitmq/sink/format/AvroFormatterTest.java
@Test
  void validateExceptionIsThrown_whenTryingToDeserializeOutputWithKafkaAvroDeserializer() {
    Struct payment = paymentValue(1, true, Currency.EURO, "testSender");
    SinkRecord sinkRecord = createSinkRecord(paymentSchema(), payment);

    byte[] output = avroRecordFormatter.format(sinkRecord);

    assertThrows(SerializationException.class, () -> kafkaAvroDeserializer.deserialize("test", output));
  }
// after putting confluent avro serialized data on your topic
after putting confluent avro serialized data on your topic
after putting confluent avro serialized data on your topic
@Test
  void validateExceptionIsThrown_whenTryingToDeserializeOutputWithKafkaAvroDeserializer() {
    Struct payment = paymentValue(1, true, Currency.EURO, "testSender");
    SinkRecord sinkRecord = createSinkRecord(paymentSchema(), payment);
    byte[] output = avroRecordFormatter.format(sinkRecord);
    assertThrows(SerializationException.class, () -> kafkaAvroDeserializer.deserialize("test", output));
  }
@ Test void validateExceptionIsThrown_whenTryingToDeserializeOutputWithKafkaAvroDeserializer ( ) { Struct payment = paymentValue ( 1 , true , Currency . EURO , "testSender" ) ; SinkRecord sinkRecord = createSinkRecord ( paymentSchema ( ) , payment ) ; byte [ ] output = avroRecordFormatter . format ( sinkRecord ) ; assertThrows ( SerializationException . class , ( ) -> kafkaAvroDeserializer . deserialize ( "test" , output ) ) ; }
after putting confluent avro serialized data on your topic
after putting confluent avro serialized data on your topic