Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[Feature] SDK Source of DataProxy support new Message format. #2075

Closed
2 tasks done
luchunliang opened this issue Dec 29, 2021 · 0 comments · Fixed by #2091
Closed
2 tasks done

[Feature] SDK Source of DataProxy support new Message format. #2075

luchunliang opened this issue Dec 29, 2021 · 0 comments · Fixed by #2091
Labels
type/feature
Milestone
1.0.0

Comments

@luchunliang
Copy link
Contributor

Description

new Message format

Message format

MessageContext Type Remark
headers Map<String,String>  data parameters that user sends.
body byte[] Raw data that user sends.

headers format

Header name Remark
inlongGroupId inlongGroupId
inlongStreamId inlongStreamId
topic  Topic name of Cache Cluster(Kafka, Pulsar, Tube)
msgTime time in milliseconds when user sends message data
sourceIp node IP that user sends message date

Use case

No response

Are you willing to submit PR?

  • Yes, I am willing to submit a PR!

Code of Conduct
@luchunliang luchunliang mentioned this issue Dec 31, 2021
Merged
1 task
@dockerzhang dockerzhang added this to the 0.13.0 milestone Dec 31, 2021
@luchunliang luchunliang changed the title [Feature] TDSDK Source of DataProxy support new Message format. [Feature] SDK Source of DataProxy support new Message format. Jan 6, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
type/feature
Projects
None yet
Milestone
1.0.0
Development

Successfully merging a pull request may close this issue.

[INLONG-2075] SDK Source of DataProxy support new Message format.
2 participants
@luchunliang @dockerzhang