文件名称：kafkaesque:允许访问Kafka的R包
文件大小：11.74MB
文件格式：ZIP
更新时间：2024-03-26 23:52:44
R
通过'rJava'的Kafka R绑定 状态 到目前为止，该软件包功能齐全，应该可以使用。 这是对客户工作的结构化提取和重写。 尽管包装的核心部件已在生产中使用，并且经过了“实战测试”，但此处提供的包装尚未使用-到目前为止。 软件包尚未发布到CRAN。 尝试了。 CRAN制定了有关程序包大小（<= 5MB）的政策，发布到CRAN意味着仅发布R代码而没有任何Java依赖项。 从CRAN安装软件包后，可以添加安装功能来下载必要的JAR文件。 到目前为止，我还没有决定是否要采用这种方式。 R代码行： 594， Java代码行： 570，测试代码行： 173 版本 0.1.1（2021-03-05 20:51:44） 描述 通过'rJava'为Kafka的Consumer，Admin和Producer API提供R绑定：“ Apache Kafka是一个开源分布式事件流平台，已有数千家公
【文件预览】：
kafkaesque-master
----docker()
--------start.sh(1KB)
--------Dockerfile(1KB)
--------test_500_000.txt(3.23MB)
--------.bashrc(246B)
--------kafka_messages.txt(47B)
--------server.properties(7KB)
----.github()
--------.gitignore(7B)
--------workflows()
----NAMESPACE(371B)
----DESCRIPTION(1KB)
----.vscode()
--------launch.json(779B)
--------settings.json(106B)
----Dockerfile(1KB)
----inst()
--------java()
----R()
--------aaa_import_magrittr.R(112B)
--------kafka_admin_class.R(5KB)
--------kafka_producer.R(218B)
--------kafka_set_log_level.R(535B)
--------kafka_consumer_class.R(10KB)
--------kafka_producer_class.R(4KB)
--------zzz.r(107B)
--------kafka_admin.R(206B)
--------gnrndmsg.R(3KB)
--------kafka_consumer.R(218B)
--------kafka_get_log_level.R(223B)
--------kafka_install_kafka.R(1KB)
--------kafka_records.R(5KB)
--------kafkaesque-package.R(344B)
----.Rbuildignore(424B)
----LICENSE.md(34KB)
----.lintr(409B)
----README.md(17KB)
----kafkaesque.Rproj(465B)
----man()
--------kafka_get_log_level.Rd(317B)
--------kafka_producer_class.Rd(5KB)
--------kafka_records_class.Rd(4KB)
--------kafka_producer.Rd(349B)
--------kafka_set_log_level.Rd(424B)
--------kafka_admin_class.Rd(6KB)
--------gnrndmsg.Rd(384B)
--------kafkaesque.Rd(440B)
--------kafka_admin.Rd(331B)
--------pipe.Rd(217B)
--------kafka_consumer_class.Rd(11KB)
--------kafka_records.Rd(320B)
--------kafka_consumer.Rd(349B)
----.codecov.yml(15B)
----tests()
--------testthat()
--------testthat.R(64B)
----.gitignore(1KB)
----README.Rmd(9KB)
----java()
--------kafkaesque()