moleculerjs / moleculer / 29911859226

94%

push

github

fix(kafka): handle nested TOPIC_ALREADY_EXISTS errors from @platformatic/kafka 2.x

In 2.x, admin.createTopics() wraps the ResponseError in an extra
MultipleErrors('Creating topics failed.') layer, so the previous
single-level check no longer recognized the concurrent topic creation
race and treated it as a fatal connection error again. Flatten the
error tree recursively and inspect the leaf errors instead, which
works with both the 1.x and 2.x error shapes.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>

5354 of 5913 branches covered (90.55%)

Branch coverage included in aggregate %.

5 of 5 new or added lines in 1 file covered. (100.0%)

7245 of 7481 relevant lines covered (96.85%)

517.47 hits per line