ручное управление смещением в confluent-kafka - PullRequest
0 голосов
/ 29 апреля 2019

Как передать конкретное значение смещения, скажем, из 25-го смещения (возможно, из базы данных) в потребителя confluent-kafka? Какие шаги нужно сделать

У меня 5 разделов на стороне производителя, мне нужно потреблять все сообщения от каждого раздела вместе со значением смещения в каждом разделе в порядке, который они отправили производителю. Также, если возникает какая-либо проблема проверки, мне нужно искать от конкретное смещение раздела, я пробовал то же самое в Java и смог выполнить мое требование. Есть ли решение сделать то же самое в .net (c #)? пожалуйста, предложите

...