feat: use inner message

[shanicky]

Signed-off-by: Peng Chen [email protected]

What's changed and what's your intention?

PLEASE DO NOT LEAVE THIS EMPTY !!!

Please explain IN DETAIL what the changes are in this PR and why they are needed:

• Summarize your change (mandatory)
• How does this PR work? Need a brief introduction for the changed logic (optional)
• Describe clearly one logical change and avoid lazy messages (optional)
• Describe any limitations of the current code (optional)

Checklist

• I have written necessary docs and comments
• I have added necessary unit tests and integration tests

Refer to a related PR or issue link (optional)

[pangzhenzhou]

LGTM

[codecov]

Codecov Report

Merging #932 (3546434) into main (158b03e) will decrease coverage by 0.00%.
The diff coverage is 0.00%.

@@             Coverage Diff              @@
##               main     #932      +/-   ##
============================================
- Coverage     71.49%   71.49%   -0.01%     
  Complexity     2766     2766              
============================================
  Files           970      970              
  Lines         56587    56591       +4     
  Branches       1787     1787              
============================================
  Hits          40457    40457              
- Misses        15240    15244       +4     
  Partials        890      890              

Flag	Coverage Δ
java	61.23% <ø> (ø)
rust	75.45% <0.00%> (-0.01%)	⬇️

Flags with carried forward coverage won't be shown. Click here to find out more.

Impacted Files	Coverage Δ
rust/connector/src/kafka/source/message.rs	0.00% <0.00%> (ø)
rust/connector/src/kafka/source/reader.rs	0.00% <0.00%> (ø)
rust/connector/src/kinesis/source/message.rs	0.00% <0.00%> (ø)
rust/connector/src/kinesis/source/reader.rs	0.00% <0.00%> (ø)
rust/connector/src/pulsar/source/message.rs	0.00% <0.00%> (ø)
rust/connector/src/pulsar/source/reader.rs	0.00% <0.00%> (ø)

📣 Codecov can now indicate which changes are the most critical in Pull Requests. Learn more

[tabVersion]

LGTM