Как работает производитель кафки на стороне клиента?

Question

Предположим, что у меня есть кластер kafka, и я прошу некоторых клиентов (веб-приложений) отправить данные в Kafka, как я могу убедиться, что клиент, который создаст производителя для подключения к моим брокерам Kafka, сделает раздел в правильный путь, если клиент будет использовать пользовательский раздел-er?

Answer 1

AFAIK невозможно ограничить клиентов/кластер Kafka, чтобы использовать какой-либо разделитель. Но если ваш продюсер скрыт за каким-то интерфейсом фасада, вы, вероятно, можете проверить правильность создания Key вашего сообщения.

Ваш фасад может принимать, например, ProducerRecord. В этом случае у вас есть доступ к полям key и value.

https://kafka.apache.org/090/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html