Issues
- 1
confirm kafka message manually
#144 opened by nieyanzhai - 2
Question for supported Sink
#142 opened by cassiaman7 - 1
Two questions about redis stream
#93 opened by jeven2016 - 2
How to use `group` or `keyBy` on the stream?
#120 opened by stairclimber - 6
Kafka-go Extension (Windows Compatibility)
#26 opened by gavinservai - 2
Cannot import the `kafka` module
#126 opened by itaranto - 1
- 2
Nats de-duplication matches Kafka
#70 opened by gedw99 - 2
- 1
Example code for Kafka - failed with panic
#63 opened by tzichtig - 1
- 2
Support grouping data by time and length
#48 opened by dalianzhu - 1
Kafka messages should be processed in parallel
#52 opened by dellekappa - 2
- 2
Are there plans to support generics?
#58 opened by dalianzhu - 2
- 0
will redis stream be supported in future?
#78 opened by jeven2016 - 5
DSL / Config for describing the Flow
#62 opened by gedw99 - 0
- 2
Support for loop/feedback in the graph
#47 opened by dumblob - 0
flink for go ?
#28 opened by smallverse - 1
Example of flow feature 'split'
#42 opened by eugeis - 2
Graceful shutdown
#40 opened by nikolay-turpitko - 6
kafka shutdown, repeat consumption
#32 opened by Doslin - 1
the problem with fanout function
#22 opened by hzw456 - 0
Add Network connector
#19 opened by reugn - 0
Add Apache Pulsar connector
#18 opened by reugn - 0
Implement Filter flow
#15 opened by reugn - 0
Implement redis connector
#7 opened by reugn - 0
Implement sliding window flow
#3 opened by reugn - 0
Implement tumbling window flow
#4 opened by reugn - 0
Implement Throttler flow
#1 opened by reugn