Project

test_kafka

0.0
No commit activity in last 3 years
No release in over 3 years
test_kafkabts/test_kafkaHomepageDocumentationSource CodeBug TrackerWiki
Minimal Kafka runner suitable for integration testing
2005
2006
2007
2008
2009
2010
2011
2012
2013
2014
2015
2016
2017
2018
2019
2020
2021
2022
2023
2024
 Popularity
Downloads
5,885
Stars
2
Forks
1
Watchers
3
 Releases
Current version
0.1.1
Total releases
2
First release
2013-11-11
Latest release
2015-06-01
 Issues
Open Issues
1
Closed Issues
1
Total Issues
2
Issue Closure Rate
50%
 Development
Primary Language
Ruby
Licenses
MIT
Average date of last 50 commits
2014-01-01
Reverse Dependencies
0

 Dependencies

Development

bundler
~> 1.3
poseidon
~> 0.0.4
rake
~> 10.1.0
rspec
~> 2.12.0
zk
~> 1.9.2

Runtime

daemon_controller
~> 1.0.0
 Project Readme

TestKafka

Minimal Kafka 0.8 runner suitable for integration testing.

Adapted from the excellent poseidon's integration tests.

Installation

Add TestKafka to your application's Gemfile:

gem 'test_kafka', '~> 0.1.1'

and bundle:

$ bundle

Usage

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
  # broker temporarily stopped in this block
end

# broker is back up

cluster.stop

Requirements

  • Kafka 0.8 or higher