分享

kafkabolt的FieldNameBasedTupleToKafkaMapper

hadoop001 发表于 2017-5-1 08:59:38 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 1 7624
我这里有一个bolt,只输出一个字段,他的输出Field是  outputMessage,这个bolt的输出tuple发送到kafkabolt,然后写入kafka,这里面tuple到kafka的message用到kafkabolt这个类。FieldNameBasedTupleToKafkaMapper("key","message"),我看到他的源码有两个构造参数,分别对应上游bolt的tuple的key和message。可是我上游bolt只有一个输出字段啊,这里应该怎么办呢?求帮忙,谢谢

已有(1)人评论

跳转到指定楼层
2017 发表于 2017-5-1 10:26:49
字段的名字是key,这个应该知道的。字段的值是message,应该是传递的
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条