Search results

Sink.healthReporter: continuous liveness probe integration for sink failures

Status: Open.

#160 In snowplow-incubator/common-streams;

· rob-ellison-jet opened on Mar 14, 2026

KafkaSink: future.get() called in Sync[F].delay instead of Sync[F].blocking

Status: Open.

#157 In snowplow-incubator/common-streams;

· rob-ellison-jet opened on Mar 13, 2026

KafkaSink: unrecoverable producer epoch errors cause permanent consumer lag

Status: Open.

#156 In snowplow-incubator/common-streams;

· rob-ellison-jet opened on Mar 13, 2026

CooperativeStickyAssignor causes permanent partition pause loop during rebalances with fs2-kafka backpressure

Status: Open.

#155 In snowplow-incubator/common-streams;

· rob-ellison-jet opened on Jan 31, 2026

Fix sbt-ghpages setup

Status: Open.

#2 In snowplow-incubator/common-streams;

· Oguzhan Unlu (oguzhanunlu) opened on Oct 10, 2023