在源码目录下运行 gradle idea。
遇到的问题:
- What went wrong:
A problem occurred evaluating root project ‘kafka-0.10.0.1-src’.
Failed to apply plugin [class ‘org.gradle.api.plugins.scala.ScalaBasePlugin’]
No such property: useAnt for class: org.gradle.api.tasks.scala.ScalaCompileOptions
需要在build.gradle开头加入:
ScalaCompileOptions.metaClass.daemonServer = true
ScalaCompileOptions.metaClass.fork = true
ScalaCompileOptions.metaClass.useAnt = false
ScalaCompileOptions.metaClass.useCompileDaemon = false
然后构建完成
启动:
验证
然后用kafka二进制包(注意是下载的二进制包,而不是源码包)中自带的脚本收发消息进行验证。
kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test001