Вопросы с тегом «kafka-producer-api»

Понимание тем и разделов Кафки

Я начинаю изучать Kafka для решения корпоративных задач. Во время моих чтений у меня возникли вопросы: Когда производитель создает сообщение - он укажет тему, в которую он хочет отправить сообщение, верно? Это заботится о разделах? Когда подписчик работает - он задает свой идентификатор группы,...

Требуется ли ключ для отправки сообщений в Kafka?

KeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String, byte[]>(request.getRequestTopicName(), SerializationUtils.serialize(message)); producer.send(keyedMessage); В настоящее время я отправляю сообщения без ключа как часть сообщений с ключом, будет ли оно работать...