Пример загрузки сообщений из Apache Kafka средствами REST API, который реализуется в рамках Confluent Platform.
Подробнее об установке и настройке REST API можно прочитать на сайте https://www.confluent.io/
Пример выполнен в виде внешней обработки и реализует два сценария чтения сообщений:
1 - чтение сообщений по полной подписке. (аналогичен примеру из документации Confluent)
2 - чтение сообщений с предварительным указанием смещения, используется когда необходимо перечитать сообщения с определенного момента.
Тестировалось на платформе 8.3.15.1869.