GitHub - areller/turing: Kafka Processing Library for Golang

Name		Name	Last commit message	Last commit date
Latest commit History 16 Commits
.vscode		.vscode
confluent		confluent
examples		examples
hack		hack
proto		proto
redis		redis
tester		tester
.gitignore		.gitignore
README.md		README.md
Tekcerfile.js		Tekcerfile.js
codec.go		codec.go
config.go		config.go
consumer.go		consumer.go
consumer_mock.go		consumer_mock.go
doc.go		doc.go
errors.go		errors.go
helpers.go		helpers.go
kv_store.go		kv_store.go
kv_store_mem.go		kv_store_mem.go
logger.go		logger.go
partition.go		partition.go
partition_manager.go		partition_manager.go
partition_manager_test.go		partition_manager_test.go
partition_test.go		partition_test.go
producer.go		producer.go
producer_mock.go		producer_mock.go
protobuf_codec.go		protobuf_codec.go
runnable.go		runnable.go
runnable_test.go		runnable_test.go
server.go		server.go
simple_processor.go		simple_processor.go
simple_processor_test.go		simple_processor_test.go
string_codec.go		string_codec.go
string_codec_test.go		string_codec_test.go
ticker.go		ticker.go
ticker_test.go		ticker_test.go
topic_producer.go		topic_producer.go
topic_producer_test.go		topic_producer_test.go