๐ New:
-
โ Kafka plugin: [ โ ๏ธ EXPERIMENTAL OPTION โ ๏ธ ] Kafka plugin now waits for 1 minute (automatically) for the broker to be available, FR, (thanks @Baiquette)
-
โ Internal: PHP Worker now uses an FSM to transition between states (
working
,ready
,invalid
, etc). -
โ Internal:
./rr reset
now works in parallel. All workers will be restarted simultaneously instead of a one-by-one sync approach. -
โ Internal:
./rr reset
and destroy (when stopping RR) now gracefully stop the workers (giving a chance for the finalizers to work). If the worker doesn't respond in 10 seconds, it'll be killed.
๐ฉน Fixes:
- ๐ SQS plugin: Incorrect detection of the
AWS IMDSv2
instances, BUG (thanks @paulermo) - ๐ Temporal plugin: Segmentation violation when using TLS, BUG, (thanks @seregazhuk)
- ๐ NATS plugin: Properly check the
stream not found
error from NATS, BUG, (thanks @pjtuxe)
๐งน Chore:
- ๐งโ๐ญ: Temporal plugin: Support for the
statsd
daemon for stats aggregation, FR, (thanks @cv65kr)
Configuration stays the same (no breaking changes), but additionally, you may specify adriver
:
Prometheus:
temporal:
address: "127.0.0.1:7233"
metrics:
driver: prometheus # <---- prometheus used by default (you may omit the driver in this case)
address: "127.0.0.1:9095"
prefix: "samples"
type: "summary"
activities:
num_workers: 4
Statsd:
temporal:
address: "127.0.0.1:7233"
metrics:
driver: statsd # <---- Should be specified to use a statsd driver
host_port: "127.0.0.1:8125"
prefix: "samples"
flush_interval: 1s
flush_bytes: 512
tags:
- foo: bar
activities:
num_workers: 4
Detailed description is here: link