issues
search
nats-io
/
nats-spark-connector
Apache License 2.0
9
stars
6
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Load balance map fix
#34
stoddabr
closed
3 weeks ago
0
Memory leak in load_balanced
#33
stoddabr
opened
4 weeks ago
1
Parsing headers causes a map error
#32
stoddabr
opened
1 month ago
2
getConsumerContext causing "stream not found" error for some streams
#31
stoddabr
opened
1 month ago
1
Refactor how spark options are passed to Options/JetStreamOptions builders
#30
stoddabr
opened
1 month ago
3
Rename streaming source class to leverage default
#29
stoddabr
closed
1 month ago
2
Adds compressed payload support though an optional config 'nats.pull.subscription.payload.compression', supports zlib or none
#28
stoddabr
closed
1 month ago
4
Add decompression to V2
#27
stoddabr
closed
1 month ago
2
Adds new connector 'V2'
#26
jnmoyne
closed
2 months ago
0
Fix sink
#25
jnmoyne
closed
3 months ago
0
Add config parameters ack none and connection outgoing max messages
#24
jnmoyne
closed
3 months ago
0
Update nats.java
#23
jnmoyne
closed
3 months ago
0
Updates the nats connector be more scala centric and stable
#22
Marcus-Rosti
closed
3 months ago
0
Adjustable datetime column format
#21
jnmoyne
closed
7 months ago
0
Improve payload handling
#20
jnmoyne
closed
7 months ago
0
Reformats sbt file
#19
Marcus-Rosti
closed
7 months ago
1
Fix PR
#18
jnmoyne
closed
8 months ago
0
Support SSL Context Factory
#17
scottf
closed
8 months ago
0
Deprecates partitioned as not being actively worked on anymore
#16
jnmoyne
closed
8 months ago
0
Add headers and JetStream metadata columns
#15
jnmoyne
closed
9 months ago
0
[IMPROVE] Improve error handling
#14
jnmoyne
closed
9 months ago
0
[ADDED] Compressed payload support
#13
jnmoyne
closed
10 months ago
0
Removed the indexed consumer code
#12
amitamit281
closed
11 months ago
1
After application restart, total number of processed messages at the end is not same as input messages
#11
vivekgh24
closed
6 months ago
3
Add the option to have batch pulls
#10
AlejandroUPC
opened
1 year ago
1
1.1.4 Small improvements
#9
jnmoyne
closed
1 year ago
0
1.1.1 [IMPROVED] Can use both NATS creds and client cert at the same time
#8
jnmoyne
closed
1 year ago
0
[ADDED] V1.1 Support for TLS authentication
#7
jnmoyne
closed
1 year ago
0
Add issue forms
#6
bruth
closed
1 year ago
2
Update README.md
#5
gcolliso
closed
1 year ago
0
Update README.md
#4
gcolliso
closed
1 year ago
1
Update README.md
#3
gcolliso
closed
1 year ago
1
Addition of load balanced version of spark connector
#2
sergiosennder
closed
1 year ago
0
Initial commit of nats-spark connector in 'partitioned' mode
#1
sergiosennder
closed
1 year ago
0