diff --git a/src/connector/src/source/kinesis/source/reader.rs b/src/connector/src/source/kinesis/source/reader.rs
index c321a4c63fd7..4ed00b88a58b 100644
--- a/src/connector/src/source/kinesis/source/reader.rs
+++ b/src/connector/src/source/kinesis/source/reader.rs
@@ -250,7 +250,8 @@ impl KinesisSplitReader {
                 .set_starting_sequence_number(starting_seq_num)
                 .set_timestamp(starting_timestamp)
                 .send()
-                .await?;
+                .await
+                .map_err(|e| anyhow!(DisplayErrorContext(e)))?;
 
             if let Some(iter) = resp.shard_iterator() {
                 Ok(iter.to_owned())