void close() {
        producer.close();
        transactionInFlight = false;
        transactionInitialized = false;
    }
@Test
    public void shouldForwardCallToClose() {
        streamsProducerWithMock.close();
        verify(mockedProducer).close();
    }