issues
search
line
/
decaton
High throughput asynchronous task processing on Apache Kafka
Apache License 2.0
336
stars
51
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
shadeAllDependencies needs to be evaluated after subproject configuation
#136
kawamuray
closed
2 years ago
0
Add BatchingProcessor
#135
ryamagishi
closed
2 years ago
2
Add new method(overload) for CentralDogmaPropertySupplier#createPropertyFile/register
#134
lazmond3
closed
2 years ago
3
Upgrade gradle to 7.3
#133
kawamuray
closed
3 years ago
0
Allow to bind KafkaClientMetrics for each decaton consumer
#132
mauhiz
closed
2 years ago
13
Bump dependencies : micrometer, centraldgoma, brave..
#131
mauhiz
closed
3 years ago
1
OutOfOrderCommitControlBenchmark does not compile
#130
mauhiz
closed
2 years ago
1
Upgrade Spring Boot version to 2.5.6(#127)
#129
hase1108
closed
3 years ago
1
Provide BatchingProcessor as a built-in processor
#128
ocadaruma
closed
3 months ago
3
Upgrade Spring Boot dependency
#127
ocadaruma
closed
3 years ago
3
Retry fails if a non-ASCII string is used for the Kafka Record Key
#126
deftfitf
closed
2 years ago
2
Add tests for deferred completion
#125
ocadaruma
closed
3 years ago
0
Leave completion object in ProcessingContext field to avoid leak
#124
kawamuray
closed
3 years ago
1
Retrying task will be discarded on task deserialization with using DefaultTaskExtractor
#123
hktechn0
opened
3 years ago
3
Use toBuilder = true on config classes
#122
m50d
closed
3 years ago
1
Use a single CentralDogma watcher per file
#121
mauhiz
closed
3 years ago
2
Adopt poll(Duration) fixes #118
#120
ocadaruma
closed
2 years ago
2
Introduce a timeout for destroying processors
#119
ocadaruma
closed
1 year ago
0
Use poll(Duration)
#118
ocadaruma
closed
2 years ago
1
Support retrying on a different cluster
#117
mauhiz
opened
3 years ago
3
Properly shutdown subscription even when its closed without started
#116
kawamuray
closed
3 years ago
0
Waiting indefinitely if closing a unstarted ProcessorSubscription
#115
mokejp
closed
3 years ago
2
Fix typo
#114
ocadaruma
closed
3 years ago
2
Correct package of Completion class as it's required to construct a processor
#113
kawamuray
closed
3 years ago
0
Follow-up docs to update for latest APIs
#112
kawamuray
closed
3 years ago
0
Correct outdated import paths in docs/example project
#111
kawamuray
closed
3 years ago
0
Support MDC enable/disable flag in BM for allocation profiling
#110
kawamuray
closed
3 years ago
0
Add a graph for total allocated bytes to check object allocation trend
#109
kawamuray
closed
3 years ago
0
default linger.ms 0 doesn't make sense typically
#108
ocadaruma
closed
3 years ago
0
Upgrade CentralDogma to 0.49.1, Jackson to 2.12.3
#107
mauhiz
closed
3 years ago
1
Upgrade micrometer to 1.6.6
#106
mauhiz
closed
3 years ago
1
Make max.poll.records customizable through consumer properties
#105
kawamuray
closed
3 years ago
0
Reduce some object allocations that are identified as expensive by allocation profiling
#104
kawamuray
closed
3 years ago
0
Flaky test in CompactionProcessorTest
#103
ocadaruma
closed
2 years ago
2
Stop setting record timestamp from meta fixes #101
#102
ocadaruma
closed
3 years ago
0
ProducerRecord for retry tasks could be generated with timestamp=0
#101
ocadaruma
closed
3 years ago
0
Transition to RUNNING only after offset-reset happens
#100
ocadaruma
opened
3 years ago
0
Support deferred completion timeout as a workaround for "leak"
#99
kawamuray
closed
3 years ago
1
Support cooperative rebalancing protocol
#98
ocadaruma
closed
2 years ago
1
Cleanup CompactionProcessor metrics upon subscription close
#97
ocadaruma
opened
3 years ago
0
[Feature request] Timeout for `deferCompletion()`
#96
hktechn0
closed
3 years ago
4
MetricsTest should clear metrics in advance to make test result stable fixes #94
#95
ocadaruma
closed
3 years ago
1
Fix flaky test MetricsTest. testMetricsLifecycleManagement
#94
ocadaruma
closed
3 years ago
1
Add integration tests for BraveTracingProvider
#93
m50d
closed
3 years ago
2
Upgrade test dependencies
#92
mauhiz
closed
3 years ago
0
Fix flaky and broken offsetRegression test
#91
kawamuray
closed
3 years ago
0
Migrate to GitHub Actions
#90
ocadaruma
closed
3 years ago
1
POC: Asyncshutdownable with CF
#89
kawamuray
closed
3 years ago
0
Bugfix: Exception from consumer.pause() in rebalance due to passing already revoked partition
#88
kawamuray
closed
3 years ago
0
DocChecker: Fail validation only if base_version differs to the release version by major version
#87
kawamuray
closed
3 years ago
0
Previous
Next