line/decaton

Issues

• Provide BatchingProcessor as a built-in processor

  #128 opened 4 months ago by ocadaruma
  3

• Provide a method to reference the topic partition

  #242 opened 4 months ago by be-hase
  0

• KIP-848 support

  #240 opened 4 months ago by ocadaruma
  0

• Virtual threads support

  #209 opened 7 months ago by ocadaruma
  1

• Add JDK21 to CI build target

  #213 opened 7 months ago by ocadaruma
  3

• E2EE between Decaton client <-> processor

  #236 opened 7 months ago by ocadaruma
  0

• Flaky test: PerKeyQuotaTest > testShaping_processingGuarantee

  #223 opened a year ago by ocadaruma
  0

• CentralDogmaPropertySupplier may leak watchers

  #221 opened a year ago by mauhiz
  0

• Expose e2e delivery latency metrics

  #208 opened a year ago by ocadaruma
  0

• Bum junit to version 5.x

  #198 opened a year ago by thachlp
  1

• Expose TopicPartition and offset from ProcessingContext

  #216 opened a year ago by bitterfox
  2

• More heap usage safety back pressure (user controllable? back pressure based on unprocessed messages?)

  #217 opened a year ago by bitterfox
  1

• Potential completion leak when TaskExtractor#extract throws non-RuntimeException

  #211 opened a year ago by ocadaruma
  0

• Isolate bursting key to prevent innocent keys are affected

  #167 opened 2 years ago by ocadaruma
  0

• Subscription could be killed by RebalanceInProgressException

  #201 opened 2 years ago by ocadaruma
  2

• Enqueue different taskData on retry (partial retry support)

  #199 opened 2 years ago by bitterfox
  0

• Narrow the scope of waiting pending task count upon dynamic property reload

  #172 opened 2 years ago by ocadaruma
  1

• Flaky test: CentralDogmaPropertySupplierIntegrationTest

  #187 opened 2 years ago by ocadaruma
  1

• Introduce a timeout for destroying processors

  #119 opened 2 years ago by ocadaruma
  0

• Provide round-robin mode in SubPartitioner for non-null key

  #146 opened 2 years ago by ocadaruma
  1

• Add default values of new properties to JSON files on CentralDogma when they are supported

  #195 opened 2 years ago by ta7uw
  0

• Support unfixed backoff strategy

  #190 opened 2 years ago by ta7uw
  2

• Add a document about metrics

  #189 opened 2 years ago by ta7uw
  0

• Silence WARNs during rebalancing

  #185 opened 2 years ago by mauhiz
  4

• Provide a way of specifying a partition in producing a task

  #159 opened 2 years ago by ta7uw
  2

• NPE in DecatonTaskRetryQueueingProcessor if RetryConfig.backoff is null

  #181 opened 2 years ago by ta7uw
  4

• Use poll(Duration)

  #118 opened 2 years ago by ocadaruma
  1

• Support cooperative rebalancing protocol

  #98 opened 2 years ago by ocadaruma
  1

• Provide CentralDogmaPropertySupplier that can read YAML

  #173 opened 2 years ago by maediy
  1

• Flaky test in BatchingProcessorTest.testLingerLimit

  #153 opened 2 years ago by ocadaruma
  1

• Retry fails if a non-ASCII string is used for the Kafka Record Key

  #126 opened 3 years ago by deftfitf
  2

• Make CentralDogma property supplier's file auto-creation optional

  #155 opened 3 years ago by mauhiz
  4

• asyncCommitInFlight concurrency

  #151 opened 3 years ago by mauhiz
  2

• Allow TaskMetadata include the `retry` count for DecatonClient

  #149 opened 3 years ago by trinhnx
  4

• Flaky test in CompactionProcessorTest

  #103 opened 3 years ago by ocadaruma
  2

• OutOfOrderCommitControlBenchmark does not compile

  #130 opened 3 years ago by mauhiz
  1

• Upgrade Spring Boot dependency

  #127 opened 3 years ago by ocadaruma
  3

• Retrying task will be discarded on task deserialization with using DefaultTaskExtractor

  #123 opened 3 years ago by hktechn0
  3

• Support retrying on a different cluster

  #117 opened 3 years ago by mauhiz
  3

• Waiting indefinitely if closing a unstarted ProcessorSubscription

  #115 opened 4 years ago by mokejp
  2

• [Feature request] Timeout for `deferCompletion()`

  #96 opened 4 years ago by hktechn0
  4

• ProducerRecord for retry tasks could be generated with timestamp=0

  #101 opened 4 years ago by ocadaruma
  0

• Transition to RUNNING only after offset-reset happens

  #100 opened 4 years ago by ocadaruma
  0

• Support awaiting all on-going, deferred tasks to complete before shutting down `ProcessorSubscription`

  #78 opened 4 years ago by kawamuray
  1

• Fix flaky test MetricsTest. testMetricsLifecycleManagement

  #94 opened 4 years ago by ocadaruma
  1

• Cleanup CompactionProcessor metrics upon subscription close

  #97 opened 4 years ago by ocadaruma
  0

• Add kafka headers support

  #73 opened 4 years ago by young891221
  0

• Published JAR files contain invalid `Class-Path` entry in manifest

  #66 opened 4 years ago by kawamuray
  0

• ERROR logged when using ProcessorSubscription as a Runnable

  #62 opened 4 years ago by mauhiz
  1

• Closing ProcessorSubscription twice causes NPE

  #58 opened 4 years ago by mauhiz
  2