我是Kafka Java API的新手,正在研究使用特定Kafka主题的记录。
我知道我可以使用方法subscribe()从该主题开始轮询记录。assign()如果我要从选定主题的分区开始轮询记录,Kafka还提供了方法。
subscribe()
assign()
我想知道这是否是两者之间的唯一区别?
java apache-kafka kafka-consumer-api
apache-kafka ×1
java ×1
kafka-consumer-api ×1