ngjaying
ngjaying
Hi @HugoSousa the helm chart did not maintain for a long time. You can try to modify and build locally based on the chart file `helm install ekuiper deploy/chart/ekuiper`. If...
Does it mean we'll need to make some changes to the ./deploy/chart? I'll try to make some changes and rerun.
RedisSub is to read from Redis stream
@retoool Could you please help?
Please try the latest v2.x beta version. The rule won't stop when connection fails at the beginning. It will reconnect automatically.
The rule will keep running but the data will be dropped if sink caching is not enabled. Check https://ekuiper.org/docs/en/latest/guide/sinks/overview.html#caching
It should be supported. Did you find any issue?
@onlylin you're right, the Kafka sink does not support dynamic topic yet. Refer to https://github.com/lf-edge/ekuiper/blob/master/internal/io/mqtt/sink.go about how to set dynamic topic
Closed by #3831
For this FVT error, in .github/workflows/run_test_case.yaml, try to add MQTT service. Add this before line 23. ``` services: emqx: image: emqx/emqx:4.3.10 ports: - 1883:1883 - 18083:18083 ```