issues
search
jet
/
FsKafka
Minimal F# wrappers for Confluent.Kafka+librdkafka.redist 1.x
https://github.com/jet/dotnet-templates
Apache License 2.0
88
stars
17
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Rename offetCommitIntervalMs to AutoCommitIntervalMs
#45
bartelink
closed
5 years ago
0
Target Confluent.Kafka 1.2.0
#44
bartelink
closed
5 years ago
3
offsetCommitIntervalMs should be renamed to align with AutoCommitIntervalMs
#43
bartelink
closed
5 years ago
0
Target CK/librdkafka.redist 1.1.0
#42
bartelink
closed
5 years ago
0
Monitor WIP
#41
bartelink
closed
5 years ago
2
Fix MessageMaxBytes defaulting
#40
bartelink
closed
5 years ago
0
Fix tail recursion leak
#39
bartelink
closed
5 years ago
0
Add Eventstore source
#38
bartelink
closed
5 years ago
1
Add EventStoreSource
#37
bartelink
closed
5 years ago
0
Add ParallelProducer
#36
bartelink
closed
5 years ago
0
Add StreamsProducer + StreamsConsumer
#35
bartelink
closed
5 years ago
0
Split ParallelConsumer out to Propulsion+Propulsion.Kafka
#34
bartelink
closed
5 years ago
0
Add Parallel Consumer
#33
bartelink
closed
5 years ago
0
Add way to filter InFlightMessageCounter re #31
#32
bartelink
closed
5 years ago
0
Proposal. `Consumer reached in-flight message threshold` too spamy
#31
Szer
closed
5 years ago
0
Split Batching impls out to own types; make defaults less surprising
#30
bartelink
closed
5 years ago
0
Pre 1.0 API cleanup
#29
bartelink
closed
5 years ago
0
custom attributes in consumer config now seq again
#28
Szer
closed
5 years ago
2
KafkaConsumerConfig expecting list as custom argument
#27
Szer
closed
5 years ago
0
Why consumer is key=string, value=string?
#26
vasily-kirichenko
closed
5 years ago
2
Correctly handle config with empty debug flags
#25
jgardella
closed
5 years ago
1
Target Confluent.Kafka 1.0.0-RC3; use CompressionType
#24
bartelink
closed
5 years ago
0
Target CK 1.0.0rc2+rdkafka 1.0.0
#23
bartelink
closed
5 years ago
0
v1.x doesnt pin `Confluent.Kafka` and `librdkafka.redist`
#22
enricosada
closed
5 years ago
0
Target Confluent.Kafka 1.0.0-RC1
#21
bartelink
closed
5 years ago
0
save offsets when calling streamBuffered
#20
michaelliao5
closed
5 years ago
1
offsetRange fails when topic does not exist
#19
vchekan
closed
5 years ago
1
pin deps
#18
enricosada
closed
5 years ago
0
pin confluence deps in nupkg
#17
enricosada
closed
5 years ago
0
Set up CI with Azure Pipelines
#16
enricosada
closed
5 years ago
0
added invalid offset constant
#15
michaelliao5
closed
6 years ago
0
The semantic of ProduceBatched in Legacy module should be the same as the one in Kafunk
#14
dongdongcai
closed
4 years ago
1
added kafunk legacy module ConsumerInfo
#13
michaelliao5
closed
6 years ago
2
Use reflection to get config DU case labels
#12
chrnola
closed
6 years ago
0
Make sure that offsets are not GC-ed if consumer experience no traffic for long time
#11
vchekan
closed
4 years ago
8
Fix eager offset storage bug
#10
chrnola
closed
6 years ago
1
Decide which tests are needed and implement
#9
vchekan
closed
4 years ago
6
Integrate tests into CI
#8
vchekan
closed
5 years ago
1
Consumer without joining a group
#7
vchekan
closed
4 years ago
1
QueryWatermarkOffsets queries one partition at the time
#6
vchekan
closed
4 years ago
1
Implement instrumentation
#5
vchekan
closed
4 years ago
1
Solve blocking producer buffer problem
#4
vchekan
closed
4 years ago
1
Add statisctics integration
#3
vchekan
closed
4 years ago
1
Wrapper introduce NLog dependency
#2
vchekan
closed
6 years ago
4
Change licence to Apache
#1
vchekan
closed
6 years ago
2
Previous