Skip to content
/ goka Public
forked from lovoo/goka

Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.

License

BSD-3-Clause license
1 star 173 forks Branches Tags Activity
Star
Notifications You must be signed in to change notification settings

Saeed903/goka

BranchesTags
 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

523 Commits
.github
.github
 
 
codec
codec
 
 
examples
examples
 
 
integrationtest
integrationtest
 
 
multierr
multierr
 
 
storage
storage
 
 
systemtest
systemtest
 
 
tester
tester
 
 
web
web
 
 
.gitignore
.gitignore
 
 
CHANGELOG.md
CHANGELOG.md
 
 
LICENSE
LICENSE
 
 
MIGRATION.md
MIGRATION.md
 
 
Makefile
Makefile
 
 
README.md
README.md
 
 
assignment.go
assignment.go
 
 
broker.go
broker.go
 
 
builders.go
builders.go
 
 
codec.go
codec.go
 
 
config.go
config.go
 
 
config_test.go
config_test.go
 
 
context.go
context.go
 
 
context_test.go
context_test.go
 
 
copartition_strategy.go
copartition_strategy.go
 
 
copartition_strategy_test.go
copartition_strategy_test.go
 
 
doc.go
doc.go
 
 
emitter.go
emitter.go
 
 
emitter_test.go
emitter_test.go
 
 
errors.go
errors.go
 
 
go.mod
go.mod
 
 
go.sum
go.sum
 
 
graph.go
graph.go
 
 
graph_test.go
graph_test.go
 
 
header_test.go
header_test.go
 
 
headers.go
headers.go
 
 
iterator.go
iterator.go
 
 
iterator_test.go
iterator_test.go
 
 
logger.go
logger.go
 
 
mockautoconsumers.go
mockautoconsumers.go
 
 
mockbuilder.go
mockbuilder.go
 
 
mockcontroller.go
mockcontroller.go
 
 
mocks.go
mocks.go
 
 
mockssarama.go
mockssarama.go
 
 
mockstorage.go
mockstorage.go
 
 
once.go
once.go
 
 
once_test.go
once_test.go
 
 
options.go
options.go
 
 
options_test.go
options_test.go
 
 
partition_processor.go
partition_processor.go
 
 
partition_table.go
partition_table.go
 
 
partition_table_test.go
partition_table_test.go
 
 
processor.go
processor.go
 
 
processor_test.go
processor_test.go
 
 
producer.go
producer.go
 
 
producer_test.go
producer_test.go
 
 
promise.go
promise.go
 
 
promise_test.go
promise_test.go
 
 
proxy.go
proxy.go
 
 
proxy_test.go
proxy_test.go
 
 
signal.go
signal.go
 
 
signal_test.go
signal_test.go
 
 
simple_backoff.go
simple_backoff.go
 
 
simple_backoff_test.go
simple_backoff_test.go
 
 
stats.go
stats.go
 
 
topic_manager.go
topic_manager.go
 
 
topic_manager_test.go
topic_manager_test.go
 
 
view.go
view.go
 
 
view_test.go