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

    assertThrows(DataException.class, () -> bytesRecordFormatter.format(record));
  }
// This is also the default behaviour when not specifying a formatter
This is also the default behaviour when not specifying a formatter
This is also the default behaviour when not specifying a formatter
@Test
  void givenAStruct_whenFormattingWithBytesRecordFormatter_expectDataException() {
    Struct payment = paymentValue(1, true, Currency.EURO, "testSender");
    SinkRecord record = createSinkRecord(TestData.paymentSchema(), payment);
    assertThrows(DataException.class, () -> bytesRecordFormatter.format(record));
  }
@ Test void givenAStruct_whenFormattingWithBytesRecordFormatter_expectDataException ( ) { Struct payment = paymentValue ( 1 , true , Currency . EURO , "testSender" ) ; SinkRecord record = createSinkRecord ( TestData . paymentSchema ( ) , payment ) ; assertThrows ( DataException . class , ( ) -> bytesRecordFormatter . format ( record ) ) ; }
This is also the default behaviour when not specifying a formatter
This is also the default behaviour when not specifying a formatter