时间戳

首页 > 解决方案 > 带有对象的新 kstream

filter - 带有对象的新 kstream

问题描述

公共 KStream 流程（KStream 输入）{ 需要 Employee 和 Employer 内部的对象。我怎样才能在返回类型中获得它。如果我必须在 kstream 中使用 ObjectMapper 将 json 转换为 java 然后通过，我该怎么办？返回输入；}

标签： filtercloudapache-kafka-streamsspring-cloud-stream

解决方案

我想创建新的 Kstream @input 给我 Kstream

我需要@Output json 是 Kstream

Employeer 有 Employee 对象和许多其他对象。我想删除所有不需要的数据..

推荐阅读