Результаты поиска по запросу "kafka-producer-api"
Это прекрасно работает большую часть времени. Тем не менее, в семантике точно один раз; это не будет работать.
ичок в Kafka и работаю над прототипом для подключения проприетарного потокового сервиса к Kafka. Я хочу получить ключ от последнего сообщения, отправленного по теме, так как наш внутренний поточный потребитель должен войти в систему с ...
Вы должны использовать ключи для идентификации каждого сообщения, которое вы хотите отправить, т.е. если вы хотите прочитать все сообщения из 100-го сообщения. Считайте с 100-го смещения до message.key <100 сбросить.
лизовал простой процессор записи мертвых букв Kafka. Он отлично работает при использовании записей, созданных производителем консоли. Однако я считаю, что наши приложения Kafka Streams не гарантируют, что при создании записей по темам приемника ...
Страница 2 из 2