Kafka 学习笔记之 Producer/Consumer (Scala)

既然Kafka使用Scala写的,最近也在慢慢学习Scala的语法,虽然还比较生疏,可是仍是想尝试下用Scala实现Producer和Consumer,而且用HashPartitioner实现消息根据key路由到指定的partition。html Producer:java import java.util.Properties import kafka.producer.ProducerConf
相关文章
相关标签/搜索