test_kafka:适用于集成测试的 Ruby Kafka 运行器

测试卡夫卡 适用于集成测试的最小 Kafka 0.8 运行器。 改编自优秀的的集成测试。 安装 将 TestKafka 添加到应用程序的 Gemfile 中： gem 'test_kafka' , '~> 0.1.1' 和捆绑： $ bundle 用法 require 'test_kafka' cluster = TestKafka . start ( '/usr/local/kafka' ) # or specify custom a temp directory and kafka/zk ports: # cluster = TestKafka.start('/usr/local/kafka', '/tmp', 9092, 2181) # ... interact with Kafka/ZK ... cluster . with_interruption do # b