1. 程式人生 > >kafka clients 2.10.0.0 不能import jar包

kafka clients 2.10.0.0 不能import jar包

java 寫kafka producer 的時候,引kafka-clients的jar包,新的寫法
Producer<String, String> producer = new KafkaProducer<>(props);
這個寫法從2.10.0.0開始有,但是引用2.10.0.0版本的jar包報錯,原因竟是。。。
2.10.0.0版本的jar包是用java1.7編譯的
2.10.0.1版本的jar包是用java1.8編譯的
要用2.10.0.0版本的jar包的話必須把專案的引用java改成1.7版本
但2.10.0.0版本的kafka叢集,用2.10.0.1版本的producer傳送,也能相容
Consumer能根據時間offset讀取,這個功能2.10
.1.0版本的jar包才有 Map<TopicPartition, OffsetAndTimestamp> x = consumer.offsetsForTimes(timestampsToSearch);