Skip to content

4.28.9

Compare
Choose a tag to compare
@bokshitsky bokshitsky released this 05 Feb 13:13
· 961 commits to master since this release

Поддерживаем возможность в nab-kafka закоммитить оффсет per-partition для сообщения.

Т.е. если мы обрабатываем List<Message> batch и делаем ack.acknowledge(batch.get(9)) - мы закомитим не все первые 9+1 сообщений из батча, а только только те, у которых partition совпадает с batch.get(9).partition