@Test
@FixFor("DBZ-1430")
public void shouldPassHeartbeatMessages() {

    Schema valueSchema = SchemaBuilder.struct()
            .name("io.debezium.connector.common.Heartbeat")
            .field(AbstractSourceInfo.TIMESTAMP_KEY, Schema.INT64_SCHEMA)
            .build();
    Struct value = new Struct(valueSchema).put(AbstractSourceInfo.TIMESTAMP_KEY, 1565787098802L);
    Schema keySchema = SchemaBuilder.struct()
            .name("io.debezium.connector.common.ServerNameKey")
            .field("serverName", Schema.STRING_SCHEMA)
            .build();
    Struct key = new Struct(keySchema).put("serverName", "op.with.heartbeat");
    final SourceRecord eventRecord = new SourceRecord(
            new HashMap<>(),
            new HashMap<>(),
            "op.with.heartbeat",
            keySchema,
            key,
            valueSchema,
            value);
    // when
    SourceRecord transformed = transformation.apply(eventRecord);
    assertThat(transformed).isSameAs(eventRecord);
}