Please use *kafka 0.8.** which you are using *kafka **1.0.0,* as kafka consumer
API changed a lot since *kafka 0.9.**
There will be some work to do if we want support kafka 0.9 +, need to
upgrade the kafka version and corresponding storm version in eagle. If you
would like to contribute, could you please create a JIRA ticket for it?

On Thu, Jan 4, 2018 at 10:44 PM, 绿飕飕 <[EMAIL PROTECTED]> wrote: