文件名称：kafka_avro_poseidon_example:集成kafkaavroposeidon的示例项目
文件大小：5KB
文件格式：ZIP
更新时间：2024-08-08 13:47:48
Ruby
Kafka/Avro/Poseidon 示例 此 repo 包含用于创建使用 Avro 编码的生产和消费 Kafka 消息的基本代码。 消费者使用poseidon_group gem 来使用高级组管理API。 这允许您在同一组中拥有多个读者。 Zookeeper 还将跟踪您的消费者的偏移量，这样您就不会复制数据。 设置 安装 Zookeeper 和 Kafka。 有关更多信息，请参阅。 创建您的主题。 在这种情况下example_topic ： kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic example_topic 安装 gem 依赖项： bundle install 运行消费者： bundle exec ./consume
【文件预览】：
kafka_avro_poseidon_example-master
----.gitignore(124B)
----pi_consumer(782B)
----producer(1008B)
----.gitmodules(70B)
----Example.avsc(196B)
----README.md(836B)
----pv_consumer(755B)
----lib()
--------avro_consumer.rb(200B)
----avro()
----Gemfile(279B)
----consumer(680B)