#apache-kafka #spring-cloud-stream #spring-cloud-stream-binder-kafka
Вопрос:
Я создал приложение, которое использует библиотеку Spring cloud stream на основе функций для публикации списка сообщений в одной теме Кафки. Я хочу знать, как мы можем установить ключ раздела для каждого сообщения в списке. В принципе , каждое сообщение должно иметь свою собственную логику ключа раздела. В настоящее время он не публикуется, если я пишу на заказ partitionKeyExtractor . Дайте мне знать, если кто-нибудь решал эту проблему раньше. Например:
Function<Message<String, List<Message<String>> processor(NotificationProcessor notification) {
return notification::processNotification
}