У меня есть Java-приложение, которое по требованию должно получать все сообщения с ключом в теме Kafka. Подходит ли использовать Kafka Stream? Однако я не знаю, как закрыть поток, не закрывая приложение. Как я могу это сделать?