This pull request addresses an issue where the HTTP Connector for Apache Kafka does not support LinkedHashMap as the record value, leading to errors when used in conjunction with Single Message Transforms (SMTs) that return LinkedHashMap. The specific error message is: "Record value must be String, Schema Struct, or HashMap, but LinkedHashMap is given."
Changes Made
Modified the relevant code to support LinkedHashMap as a valid record value.
Testing
Added test cases to ensure that the HTTP Connector functions correctly with record values of type LinkedHashMap.
Ran existing tests to ensure backward compatibility.
How to Verify
Build and test the modified connector.
Ensure that the connector now accepts and handles LinkedHashMap as the record value without generating errors.
Checklist
[ x ] Code follows the project's coding conventions.
[ ] Tests have been added to cover the changes.
[ ] Documentation has been updated to reflect the changes.
Description
This pull request addresses an issue where the HTTP Connector for Apache Kafka does not support
LinkedHashMap
as the record value, leading to errors when used in conjunction with Single Message Transforms (SMTs) that returnLinkedHashMap
. The specific error message is: "Record value must be String, Schema Struct, or HashMap, but LinkedHashMap is given."Changes Made
LinkedHashMap
as a valid record value.Testing
LinkedHashMap
.How to Verify
LinkedHashMap
as the record value without generating errors.Checklist