issues
search
jonathansant
/
Orleans.Streams.Kafka
An implementation of a PersistentStreamProvider for Microsoft Orleans and Kafka using the Confluent API
GNU General Public License v3.0
79
stars
31
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
AccessviolationException occurred with race condition when pulling agent rebalancing
#11
mkjeff
opened
5 years ago
1
Prevent producing empty content
#10
mkjeff
closed
5 years ago
0
Performance issues
#9
darrrrek
opened
5 years ago
10
feat(message tracking)
#8
jonathansant
closed
5 years ago
0
Exception when used topic based on one partition
#7
darrrrek
closed
5 years ago
7
Feature/consumer-batching
#6
jonathansant
closed
5 years ago
0
IQueueAdapterReceiver.GetQueueMessagesAsync support batch semantic
#5
mkjeff
closed
5 years ago
2
`Consume` invocation wrapped with Task seems redundant
#4
mkjeff
closed
5 years ago
1
feat(producer): use `message.timeout.ms` instead of cancellation token
#3
jonathansant
closed
6 years ago
0
Producer timeout by 'message.timeout.ms'
#2
mkjeff
closed
6 years ago
3
Remove hardcoding, not working on my PC
#1
SunSatION
closed
6 years ago
1
Previous