[SERVER-82102] Streams: fix stop flow when $emit connection fails Created: 11/Oct/23  Updated: 29/Nov/23  Resolved: 13/Oct/23

Status: Closed
Project: Core Server
Component/s: None
Affects Version/s: None
Fix Version/s: 7.2.0-rc0

Type: Task Priority: Major - P3
Reporter: Matthew Normyle Assignee: Matthew Normyle
Resolution: Fixed Votes: 0
Labels: init-337-m3
Remaining Estimate: Not Specified
Time Spent: Not Specified
Original Estimate: Not Specified

Assigned Teams:
Atlas Streams
Backwards Compatibility: Fully Compatible
Sprint: Sprint 33
Participants:

 Description   

{"t":

{"$date":"2023-10-11T21:12:13.633+00:00"}

,"s":"W", "c":"STREAMS", "id":75899, "ctx":"thread4700","msg":"encountered exception, exiting runLoop(): {error}","attr":{"context":

{"streamProcessorName":"eriktest","streamProcessorId":"6524304d6b9f6f609c2c6ac9","tenantId":"6509e58bfd98a76e09b7f80a"}

,"errorCode":74686,"reason":"$emit to Kafka encountered error while flushing, kafka error code: -185","error":"$emit to Kafka encountered error while flushing, kafka error code: -185"}}

{"t":

{"$date":"2023-10-11T21:12:13.633+00:00"}

,"s":"F", "c":"ASSERT", "id":23079, "ctx":"thread4700","msg":"Invariant failure","attr":{"expr":"processorInfo->streamStatus == StreamStatusEnum::Running","file":"src/mongo/db/modules/enterprise/src/streams/management/stream_manager.cpp","line":714}}

{"t":

{"$date":"2023-10-11T21:12:13.633+00:00"}

,"s":"F", "c":"ASSERT", "id":23080, "ctx":"thread4700","msg":"\n\n***aborting after invariant() failure\n\n"}

{"t":

{"$date":"2023-10-11T21:12:13.633+00:00"}

,"s":"F", "c":"CONTROL", "id":6384300, "ctx":"thread4700","msg":"Writing fatal message","attr":{"message":"\n"}}


Generated at Thu Feb 08 06:48:15 UTC 2024 using Jira 9.7.1#970001-sha1:2222b88b221c4928ef0de3161136cc90c8356a66.