apache / apache/rocketmq-externals

[rocketmq-connect] format converter

Open
#829 1 comment 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
4.6k
Forks
3k
Avg merge
2h 33m
Merged PRs (30d)
1

Description

1. Please describe the issue you observed:
- The converter logic is integrated with sendRecord, which is not conducive to subsequent expansion.

2. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc):
- Abstract the converter logic into the corresponding Converter object.

Contributor guide

No contributing guide indexed for this repository

Research direction

Start by locating the rocketmq-connect sendRecord implementation and trace how converter logic is currently integrated there. Review the surrounding connector flow before defining the Converter object boundary. Done means the converter logic is abstracted into the corresponding Converter object without changing the stated sendRecord behavior; no test file is named in the issue.

Written by the indexing model from the issue text.

Assessment

Tech stack
java
Domain
backend, distributed-systems
Issue type
Refactor
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Mostly clear
Newbie friendliness
30/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.