Там просто - есть функция latest_by_offset. Поле в него завернуть по которому ты хочешь получать последнее значение

В комментариях напишите, что пошло не так и почему откатились на более «традиционные» API. Так же те кто ответил «нет», напишите если бы хотели научиться

spring-cloud-stream-kafka 2018-19 годов было затруднительно "подлезть" и читать один хедер вместо другого, это понадобилось т к они рефакторнулись и стали использовать другой хедер для передачи типа. Т. е. нарушили совместимость. Мы не могли обновить все проекты сразу, хотелось обновлять по частям, а с вышеописанной проблемой это было сложно.
Также там в конфиге есть слово мозгорвзрывающее слово native.
Также там было суперсложно включить транзакции консумера и продюсера, нужно было настроить множество пропертей, я остановился на том что после включения транзакций скорость консумера драматически упала, насколько помню из-за того что помимо транзакций нужно было настроить и батчи. Тут я плюнул и начал его выпиливать, заменять на spring-kafka.

Если в двух словах - то минусы - переусложнённый конфиг, сложность настройки кастомного поведения(хедеры), нарушение обратной совместимости при апдейтах.

Может конечно сейчас они стали более developer friendly, но как такового сакрального смысла stream binder kafka(да и вообще) я для себя не вижу.

Просто ещё одна лишняя абстракция, добавляющая геморроя. Т. е. kafka-client <- spring-kafka <- spring-cloud-stream-binder. Too many abstractions ;)

Самому интересно, есть ли у кого позитивный опыт, какой-то может нереальный буст скорости разработки/отладки после внедрения stream binder kafka ;)

Т. е. я понимаю что делает spring-kafka - скрывает сложность kafka-client, например необходимость обработки специальных эксепшенов консумера, вроде умеет хэндлить ребалансировки, предоставляет аннотацию @KafkaListener, я могу это объяснить/обосновать,
но что делает stream kafka binder и зачем он нужен на проекте, объяснить сложно)

А можно в двух словах без отсылок к документации в 100500 страниц и маркетингового буллшита - а что это вообще такое, в чём отличие от традиционного АПИ?

Вон выше постом отличный саммари был

такая же ситуация, как и со spring data rest

слишком высокоуровневая штука, шаг вправо - инструмент начинает мешать

Привет,
использую kafka-connect-s3-sink для екпорта данных из топика в бакет, столкнулся с проблемой что один из топиков использует кастомную SubjectNameStrategy, это статичесткое имя не связаное ни с данными ни с названием топика. Подскажите плз как я могу в конфигурации указать кастомный класс для value.subject.name.strategy или как указать сразу это статическое значение для названия схемы?

Добрый день. Использую Spring Boot и аннотацию @KafkaListener. Если указываю вот такой параметр spring.kafka.listener.concurrency=3 означает ли это что чтение будет происходить в трех потоках и за счет этого возрастет скорость считывания? Спасибо

Вот прямо по нему ctrl-b и читай

Вроде нужно еще закунфигурировать контейнер правильно

Один консьюмер уже у тебя читает?

в приложение только один метод помечен данной аннотацией

наверное проще будет в тесте замерять, за пять минут например количество прочитанных сообщений при разных значениях этого параметра

из доков

   > If, say, six TopicPartitionOffset instances are provided and the concurrency is 3; each container gets two partitions. For five TopicPartitionOffset instances, two containers get two partitions, and the third gets one.

то есть партишенов должно быть не менее 3, иначе не имеет смысла выставлять concurrency  больше

Так байдинги спринг уже задепрекейтил
Типа теперь надо функции юзать

Я на прошлой неделе делал стрим. Сегодня тоже будет. Там с нуля на пальцах все объясню