We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dcfbfb5 commit 2ea66b8Copy full SHA for 2ea66b8
src/connector/src/source/kinesis/source/reader.rs
@@ -193,7 +193,16 @@ impl KinesisSplitReader {
193
self.new_shard_iter().await?;
194
continue;
195
}
196
- Err(e) => return Err(anyhow!(DisplayErrorContext(e))),
+ Err(e) => {
197
+ let error_msg = format!(
198
+ "Kinesis got a unhandled error: {:?}, stream {:?}, shard {:?}",
199
+ DisplayErrorContext(e),
200
+ self.stream_name,
201
+ self.shard_id,
202
+ );
203
+ tracing::error!("{}", error_msg);
204
+ return Err(anyhow!("{}", error_msg));
205
+ }
206
207
208
0 commit comments