看到好多文章,里都有低级 API,SimpleConsumer,包括官网,但是 kafka-client.jar (版本 0.10.0.0 )里翻了个遍也没找到,希望有大佬能够解惑。
还有一个问题是 scala 代码问题,《 Kafka 源码解析与实战》一书中 kafka.javaapi.producer.Producer 是对 kafka.producer.Producer 的包装,而后者是 scala 写的。但是同样没有找到,一般 scala 写的代码在 jar 包里字节码文件名是以$结尾,整个 client 的 jar 包里没有$结尾的字节码文件。