Разбор Кафки сообщений

Question

Мой вопрос будет коротким и чистым.Я хотел бы проанализировать данные JSON, которые будут поступать из темы Кафки.Таким образом, Мое приложение будет работать как потребитель Kafka.Меня интересует только некоторая часть данных JSON.Нужно ли обрабатывать эти данные с помощью библиотеки, например, Apache-Flink?После этого я отправлю данные куда-то еще.

Answer 1

Вначале вы говорите «фильтровать данные», поэтому, похоже, вам нужно ввести RecordFilterStrategy в AbstractKafkaListenerContainerFactory. См. Документацию по этому вопросу: https://docs.spring.io/spring-kafka/docs/current/reference/html/#filtering-messages

Тогда вы говорите, "заинтересованы в какой-то части в JSON". Ну, это не похоже на фильтрацию записей , но больше похоже на проецирование данных . По этой причине вы можете использовать ProjectingMessageConverter для нарезки данных на несколько ProjectionFactory. См. Их JavaDocs для получения дополнительной информации.