enthusiast / worker-template

1.2.9 2026-09-11 09:04 UTC

Requires

• php: ^8.4
• ext-pcntl: *
• ext-rdkafka: *
• ext-redis: *
• enqueue/rdkafka: ^0.10.27
• open-telemetry/api: ^1.0
• open-telemetry/sdk: ^1.14
• psr/log: ^2.0 || ^3.0
• yiisoft/yii-console: ^2.4

Suggests

• ext-opentelemetry: Required to auto-hook PSR-3 logs onto active span events for Jaeger

Unknown License

• Konstantin Popov

Published on Packagist.org on 2026-09-11 09:19 UTC

README

Sharing common worker parts: instrumentation, queue logic etc.

Kafka tracing

AbstractBufferedConsumer does not manage spans. Lifecycle is owned by open-telemetry/opentelemetry-auto-ext-rdkafka:

1. KafkaConsumer::consume → start consumer span (+ parent from message traceparent)
2. app processes the message (PSR-3 span-events hook writes to current span)
3. acknowledge → commit / commitAsync → end span

Do not call Span::getCurrent()->end() in the consumer loop: it races the commit hook and leaks context scopes, so later messages inherit the same trace.

PSR-3 → span events (Jaeger-friendly)

Jaeger does not store OTLP Logs / Loki streams. This package can hook every PSR-3 logger call onto the active span as an event (Span::addEvent).

Works alongside open-telemetry/opentelemetry-auto-psr3 (inject / export).

Enable

OTEL_PHP_PSR3_SPAN_EVENTS=true
OTEL_PHP_PSR3_SPAN_EVENTS_LEVEL=info

Disable:

OTEL_PHP_DISABLED_INSTRUMENTATIONS=psr3-span-events

Requires ext-opentelemetry. Registered via Composer files autoload (_register_psr3_span_events.php) — no DI changes in apps.