Привет, подскажите, когда добавляем ключ в сообщение, то к какой

партиции относить сообщение определяет продюсер или же кафка говорит в какую партицию класть? кто вычисляет партицию?

Либо продюсер явно указывает либо берется хеш от ключа и остаток от деления даёт номер партиции

т.е. продюсер берет хеш и определяет партицию, операция на стороне продюсера, не кафка это вычисляет?

Нет, хеш берет уже кафка. Если в сообщении не заполнен номер партиции явно - продюсер не знает о количестве партиций обычно (и уж точно его эт не волнует если ему не надо заполнять номер партиции)

Это называется consistent hashing - есть дороговоренность о хэшфункции. Хэш считается на клиенте

Знает, это информация в метадате топика прилетает

Где это вы там увидели хеш ключа на клиенте ? Хеш сообщения для контроля целостности - да, но ключа?

Посмотрите на релаизацию в ваше библиотеке. Продюсер берет хеш от ключа, в зависимости от библиотеки это поведение можно изменить

Можно ещё свой Partitioner реализовать

Я же не знаю на чем пишет автор. Goшные либы позволяют менять стратегию

https://github.com/IBM/sarama/blob/main/partitioner.go#L209

ява

Ещё раз: если НЕ указывать патрицию, яж писал - не укажи и сервер тебе все сам посчитает, не клиент И под "не укажи" я говорю о сообщении, байтиках там

Джава конечно же 😅

Зависит от реализации клиента. Клиент по дефолту может сам раскидывать по хешу https://github.com/IBM/sarama/blob/main/config.go#L527

При чем тут клиент и его реализации????? Вы понимаете чем байт отличается от клиенткой либы или нет?

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