Issues
- 0
test: broken `TestProducerMetrics`
#483 opened by kyungeunni - 2
Tests: flaky failures
#464 opened by inge4pres - 0
- 2
- 1
Encoder/Decoder bytes metrics
#205 opened by endorama - 2
kafka(consumer): Consider processing multiple events
#243 opened by marclop - 0
- 22
- 0
- 2
- 0
Trace Kafka reads and writes
#306 opened by marclop - 3
Update Kafka producer metric names
#251 opened by marclop - 0
telemetry: don't trace on a per-event basis
#300 opened by marclop - 1
Race in test TestProducerGracefulShutdown
#225 opened by carsonip - 2
Data race in TestProducerConcurrentClose
#196 opened by axw - 2
test: TestConsumerDelivery is flaky
#161 opened by kruskall - 6
- 2
- 2
Introduce `namespace` concept
#224 opened by marclop - 0
- 0
- 0
kafka: support loading Azure credentials from disk
#235 opened by axw - 0
kafka: support loading AWS MSK credentials from ~/.aws
#234 opened by axw - 0
pubsublite: measure subscription lag
#202 opened by axw - 6
Investigate slow systemtest
#149 opened by kruskall - 0
Make producer/consumer telemetry generic
#218 opened by dmathieu - 0
- 6
kafka(consumer): Document/clarify the consumer behavior, or implement re-processing if processor fails
#118 opened by marclop - 1
Create a `consumer` binary
#85 opened by marclop - 0
- 3
system tests: cleanup
#169 opened by reakaleek - 2
systemtest: suppress kafka logs for successful tests
#188 opened by axw - 3
kafka: data race accessing/updating partition consumers
#189 opened by axw - 16
system tests: Run as part of PR checks
#95 opened by marclop - 0
test: explore enabling race detector for tests
#114 opened by kruskall - 2
test: enable failing group consuming system test
#117 opened by kruskall - 3
consistent behaviour on shutdown
#147 opened by kruskall - 0
- 0
reduce duplicate code in systemtest
#151 opened by kruskall - 4
kafka: Extend unit tests
#123 opened by marclop - 0
pubsublite: Add comprehensive system tests
#122 opened by marclop - 0
kafka: Extend system tests
#124 opened by marclop - 2
system tests: group consuming
#94 opened by marclop - 1
- 1
test: add consumer unit test for multiple topics
#107 opened by kruskall - 1
health checks should accept a context
#96 opened by kruskall - 0
system tests: write basic producer tests
#93 opened by marclop - 0
ci: add job to validate go.mod state
#106 opened by kruskall - 0
System tests: Create initial framework
#92 opened by marclop - 0