@Override
    public Record<?> getCurrentRecord() {
        return new PulsarFunctionRecord(record, config.getFunctionDetails());
    }
@Test
    public void testGetCurrentRecord() {
        Record<?> currentRecord = context.getCurrentRecord();
        assertTrue(currentRecord instanceof PulsarFunctionRecord<?>);
    }