Срочно Kafka Consumer с обработкой последнего сообщения

Срочно Что нужно реализовать: Kafka consumer на Java: Подписывается на заданный топик Kafka. При старте определяет текущее максимальное смещение в топике. Считывает последнее сообщение (смещение - 1). После этого начинает слушать и обрабатывать новые сообщения в реальном времени. Docker окружение: Использовать docker-compose для поднятия Kafka. Контейнер с Java-приложением (или локальный запуск). Тесты (JUnit): Проверить корректность работы consumer: Отправить тестовые сообщения в Kafka. Убедиться, что consumer после рестарта корректно считывает последнее отправленное сообщение и продолжает работу с новыми. Использовать интеграционные тесты, взаимодействующие с реальной Kafka из Docker. Ключевые особенности: Kafka consumer должен самостоятельно определять позицию смещения при запуске. Работать с manual commit или seek, чтобы контролировать смещения. После перезапуска не пропускать последнее сообщение, а начать с него.