Files in petermeissner/kafkaesque

Kafka R Bindings via 'rJava'

.Rbuildignore

.codecov.yml

.github/.gitignore

.github/workflows/tests.yml

.gitignore

.lintr

.vscode/launch.json

.vscode/settings.json

DESCRIPTION

Dockerfile

LICENSE

LICENSE.md

NAMESPACE

NEWS.md R/aaa_import_magrittr.R R/gnrndmsg.R R/kafka_admin.R R/kafka_admin_class.R R/kafka_consumer.R R/kafka_consumer_class.R R/kafka_get_log_level.R R/kafka_install_kafka.R R/kafka_producer.R R/kafka_producer_class.R R/kafka_records.R R/kafka_set_log_level.R R/kafkaesque-package.R R/zzz.r README.Rmd README.md demo_user2021/demo_consumer.R demo_user2021/demo_consumer_commandline.R demo_user2021/demo_consumer_loop.R demo_user2021/demo_consumer_loop_batch.R demo_user2021/demo_producer.R demo_user2021/demo_producer_commandline.R

demo_user2021/peter_meissner_user_2021_kafkaesque_HTML_PDF.zip

docker/.bashrc

docker/Dockerfile

docker/kafka_messages.txt

docker/server.properties

docker/start.sh

docker/test_500_000.txt

inst/java/gson-2.8.9.jar

inst/java/kafka-clients-2.8.1.jar

inst/java/kafkaesque-2.8.1.jar

inst/java/log4j-api-2.17.1.jar

inst/java/log4j-core-2.17.1.jar

inst/java/log4j-slf4j-impl-2.17.1.jar

inst/java/lz4-java-1.7.1.jar

inst/java/slf4j-api-1.7.30.jar

inst/java/snappy-java-1.1.8.1.jar

inst/java/zstd-jni-1.4.9-1.jar

java/kafkaesque/.vscode/launch.json

java/kafkaesque/.vscode/settings.json

java/kafkaesque/.vscode/tasks.json

java/kafkaesque/pom.xml

java/kafkaesque/src/main/java/kafkaesque/App.java

java/kafkaesque/src/main/java/kafkaesque/Json.java

java/kafkaesque/src/main/java/kafkaesque/Kafka_Consumer.java

java/kafkaesque/src/main/java/kafkaesque/Kafka_admin.java

java/kafkaesque/src/main/java/kafkaesque/Kafka_admin_props.java

java/kafkaesque/src/main/java/kafkaesque/Kafka_consumer_props.java

java/kafkaesque/src/main/java/kafkaesque/Kafka_helper.java

java/kafkaesque/src/main/java/kafkaesque/Kafka_logger.java

java/kafkaesque/src/main/java/kafkaesque/Kafka_offset_arrays.java

java/kafkaesque/src/main/java/kafkaesque/Kafka_producer.java

java/kafkaesque/src/main/java/kafkaesque/Kafka_producer_props.java

java/kafkaesque/src/main/java/kafkaesque/Kafka_props.java

java/kafkaesque/src/main/java/kafkaesque/Kafka_record_arrays.java

java/kafkaesque/src/main/resources/log4j2.xml

java/kafkaesque/src/test/java/kafkaesque/AppTest.java

kafkaesque.Rproj

man/gnrndmsg.Rd man/kafka_admin.Rd man/kafka_admin_class.Rd man/kafka_consumer.Rd man/kafka_consumer_class.Rd man/kafka_get_log_level.Rd man/kafka_producer.Rd man/kafka_producer_class.Rd man/kafka_records.Rd man/kafka_records_class.Rd man/kafka_set_log_level.Rd man/kafkaesque.Rd man/pipe.Rd tests/testthat.R tests/testthat/test_gnrndmsg.R tests/testthat/test_java_works.R tests/testthat/test_kafka.R tests/testthat/test_kafka_admin.R tests/testthat/test_kafka_consumer.R tests/testthat/test_kafka_consumer_loop.R tests/testthat/test_kafka_producer.R tests/testthat/test_tests_work.R

petermeissner/kafkaesque documentation built on Sept. 28, 2022, 4:30 a.m.