Merge pull request #2454 from pikasTech/fix/kafka-sse-raw-list
Pipelines as Code CI / hwlab-nc01-v03-ci-poll- Success
Pipelines as Code CI / hwlab-nc01-v03-ci-poll- Success
fix: keep kafka debug list to raw events
This commit is contained in:
@@ -96,6 +96,7 @@ function openKafkaStream(): void {
|
|||||||
onOpen: () => { kafkaStatus.value = "open"; },
|
onOpen: () => { kafkaStatus.value = "open"; },
|
||||||
onError: () => { kafkaStatus.value = "error"; },
|
onError: () => { kafkaStatus.value = "error"; },
|
||||||
onEvent: (event, eventName) => {
|
onEvent: (event, eventName) => {
|
||||||
|
if (eventName === "hwlab.kafka.connected") return;
|
||||||
if (eventName === "hwlab.kafka.error") {
|
if (eventName === "hwlab.kafka.error") {
|
||||||
kafkaStatus.value = "error";
|
kafkaStatus.value = "error";
|
||||||
error.value = event.error?.message || "Kafka SSE 事件流错误";
|
error.value = event.error?.message || "Kafka SSE 事件流错误";
|
||||||
|
|||||||
Reference in New Issue
Block a user