streamthoughts/azkarra-streams

Issues

• How do i listen to streams state using a topology provider ?

  #193 opened 2 years ago by Dharin-shah
  0

• DefaultInteractiveQueryService has a problem when one environment has more than one container

  #159 opened 3 years ago by wangkedao
  1

• feat(commons): add deadLetterQueue support for StreamsUncaughtExceptionResponse

  #148 opened 4 years ago by fhussonnois
  0

• upgrade to kafka streams 2.8

  #147 opened 4 years ago by fhussonnois
  0

• feat(server): add new REST endpoint ot scale the number of stream threads.

  #150 opened 4 years ago by fhussonnois
  0

• feat(runtime): add new StreamThreadExceptionHandler to restart new StreamThread.

  #149 opened 4 years ago by fhussonnois
  0

• feat(all): add a new StreamExecutionEnvironment to allow managing KafkaStreams in Kubernetes

  #122 opened 4 years ago by fhussonnois
  0

• Improves HealthCheck to return to be aware of StreamThread status

  #143 opened 4 years ago by fhussonnois
  0

• Add Dead Letter Topic support ProductionException

  #141 opened 4 years ago by fhussonnois
  0

• Add new interface DeadLetterTopicNameExtractor

  #142 opened 4 years ago by fhussonnois
  0

• DeadLetterTopic should be automatically created

  #140 opened 4 years ago by fhussonnois
  0

• Healthchecks aware of State Stores

  #139 opened 4 years ago by Fryuni
  6

• LimitHandlers.dropHeadOnLimitReached returns the wrong implementation

  #136 opened 4 years ago by fhussonnois
  0

• MapConf#getValue() should add fallback when returning a Conf object.

  #135 opened 4 years ago by fhussonnois
  0

• MapConf#keyset() throws NPE when fallback is null

  #134 opened 4 years ago by fhussonnois
  0

• ComponentNameGenerator fails to generate component name for inner class

  #129 opened 4 years ago by fhussonnois
  0

• ComponentScan annotation should support arguments to specify the packages to scan

  #130 opened 4 years ago by fhussonnois
  0

• Bad configuration is provided in azkarra quickstart archetypes

  #131 opened 4 years ago by fhussonnois
  0

• Azkarra fails to start if azkarra.context config is missing

  #132 opened 4 years ago by fhussonnois
  0

• Declared ApplicationIdBuilder are not set to StreamExecutionEnvironment

  #133 opened 4 years ago by fhussonnois
  0

• Azkarra UI: tables must be sortable

  #127 opened 4 years ago by fhussonnois
  0

• Kafka Streams metric values are returned with the wrong content-type

  #125 opened 4 years ago by fhussonnois
  0

• Enhance Azkarra UI to display the raw string topology description

  #126 opened 4 years ago by fhussonnois
  0

• feat(runtime): Enhance MonitoringStreamsInterceptor to support pluggable reporters

  #124 opened 4 years ago by fhussonnois
  0

• Add new tab for displaying state store offsets and lags in Azkarra UI

  #123 opened 4 years ago by fhussonnois
  0

• Add a MonitoringStreamsTask implementation that emits metrics to MetricRegistry

  #113 opened 4 years ago by ebrard
  5

• Add a default StateRestoreListener to provide custom KafkaStreams states

  #121 opened 4 years ago by fhussonnois
  0

• Add a new KafkaStreamsContainerAware interface

  #120 opened 4 years ago by fhussonnois
  0

• Configurable topology name with auto component scan

  #118 opened 4 years ago by ebrard
  2

• IllegalStateException is thrown when providing custom KafkaStreamsFactory

  #119 opened 4 years ago by fhussonnois
  0

• feat(api): allow more fine-tuning of RocksDB instances

  #116 opened 4 years ago by fhussonnois
  0

• deps(all): bump kafka streams version to 2.7.x

  #117 opened 4 years ago by fhussonnois
  0

• Topology DAG shows duplicate nodes when there are multiple input topics

  #110 opened 4 years ago by IndeedSi
  1

• StackOverflow while using kotlin, kotlin.metadata annotation problem

  #107 opened 4 years ago by sebastian-ziegler
  1

• MonitoringStreamsInterceptor should report local state stores offset lags

  #103 opened 4 years ago by fhussonnois
  0

• feat(server): add support for Server Sent Event

  #100 opened 4 years ago by fhussonnois
  0

• feat: Azkarra should allows to only return successfull records from IQ

  #98 opened 4 years ago by fhussonnois
  0

• Generalize the @DefaultStreamsConfig to any component as a new @ConfValue annotation

  #85 opened 4 years ago by fhussonnois
  0

• Invalid JSON is returned when using Avro with logical-type (e.g timestampMillis, etc)

  #97 opened 4 years ago by fhussonnois
  0

• Azkarra does not respect @Order of StreamsLifecycleInterceptor when different @Restriction is used

  #95 opened 4 years ago by fhussonnois
  0

• NPE can be thrown if Azkarra Dashboard queries a streams instance while KafkaStreams is not initialized yet

  #96 opened 4 years ago by fhussonnois
  0

• NPE is thrown when no query param 'cleanup' is passed while stopping streams

  #94 opened 4 years ago by fhussonnois
  0

• The internal consumer used by KafkaStreamsContainer is never properly closed

  #93 opened 4 years ago by fhussonnois
  0

• Stop/Restart actions do not work when Kafka Streams metrics binder is enable

  #90 opened 4 years ago by fhussonnois
  0

• Azkarra does not support custom annotated annotations

  #91 opened 4 years ago by fhussonnois
  0

• Sometimes an IllegalArgumentException is thrown while registering metrics in PrometheusMeterRegistry

  #92 opened 4 years ago by fhussonnois
  0

• ClassNotFoundException is thrown when initializing topology loaded as an external component

  #88 opened 4 years ago by fhussonnois
  0

• setStreamsExecutionEnvironment is never invoked on KafkaStreamsFactory and TopologyProvider classes

  #89 opened 4 years ago by fhussonnois
  0

• add a content-type header to be fully compatible wth CloudEvents specification for MonitoringInterceptor

  #87 opened 4 years ago by fhussonnois
  0

• WaitForSourceTopicsInterceptor should not wait for ForeignKey subscription topics

  #84 opened 4 years ago by fhussonnois
  0