在同一個應用程序中使用不同版本的kafka - 0.8.2.2和0.10.1 API

Question

我有一個Java應用程序，它使用來自Kafka的數據並將消耗的數據推送到數據庫。它目前基於Kafka 0.8.2 API。是否可以（動態/靜態地）使用版本0.8.2或0.10.2來選擇/創建消費者以提供功能？

目前該應用程序是使用以下卡夫卡類：kafka.consumer.ConsumerConfig，kafka.consumer.ConsumerIterator，kafka.consumer.KafkaStream，kafka.javaapi.consumer.ConsumerConnector，kafka.message.MessageAndMetadata？

感謝

Answer 1

當您在應用程序（不僅是卡夫卡）運行同一個庫的兩個版本，那麼你會得到NoSuchMethodError例外。