apache / apache/pekko-connectors
MqttSessionSpec: MQTT server connector should re-connect given connect, subscribe, connect again, publish
Open
flaky test
- Dominant language
- Scala
- Stars
- 82
- Forks
- 50
- Avg merge
- 1d 2h
- Merged PRs (30d)
- 78
Description
```
java.lang.AssertionError: assertion failed: expected no StreamSupervisor children, but got [Actor[pekko://mqtt-spec/system/Materializers/StreamSupervisor-4/flow-295-0-unnamed#-741345539], Actor[pekko://mqtt-spec/system/Materializers/StreamSupervisor-4/flow-296-0-ignoreSink#1738476296]]
```
Contributor guide
Research direction
Start with MqttSessionSpec and reproduce the reported failure for the sequence of connect, subscribe, reconnect, and publish. Use the StreamSupervisor assertion as the symptom; done means the MQTT server connector reconnects successfully and the test no longer leaves unexpected StreamSupervisor children.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- scala
- Domain
- backend
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 35/100