MessageFormatter formatter() {
        return formatter;
    }
@SuppressWarnings("deprecation")
    @Test
    public void testNewAndDeprecateTransactionLogMessageFormatter() throws Exception {
        String[] deprecatedTransactionLogMessageFormatter = 
                generateArgsForFormatter("kafka.coordinator.transaction.TransactionLog$TransactionLogMessageFormatter");
        assertInstanceOf(kafka.coordinator.transaction.TransactionLog.TransactionLogMessageFormatter.class, 
                new ConsoleConsumerOptions(deprecatedTransactionLogMessageFormatter).formatter());

        String[] transactionLogMessageFormatter = 
                generateArgsForFormatter("org.apache.kafka.tools.consumer.TransactionLogMessageFormatter");
        assertInstanceOf(TransactionLogMessageFormatter.class, 
                new ConsoleConsumerOptions(transactionLogMessageFormatter).formatter());
    }