Потребляйте всю тему Кафки, а затем немедленно отключите ее?

Question

В основном я использую Kafka для обмена традиционными сообщениями, но мне также нравится возможность потреблять небольшие темы в пакетном режиме, то есть подключаться к теме, потреблять все сообщения и немедленно отключать (не блокировать ожидание новых сообщений). Все мои темы имеют один раздел (хотя они реплицируются через кластер), и я хотел бы использовать, по возможности, высокопоставленного пользователя. Из документов не ясно, как я мог бы добиться такого в Scala (или Java). Любые советы с благодарностью получили.

Answer 1

Постановление consumer.timeout.ms будет вызывать исключение таймаута по истечении указанного времени, если до этого не было дописано ни одного сообщения, и это единственный вариант, который у вас есть с потребительским afaik высокого уровня. Используя это, вы можете установить его примерно на 1 секунду и отключить после этого, если это приемлемое решение.

Если нет, вам придется использовать простые посланники и контрольные сообщения.