ChunLiang Lu

[INLONG-5311][DataProxy] Support to configurated event handler to package event group and transform event content

1

### Prepare a Pull Request - Title : [INLONG-5311][DataProxy] Support to configurated event handler to package event group and transform event content - Fixes #5311 ### Motivation *Explain here the...

[Feature][DataProxy] Support to configurated event handler to package event group and transform event content.

1

### Description [Feature][DataProxy] Support to configurated event handler to package event group and transform event content. When DataProxy group multiple events to package a MessageQueue message, user can configure a...

### Description Optimize the sink architecture of DataProxy. * Message queue supporting multiple clusters. * Support configurable extended message queue types. * Support configurable message packaging strategy. ### Use case...

### Description 1. Change cluster tag of a inlong group id. 2. Change Partition number of a inlong group id. 3. Change sort cluster of a inlong stream. ### Use...

### Description 1. Control produce operation and consume operation of Inlong message queue cluster. 2. Build relationships between DataProxy cluster and MessageQueue cluster. 3. Remove relationships between DataProxy cluster and...

### Description 1. Create a topic in all message queue of Cluster Tag. 2. Delete a topic from all message queue of Cluster Tag. 3. Change retention policies about all...

[INLONG-5628][DataProxy] Add buffer limit of sink dispatch queue

1

### Prepare a Pull Request - Title: [INLONG-5628][DataProxy] Add buffer limit of sink dispatch queue - Fixes #5628 ### Motivation *Explain here the context, and why you're making that change....

[SDK] Support to transform from Json protocol to CSV/KV protocol by single SQL Fixes #10109 Parent issue: #10022 ### Motivation Support to transform from Json protocol to CSV/KV protocol by...

### Description [SDK] Support to transform from Json protocol to CSV/KV protocol by single SQL Parent issue: #10022 ### Use case _No response_ ### Are you willing to submit PR?...

## Motivation - Agent (File collection) needs the ability to filter and collect valid data content. - Agent (Pulsar collection) requires PB protocol parsing and data extraction capabilities. ## Solution...