@Test
public void whenKafkaProducerFailTransportCommandReturnFalse() throws InterruptedException, ExecutionException {

	when(kermossProperties.getKafkaDestination(anyString())).thenReturn("io.kermoss.topic.pizza-shop");	
	ListenableFuture mock = mock(ListenableFuture.class);
	TransporterCommand command =mock(TransporterCommand.class);
stenableFuture<SendResult<String, TransporterCommand>> send = this.kafkaTemplate.send("io.kermoss.topic.pizza-shop", command);
en(send).thenThrow(InterruptedException.class);
olean transportCommand = kafkaCommandTransporterStrategy.transportCommand(command);
sert.assertFalse(transportCommand);

}