pro.jvm

01 May 2025 11:27

Нет, я ничего не пытаюсь переизобрести, это академический интерес.

pro.jvm

01 May 2025 10:48

Бнопня. Существует ли блокирующая очередь со следующими характеристиками, и если да, то как она имплементируется?

- Thread-safe, конечно же
- В оптимистичном случае (наличие элементов) выполняется non-blocking path. Отдельно это делается легко, хоть treiber stack.
- В случае отсутствия элементов очередь блокирует тред до следующей публикации.
- Блокировка снимается по сигналу доступности элемента, а не по таймауту. i.e. делать какой-нибудь wait(1) не вариант.

Наивный подход тут не сработает, потому что либо надо так или иначе уходить в lock-unfree на каждую операцию, либо появляется race condition между проверкой наличия элемента и самой блокировкой - если публикация произойдет именно в этот момент, то сигнал будет потерян.

pro.jvm

30 Apr 2025 13:48

Первый костыль, который в голову приходит, это Verticle поднять внутри Quarkus-приложения. Вывести на отдельный порт. Но это уровень абстракции несколько ниже чем дает Quarkus - писать будет не настолько удобно как могли привыкнуть.

Разработчикам я вопрос задал - ждем.

pro.jvm

30 Apr 2025 13:07

Насколько я знаю, как раз в этом и смысл новой имплементации, чтобы интегрировать под один порт.
В документации ясно сказано, см
https://quarkus.io/guides/grpc-reference#selecting-a-grpc-server

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

pro.jvm

30 Apr 2025 12:48

Я хвалил сегодня кваркус в соседнем чате. И сразу вляпался в вопрос, может кто сталкивался: если хочется развести grpc и REST на разных портах, то есть ли возможность это сделать при использовании new Vert.x gRPC сервера: quarkus.grpc.server.use-separate-server=false

Внезапно L7 LB разводит http2 и http1 и нельзя замапить на один порт

When you disable quarkus.grpc.server.use-separate-server, you are then using the new Vert.x gRPC server implementation which uses the existing HTTP server. Which means that the server port is now 8080 (or the port configured with quarkus.http.port). Also, most of the other configuration properties are no longer applied, since it’s the HTTP server that should already be properly configured.

pro.jvm

30 Apr 2025 09:51

в спринге, действительно, можно параметры в yaml писать по-разному, как это называется в статье relaxed. Какого-то правила однозначного не выработалось у нас, в данном проекте в kebab-case написано

pro.jvm

30 Apr 2025 09:47

Точно? А вот это https://github.com/spring-projects/spring-boot/wiki/relaxed-binding-2.0

pro.jvm

30 Apr 2025 09:43

в Spring Boot проекте вот так:

spring:
    kafka:
      consumer:
          max-poll-records: 50

pro.jvm

30 Apr 2025 09:34

Но я все же думаю лучше глянуть в доке, чем чат gpt мучать

pro.jvm

30 Apr 2025 09:32

И писать вложено нельзя

pro.jvm

30 Apr 2025 09:29

вроде эта штука вообще превратиться в consumerProperties.maxpollrecords=20
релаксед байндинг чтоль это называлось

pro.jvm

30 Apr 2025 09:25

consumerProperties:
max.poll.records: 20

pro.jvm

30 Apr 2025 08:43

Что?! Да ведь это серьёзный ответ на сообщение 5 летней давности...

pro.jvm

30 Apr 2025 01:00

Ответ на сообщение, которому 5 лет, для рекламы своего продукта?

pro.jvm

29 Apr 2025 06:11

Я может не понял где смеяться, но там же есть @SerialName?

pro.jvm

01 May 2025 11:08

ты случаем не пытаешься переизобрести reactive streams?

pro.jvm

30 Apr 2025 14:00

@flood

pro.jvm

30 Apr 2025 13:18

Да, было бы супер, может костыль есть. Не хочу тащить два разных сервера и старый подход.

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

pro.jvm

30 Apr 2025 13:01

@lasteris

pro.jvm

30 Apr 2025 10:03

да. глянул org.springframework.boot.autoconfigure.kafka.KafkaProperties.Consumer
max-poll-records прокатит.

pro.jvm

30 Apr 2025 09:48

на одном из проектов специально глянул

pro.jvm

30 Apr 2025 09:45

Я так понял это еще от версии кафки зависит? Спринговой

pro.jvm

30 Apr 2025 09:35

сейчас бы чатгпт спрашивать и его ответы сюда кидать, а не вот это вот всё

pro.jvm

30 Apr 2025 09:34

"Потому что Kafka не распознает такую вложенность. Она ожидает плоскую структуру с ключами в строковом формате."

pro.jvm

30 Apr 2025 09:32

Чат говорит, что Кафка ожидает плоскиее ключи, а не объекты

pro.jvm

30 Apr 2025 09:26

Капец я не угадал - спасибо

pro.jvm

30 Apr 2025 09:24

Тупой вопрос
Если конфиг .yaml
То для кафки правильно так
consumerProperties:
max:
poll:
records: 20
Или так
consumerProperties:
max-poll-records: 20
Чет не гуглится

pro.jvm

30 Apr 2025 01:02

а вдруг с того момента, я писал его 5 лет чтоб сейчас ответить))

pro.jvm

30 Apr 2025 00:56

cf sucks, есть альтернативы, например https://overpoweredjs.com, одинаковый отпечаток даже в инкогнито

pro.jvm

28 Apr 2025 23:46

Не, это еще не самое худшее. Это же не рутуб. Еще есть, куда падать