kafka集群的topic是可以动态添加的,添加之后就会有数据写到topic,那么我想问下:我怎么把topic里面的数据写入到hdfs里面,还有是什么时候写呢,怎么停止topic的这个消费?
写一个消费者落地kafka消息 然后批量导入到hdfs中
`单行代码`
关注海汼部落技术社区