issues
search
etf1
/
kafka-message-scheduler
scheduler for kafka messages
MIT License
76
stars
14
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Broker transport failure: localhost:9092/bootstrap
#56
sarthaksnh5
opened
5 months ago
5
Update go 1.22 + kafka-go v2
#55
ldechoux
closed
7 months ago
0
Update README.md
#54
fkarakas
closed
1 year ago
0
Scheduler sending already triggered messages
#53
Ahmad44452
closed
1 year ago
7
remove codecov
#52
fkarakas
closed
1 year ago
0
Use incremental rebalance protocol
#51
james-johnston-thumbtack
closed
1 year ago
3
Fix unstable tests
#50
fkarakas
closed
1 year ago
1
Update README.md add Architecture section
#49
tjerkw
closed
1 year ago
1
Update configuration variables section in readme
#48
james-johnston-thumbtack
closed
1 year ago
1
Upgrade kafka client library to v1.9.2
#47
james-johnston-thumbtack
closed
1 year ago
1
Messages are rescheduled & received at 00:00 UTC
#44
odinnou
closed
1 year ago
4
Use the RebalanceCb to listen to rebalance events
#43
james-johnston-thumbtack
closed
2 years ago
2
Wait for poller loop to exit before closing consumer
#42
james-johnston-thumbtack
closed
2 years ago
1
Upgrade golangci-lint to v1.49.0
#41
james-johnston-thumbtack
closed
2 years ago
2
Health check / liveness endpoint / IsAlive function does not support multiple concurrent callers
#40
james-johnston-thumbtack
opened
2 years ago
2
Scheduling on millisecond instead of second ?
#39
odinnou
closed
1 year ago
1
Buffer stopChan and exitChan
#38
james-johnston-thumbtack
closed
2 years ago
2
How to set partition ?
#36
yusuf5033
closed
1 year ago
5
Enhancement proposal: allow configuration of sasl.username and sasl.password from environment variables.
#35
odinnou
closed
2 years ago
2
Grace interval for outdated schedules
#34
fkarakas
closed
2 years ago
0
Fix deadlock for missed events handler
#33
fkarakas
closed
2 years ago
0
Corner case deadlock
#32
fkarakas
closed
2 years ago
0
Grace interval for immediate schedules
#31
fkarakas
closed
2 years ago
0
Expired schedules should be deleted
#30
fkarakas
closed
2 years ago
0
Fix tests on github action
#29
fkarakas
closed
2 years ago
0
Weird behavior
#28
NV4RE
closed
2 years ago
3
Add support for YAML configuration file
#27
james-johnston-thumbtack
closed
2 years ago
0
Support nil target keys
#26
james-johnston-thumbtack
closed
2 years ago
2
Support custom librdkafka configuration values
#25
james-johnston-thumbtack
closed
2 years ago
2
Scheduler converts null target keys to empty strings
#24
james-johnston-thumbtack
closed
2 years ago
2
Added OpenTelemetry collector
#21
eko
closed
1 year ago
1
Some improvements
#20
fkarakas
closed
3 years ago
0
Design Doc of how the schedules are being handled
#19
shaikidris
closed
3 years ago
4
Add mock-server
#18
fkarakas
closed
3 years ago
0
Add /info and /schedules endpoints
#17
fkarakas
closed
3 years ago
0
Make simple-schedule public
#16
fkarakas
closed
3 years ago
0
Introduce an API server & liveness endpoints
#13
fkarakas
closed
3 years ago
0
Change metrics http port configuration
#12
ldechoux
closed
3 years ago
0
De/activate pprof endpoint with linux signal
#11
fkarakas
closed
3 years ago
0
Added retry feature to clientlib and a backoff strategy
#10
eko
closed
3 years ago
0
fix #8 : deadlock on golang time <-t.C
#9
fkarakas
closed
3 years ago
0
scheduler deadlock
#8
fkarakas
closed
3 years ago
0
Improve clientlib
#7
fkarakas
closed
3 years ago
0
Clean logs
#6
fkarakas
closed
3 years ago
0
update confluent-kafka-go to v1.5.2
#5
ldechoux
closed
3 years ago
0
fix OriginalTopic comment
#4
chemidy
closed
3 years ago
1
Fixed clientlib code examples
#3
eko
closed
3 years ago
3
Fixed clientlib go.mod module name
#2
eko
closed
3 years ago
1