argoproj-labs/old-argo-dataflow

Issues

• Jetstream de-dupe

  #440 opened 3 years ago
  1

• Jetstream sink headers

  #438 opened 3 years ago
  2

• don't log "pending not available" at level=error

  #434 opened 3 years ago
  0

• Correctly log Kafka

  #431 opened 3 years ago
  0

• Jitter peeking

  #430 opened 3 years ago
  0

• Message replay

  #428 opened 3 years ago
  1

• memory leak (in new Kafka code?)

  #427 opened 3 years ago
  4

• do we need to use a finaliser to block step deletion?

  #426 opened 3 years ago
  3

• Events from workflow visible in Step Events

  #425 opened 3 years ago
  1

• Misleading metrics and logs in sidecar

  #424 opened 3 years ago
  3

• tech debt: better sidecar lifecycle

  #422 opened 3 years ago
  4

• Kafka pending messages seems too low

  #421 opened 3 years ago
  1

• Re-instate missing/duplicate service

  #419 opened 3 years ago
  0

• Surface log events as Prometheus metrics

  #418 opened 3 years ago
  0

• Pipeline is deleted but Steps remain

  #417 opened 3 years ago
  8

• Support `ErrPendingNotAvailable` with STAN

  #416 opened 3 years ago
  1

• controller logs a lot of errors when trying to get pending for scaled-to-zero steps

  #415 opened 3 years ago
  0

• Unable to create pipelines if the controller-manager is in different namespace

  #412 opened 3 years ago
  5

• `assignedPartition` must be idempotent

  #404 opened 3 years ago
  0

• build error `FAIL: TestDBSource failed to wait for metric named "process_latency_seconds" to be eq 0: context deadline exceeded`

  #401 opened 3 years ago
  1

• Kafka edge-case with pod restart and not offsets committed

  #399 opened 3 years ago
  1

• Dead Letter Queue (DLQ)

  #397 opened 3 years ago
  0

• Enable Redis configuration

  #396 opened 3 years ago
  0

• What is the right key/value store?

  #389 opened 3 years ago
  1

• Resource usage metrics

  #388 opened 3 years ago
  1

• Sidecar fails to fetch kafka secret and crashes pod

  #385 opened 3 years ago
  1

• Kafka idempotent producer

  #384 opened 3 years ago
  0

• tech debt: metrics do not need replica label

  #383 opened 3 years ago
  1

• Missing/duplicate detection will fail on rebalance - resulting in over-reporting missing messages or unreported duplicates

  #382 opened 3 years ago
  0

• Missing/duplicate detection for non-Kafka sources

  #376 opened 3 years ago
  0

• Request time heap map

  #375 opened 3 years ago
  0

• Durable big number KPIs

  #372 opened 3 years ago
  1

• Apache Atlas/Metadata Registry for data governance and lineage

  #371 opened 3 years ago
  1

• Message latency metric

  #368 opened 3 years ago
  0

• Update Python DSL to support multiple sources and sinks

  #364 opened 3 years ago
  0

• Unix Domain Socket sometimes already open

  #355 opened 3 years ago
  0

• ZeroMQ

  #352 opened 3 years ago
  0

• Source concurrency controls

  #351 opened 3 years ago
  0

• Support async for all sinks

  #350 opened 3 years ago
  1

• fix pending metric

  #347 opened 3 years ago
  1

• Fix `TestStanFMEA_STANServiceDisruption`

  #330 opened 3 years ago
  2

• Replace `total` with `success` metrics

  #329 opened 3 years ago
  0

• Remove Kafka auto-commit

  #327 opened 3 years ago
  0

• Disaster recovery

  #325 opened 3 years ago
  1

• Faster ways to process messages

  #324 opened 3 years ago
  3

• Why does it take 1ms to send HTTP request to main?

  #323 opened 3 years ago
  0

• Draft a prioritised list of sources+sinks to support

  #321 opened 3 years ago
  1

• JetStream

  #320 opened 3 years ago
  0

• Load balanced sources (S3, volume) will not work with > 1 replicas

  #319 opened 3 years ago
  0

• Selective data sinks

  #318 opened 3 years ago
  3