Java Kafka 客户端求助帖

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

这是一个创建于 1424 天前的主题，其中的信息可能已经有所发展或是发生改变。

看到好多文章，里都有低级 API，SimpleConsumer，包括官网，但是 kafka-client.jar （版本 0.10.0.0 ）里翻了个遍也没找到，希望有大佬能够解惑。

还有一个问题是 scala 代码问题，《 Kafka 源码解析与实战》一书中 kafka.javaapi.producer.Producer 是对 kafka.producer.Producer 的包装，而后者是 scala 写的。但是同样没有找到，一般 scala 写的代码在 jar 包里字节码文件名是以$结尾，整个 client 的 jar 包里没有$结尾的字节码文件。

3 条回复 • 2021-01-04 09:14:31 +08:00

dai875939260

2020-12-31 16:54:07 +08:00

SimpleConsumer 不是在 client 包里吧，应该是在 server 里的，不过新版本好像也是被删除了 https://github.com/apache/kafka/pull/5230/files?file-filters%5B%5D=.scala#diff-7d28cdf667cc207b964e7139f75740ce7a0e847e552ad8abf05646caf1cacfe2

dai875939260

2020-12-31 16:57:17 +08:00

2.0 才开始删除的，1.1 还是有的 https://github.com/apache/kafka/blob/1.1/core/src/main/scala/kafka/consumer/SimpleConsumer.scala

lancelee01

2021-01-04 09:14:31 +08:00

@dai875939260 找到了，谢谢大佬，原来不是 kafka-client 啊