A
Size: a a a
2021 February 03
VG
Oleg Gavrilov
Так а почему spring kafka есть, а asp.net core kafka нет?
https://www.matthowlett.com/2019-06-02-stream-processing-pt1-what-and-why.html - вот что Мэтт пишет. Он же в комманде .NET клиента
OG
Хорошо пишет, складно
OG
Самое толерантное "вам надо вы и пишите, это супер симпл" что я видел
OG
Тем временем consumer loop делают кто как может, я лично пару раз уже напоролся на косяки с потоками, походу надо будет на channels делать
NR
доброго.
spring boot + kafka consumer api.
пытаюсь отмотать очередь на начало. говорят, что перед перемоткой нужно получить партиции, которым можно выставить смещение, т.е. сделать:
почему с 0-ым таймаутом не работает?
spring boot + kafka consumer api.
пытаюсь отмотать очередь на начало. говорят, что перед перемоткой нужно получить партиции, которым можно выставить смещение, т.е. сделать:
consumer.poll(Duration.ZERO)не перематывается - не возвращает сообщения (про повторном poll). но если выполнить с бОльшим таймаутом:
consumer.poll(Duration.ofMillis(1000))то перематывается, сообщения получаю.
почему с 0-ым таймаутом не работает?
РХ
доброго.
spring boot + kafka consumer api.
пытаюсь отмотать очередь на начало. говорят, что перед перемоткой нужно получить партиции, которым можно выставить смещение, т.е. сделать:
почему с 0-ым таймаутом не работает?
spring boot + kafka consumer api.
пытаюсь отмотать очередь на начало. говорят, что перед перемоткой нужно получить партиции, которым можно выставить смещение, т.е. сделать:
consumer.poll(Duration.ZERO)не перематывается - не возвращает сообщения (про повторном poll). но если выполнить с бОльшим таймаутом:
consumer.poll(Duration.ofMillis(1000))то перематывается, сообщения получаю.
почему с 0-ым таймаутом не работает?
из доков KafkaConsumer
> This method returns immediately if there are records available. Otherwise, it will await the passed timeout. If the timeout expires, an empty record set will be returned.
> This method returns immediately if there are records available. Otherwise, it will await the passed timeout. If the timeout expires, an empty record set will be returned.
NR
из доков KafkaConsumer
> This method returns immediately if there are records available. Otherwise, it will await the passed timeout. If the timeout expires, an empty record set will be returned.
> This method returns immediately if there are records available. Otherwise, it will await the passed timeout. If the timeout expires, an empty record set will be returned.
> Note, that seekXXX() can only be used after a consumer joined a group -- thus, it's required to do a "dummy-poll" before using seekXXX()
NR
т.е. вот так не работает:
consumer.poll(Duration.ZERO) // dummy-pollа вот так работает
consumer.seekToBeginning(consumer.assignment())
consumer.poll(Duration.ofMillis(1000)) // тут нет сообщений
consumer.poll(Duration.ofMillis(1000)) // dummy-poll
consumer.seekToBeginning(consumer.assignment())
consumer.poll(Duration.ofMillis(1000)) // тут есть сообщения
РХ
т.е. вот так не работает:
consumer.poll(Duration.ZERO) // dummy-pollа вот так работает
consumer.seekToBeginning(consumer.assignment())
consumer.poll(Duration.ofMillis(1000)) // тут нет сообщений
consumer.poll(Duration.ofMillis(1000)) // dummy-poll
consumer.seekToBeginning(consumer.assignment())
consumer.poll(Duration.ofMillis(1000)) // тут есть сообщения
деталей не знаю, но предположу что запрос на брокер даже не уходит, потому что выставляете таймаут ожидания в ноль
VG
Это RBAC он в Enterprise версии
SN
Доброго вечера,
подскажите, кто-нибудь пробовал использовать schema registry без кафки?
нужно предварительно провалидировать объект по схеме avro, которая в schema registry
стек java, spring boot. ничего из "коробки" не нашлось
подскажите, кто-нибудь пробовал использовать schema registry без кафки?
нужно предварительно провалидировать объект по схеме avro, которая в schema registry
стек java, spring boot. ничего из "коробки" не нашлось
SB
Доброго вечера,
подскажите, кто-нибудь пробовал использовать schema registry без кафки?
нужно предварительно провалидировать объект по схеме avro, которая в schema registry
стек java, spring boot. ничего из "коробки" не нашлось
подскажите, кто-нибудь пробовал использовать schema registry без кафки?
нужно предварительно провалидировать объект по схеме avro, которая в schema registry
стек java, spring boot. ничего из "коробки" не нашлось
Это не сложно, там элементарный гет запрос
VG
Доброго вечера,
подскажите, кто-нибудь пробовал использовать schema registry без кафки?
нужно предварительно провалидировать объект по схеме avro, которая в schema registry
стек java, spring boot. ничего из "коробки" не нашлось
подскажите, кто-нибудь пробовал использовать schema registry без кафки?
нужно предварительно провалидировать объект по схеме avro, которая в schema registry
стек java, spring boot. ничего из "коробки" не нашлось
SR использует кафку как хранилище BTW