issues
search
nodefluent
/
kafka-streams
equivalent to kafka-streams :octopus: for nodejs :sparkles::turtle::rocket::sparkles:
https://nodefluent.github.io/kafka-streams/
MIT License
830
stars
111
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Calling .consume() is not required in streaming mode.
#91
gilesbradshaw
closed
5 years ago
5
Update log4bro to the latest version 🚀
#90
greenkeeper[bot]
closed
5 years ago
0
An in-range update of debug is breaking the build 🚨
#89
greenkeeper[bot]
closed
5 years ago
1
Update quick-start.md
#88
gilesbradshaw
closed
5 years ago
0
Fix index.d.ts compiling error
#87
slcraciun
closed
5 years ago
0
KTable State Persistence
#86
dm261395
opened
5 years ago
5
How do I produce to multiple topics?
#85
sshaginyan
closed
5 years ago
3
An in-range update of bluebird is breaking the build 🚨
#84
greenkeeper[bot]
closed
5 years ago
1
Intermittent stringification issue
#83
boriskogan81
closed
5 years ago
1
An in-range update of sinek is breaking the build 🚨
#82
greenkeeper[bot]
closed
5 years ago
1
Update sinek to the latest version 🚀
#81
greenkeeper[bot]
closed
5 years ago
3
Cannot install node-rdkafka because you updated to Mojave?
#80
krystianity
closed
4 years ago
1
Corrected type of first argument of start method
#79
dm261395
closed
5 years ago
0
Update debug to the latest version 🚀
#78
greenkeeper[bot]
closed
5 years ago
0
StreamDSL to() method parameter type
#77
dm261395
closed
6 years ago
0
Creating new topic with multiple partitions
#76
mangvlad
closed
6 years ago
2
Fix KStream start method type
#75
yacut
closed
6 years ago
0
Fix StreamDSL type
#74
yacut
closed
6 years ago
0
An in-range update of sinek is breaking the build 🚨
#73
greenkeeper[bot]
closed
6 years ago
1
An in-range update of debug is breaking the build 🚨
#72
greenkeeper[bot]
closed
6 years ago
1
Update debug to the latest version 🚀
#71
greenkeeper[bot]
closed
6 years ago
2
Update typescript def to define return type for to()
#70
JRGranell
closed
6 years ago
1
Update debug to the latest version 🚀
#69
greenkeeper[bot]
closed
6 years ago
1
Partitioner?
#68
paambaati
closed
6 years ago
2
Is possible to branch a stream?
#67
Moises-Soares
closed
6 years ago
3
Produce messages as Objects
#66
SamiSammour
closed
6 years ago
7
Inner Join on KStreams
#65
memaskal
closed
6 years ago
2
Question: How do I consume from multiple topics?
#64
paambaati
closed
5 years ago
4
TypeError: createSubject is not a function @ examples/window.js
#63
raiscui
opened
6 years ago
4
Update sinek to the latest version 🚀
#62
greenkeeper[bot]
closed
6 years ago
3
KTable methods
#61
boriskogan81
opened
6 years ago
0
Can the map function do async work?
#60
yashgt
closed
5 years ago
1
Update sinek to the latest version 🚀
#59
greenkeeper[bot]
closed
6 years ago
0
Update uuid to the latest version 🚀
#58
greenkeeper[bot]
closed
6 years ago
0
Buffers are converted to strings
#57
imnotjames
closed
6 years ago
4
Mutating message value with version property when using 'buffer' as produceType and native client
#56
JRGranell
closed
6 years ago
1
Questions about KTables
#55
jonathan-roy
opened
6 years ago
5
Update sinek to the latest version 🚀
#54
greenkeeper[bot]
closed
6 years ago
1
Question
#53
MaRaSu
closed
5 years ago
1
Add concatStream method
#52
SkeLLLa
closed
6 years ago
0
Update mocha to the latest version 🚀
#51
greenkeeper[bot]
closed
6 years ago
0
[q] How to add messages to stream
#50
SkeLLLa
closed
6 years ago
5
add awaitPromises
#49
SkeLLLa
closed
6 years ago
0
Async map support and awaitPromises.
#48
SkeLLLa
closed
6 years ago
2
Error importing kafka-streams
#47
ZephD
closed
6 years ago
1
fix(start): start consumeStream instead of stream
#46
rsilvestre
closed
6 years ago
0
Update proxyquire to the latest version 🚀
#45
greenkeeper[bot]
closed
6 years ago
1
node-rdkafka
#44
tannad
closed
6 years ago
1
Is this using the Kafka Streams API ?
#43
danedavid
closed
6 years ago
1
Commit offset only after processing and producing to a different topic was successful
#42
nabeelz6
closed
6 years ago
4
Previous
Next