goka
goka copied to clipboard
lovoo
Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.
Adds some system tests that were used to verify expected behavior for issue #369 Won't hurt to have those tests merged
if the group table already exists, it is not checked for copartitioning with the input topics - which is dangerous. This needs to be checked when starting the processor
the processor integration test is unclean and has many commented test cases. Implement them or remove them: https://github.com/lovoo/goka/blob/master/integrationtest/processor_test.go#L227
In most cases, when multiple processors in the same application (system test, in this case), are shut down at the same time by closing the runner-`ctx` - one of them...
in rare cases, topic creation can get delayed, so the topic manager should retry when verifying a topic, like this: ```go func (m *topicManager) getTopicConfigMap(topic string) (map[string]sarama.ConfigEntry, error) { var...
Implement [Streams DSL](https://docs.confluent.io/platform/current/streams/developer-guide/dsl-api.html) using Processor and storage API. Included abstractions: 1. KStream 2. KTable 3. KGroupedStream 4. KGroupedTable 5. WindowedJoins 6. PersistentJoins 7. Cogroups This provides much needed abstractions stream...
Hi, I have a problem with using a loop. I found that when using the loop, both input and loop topics must have the same number of partitions. However, if...
Hi @frairon, I would like to implement [OpenTelemetry](https://opentelemetry.io/) support with Goka.  I've seen that some discussions have already started on issue https://github.com/lovoo/goka/issues/160 some time ago. In order to do...
If two views use the same storage folder for any reason: ```error setting up partition table: error building storage: error opening leveldb: resource temporarily unavailable``` That might be confusing, because...
This commit https://github.com/lovoo/goka/commit/efeaf69a500dc79b3adeecf8312a3de77b14f272 introduced a breaking change by actively avoiding creating new topics, regardless of the broker configurations. It breaks integration tests which rely on creating topics automatically. Without it,...
