请教，多个topic数据源，但topic中没有标识字段如何集中处理

来源：11-6 -Spark Streaming消费Kafka的数据进行统计

龙葛葛

2018-01-17

老师你好，咨询个问题：数据来源是多个topic，每个topic的数据格式和内容都不一样，源端没有在每个topic数据中增加标识字段，在采用流处理过程中，怎么处理这种业务场景，或者怎么在处理时主动给每个topic分别增加不同标识呢？

写回答

1回答

Michael_PK

2018-01-17

每个业务要处理格式肯定是一样的，就必须要事先明确知道topic的

Michael_PK

龙葛葛

数据格式事先约定好的，不按要求来的数据没办法处理的，格式不是我们考虑兼容的，是事先必须知道的

2018-01-17

共2条回复

Spark Streaming实时流处理项目实战

Flume+Kafka+Spark Streaming 构建通用实时流处理平台

1404 学习 · 571 问题

相似问题

回答 1

回答 1

回答 1

回答 1

回答 1