Результаты поиска по запросу "spring-kafka"
Спасибо, Гэри. Ты спас мой день :)
работал@KafkaListener это также отмеченоConsumerAwareRebalanceListener интерфейс, используя Spring Boot 2.0.6. Я реализовалonPartitionsAssigned метод, в котором я перематываю смещение на фиксированное количество времени, скажем, 60 секунд. Все ...
Я думаю, что вы можете использовать что-то вроде этого:
ли способ сделать операцию, подобную ветви, но поместить запись в каждый выходной поток, предикат которого оценивается как true? Brach помещает запись в первое совпадение (документация: запись помещается в один и только один выходной поток при ...
Страница 2 из 2