feat: added support for message timestamp

[antonio-pedro99]

Description:
This PR fixes #912. It introduces enhancements to the Kafka bridge to support more flexible message timestamp handling by allowing producers to specify timestamps explicitly in ProducerRecord objects. Currently, the Kafka bridge does not fully utilize the timestamp parameter in the ProducerRecord constructors, leading to using the CreateTime message timestamp type every time we produce a message. On the other hand, the ConsumerRecord has also been updated with the timestamp parameter.

Changes:

• Implemented support for interpreting the timestamp parameter in ProducerRecord objects sent to Kafka topics via the bridge.
• Allow users to read the ConsumerRecord timestamp on the request's response. E.g

[
    {
        "topic": "bridge-quickstart-topic",
        "key": "my-key",
        "value": "sales-lead-0001",
        "partition": 0,
        "offset": 0,
        "timestamp": 1719663008510(new)
    },
    {
        "topic": "bridge-quickstart-topic",
        "key": "my-key",
        "value": "sales-lead-0001",
        "partition": 0,
        "offset": 1,
        "timestamp": 1719663054984(new)
    }
]

• Updated the Kafka bridge logic to correctly handle timestamps specified by producers, aligning with configured Kafka broker timestamp policies (CreateTime or LogAppendTime).

Testing:

• Unit tests were added to verify the correct interpretation and propagation of timestamp in ProducerRecord.
• I am still adjusting to the BasicKafkaClient to change ConsumerIT with the required tests.

[ppatierno]

@antonio-pedro99 I haven't reviewed the PR yes but I see this doc build failure here you should address ...

ERROR: Uncommitted changes in documentation:
M	documentation/book/api/definitions.adoc
Run the following to add up-to-date resources:
  make docu_api \
    && git add documentation/book/ \
    && git commit -s -m 'Update generated documentation'
make: *** [Makefile:67: docu_check] Error 1

after that I will start my review. Thanks!

[antonio-pedro99]

@ppatierno sorry for being late.

Any clue about this error?

[ERROR] Failed to execute goal io.github.swagger2markup:swagger2markup-maven-plugin:1.3.7:convertSwagger2markup (generate-apidoc) on project kafka-bridge: Failed to execute goal 'convertSwagger2markup': Error creating extended parser class: Could not determine whether class 'org.pegdown.Parser$$parboiled' has already been loaded: Unable to make protected final java.lang.Class java.lang.ClassLoader.findLoadedClass(java.lang.String) accessible: module java.base does not "opens java.lang" to unnamed module @358ab600 -> [Help 1]

I have been trying to fix, but could not figure it out.

[ppatierno]

Any clue about this error?

No idea :-(

[scholzj]

Could it be a wrong Java version or something?

[ppatierno]

@antonio-pedro99 we are going to plan a release. Are you still working to fix this on your side? or should we leave it out of 0.30.0?

[antonio-pedro99]

@antonio-pedro99 we are going to plan a release. Are you still working to fix this on your side? or should we leave it out of 0.30.0?

Yeah, I am going to finish it soon.

[antonio-pedro99]

Could it be a wrong Java version or something?

I guess so

[antonio-pedro99]

@ppatierno, we had a similar issue here #858 (comment)
Maybe we should try to push the files again?

I guess there is something wrong with my setup, I will double-check the contribution documentation.

[ppatierno]

I have pushed the doc changes as done last time and left some minor comments.

[ppatierno]

@antonio-pedro99 we also need the feature to be listed in the CHANGELOG.

[scholzj]

This seems like something definitely worth having it in the CHANGELOG. LGTM otherwise. Thanks for the PR

[antonio-pedro99]

I have pushed the doc changes as done last time and left some minor comments.

Thanks a lot for this.
I will DM regarding what might be wrong with my setup.

[ppatierno]

Thanks Antonio. I reworded the CHANGELOG addition and resolved a conflict. Now ready to be merged! LGTM ;-)