文件名称：kafka-on-actors:用于 Scala 的基于 Akka Actors 的 Kafka 消费者生产者
文件大小：20KB
文件格式：ZIP
更新时间：2024-06-29 23:44:41
Scala
Scala 的基于 Akka Actors 的 Kafka 消费者/生产者 支持卡夫卡 0.8.2.1 概念 Kafka 的消费者本质上是阻塞的，其想法是让消费者在自己的线程池中运行，并将消息委托给在自己的线程池中运行的 worker-actor，同时实现以防止邮箱溢出且不阻塞。 val (zookepers, brokers, groupId) = ( " zk1:2181,zk2:2181,zk3:2181 " , " kf1:9092,kf2:9092,kf3:9092 " , " test-group " ) val topicConfigs = Seq ( TopicConfig ( " topic1 " , Props ( new TopicActor ( " topic1 " )), numWorkers = 10 ), TopicConfig ( " t
【文件预览】：
kafka-on-actors-master
----.gitignore(228B)
----project()
--------plugins.sbt(59B)
--------build.properties(132B)
----src()
--------main()
--------test()
----LICENSE(11KB)
----README.md(1KB)
----build.sbt(824B)