Bad Consumer implementation in KafkaConsumer Controller

If you activate the 'consumer.on message' event, this never ends, you will hear the messages until eternity.

Although there is a consumer, the closure of something happens with the life cycle and the consumer's problems a little more after sending the response.

Maybe I should wait for the consumer.close callback to issue the answer.

Therefore, if the controller issues his response and after this, the listener adds a new message to the response, we will get this error.

By definition, the consumer of Kafka behaves like a service or a demon and must start as a process at the beginning of the application.

Could you explain the best practice to do this? In loopback 3 we would use 'boot' directory to add a file with this responsibility.

Bắt đầu bằng cách xem xét KafkaConsumer Controller và vòng đời consumer.on message được mô tả trong issue. So sánh trách nhiệm khởi động được yêu cầu với cách tiếp cận thư mục boot của LoopBack 3. Hoàn thành có nghĩa là ghi lại cách được khuyến nghị để chạy Kafka consumer dưới dạng một dịch vụ do ứng dụng khởi động và tránh gửi phản hồi sau khi vòng đời của controller kết thúc.