You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by GitBox <gi...@apache.org> on 2021/12/29 06:12:53 UTC
[GitHub] [incubator-inlong] luchunliang opened a new issue #2075: [Feature] TDSDK Source of DataProxy support new Message format.
luchunliang opened a new issue #2075:
URL: https://github.com/apache/incubator-inlong/issues/2075
### Description
new Message format
<html>
<body>
<!--StartFragment--><h2 id="messageFormat" style="margin: 30px 0px 0px; padding: 0px; color: rgb(23, 43, 77); font-weight: normal; text-transform: none; font-size: 20px; line-height: 1.5; letter-spacing: -0.008em; border-bottom-color: rgb(255, 255, 255); font-family: -apple-system, BlinkMacSystemFont, "Segoe UI", Roboto, Oxygen, Ubuntu, "Fira Sans", "Droid Sans", "Helvetica Neue", sans-serif; font-style: normal; font-variant-ligatures: normal; font-variant-caps: normal; orphans: 2; text-indent: 0px; white-space: normal; widows: 2; word-spacing: 0px; -webkit-text-stroke-width: 0px; background-color: rgb(255, 255, 255); text-decoration-thickness: initial; text-decoration-style: initial; text-decoration-color: initial; text-align: left;"><span class="nh-number" style="margin: 0px;"></span>Message format</h2><div class="table-wrap" style="margin: 10px 0px 0px; padding: 0px; overflow-x: auto; color: rgb(23, 43, 77); font-family: -apple-system, Bl
inkMacSystemFont, "Segoe UI", Roboto, Oxygen, Ubuntu, "Fira Sans", "Droid Sans", "Helvetica Neue", sans-serif; font-size: 14px; font-style: normal; font-variant-ligatures: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; orphans: 2; text-align: start; text-indent: 0px; text-transform: none; white-space: normal; widows: 2; word-spacing: 0px; -webkit-text-stroke-width: 0px; background-color: rgb(255, 255, 255); text-decoration-thickness: initial; text-decoration-style: initial; text-decoration-color: initial;">
MessageContext | Type | Remark
-- | -- | --
headers | Map<String,String> | data parameters that user sends.
body | byte[] | Raw data that user sends.
</div><!--EndFragment-->
</body>
</html>
<html>
<body>
<!--StartFragment--><h2 class="auto-cursor-target" id="id-headers" style="margin: 30px 0px 0px; padding: 0px; color: rgb(23, 43, 77); font-weight: normal; text-transform: none; font-size: 20px; line-height: 1.5; letter-spacing: -0.008em; border-bottom-color: rgb(255, 255, 255); font-family: -apple-system, BlinkMacSystemFont, "Segoe UI", Roboto, Oxygen, Ubuntu, "Fira Sans", "Droid Sans", "Helvetica Neue", sans-serif; font-style: normal; font-variant-ligatures: normal; font-variant-caps: normal; orphans: 2; text-align: start; text-indent: 0px; white-space: normal; widows: 2; word-spacing: 0px; -webkit-text-stroke-width: 0px; background-color: rgb(255, 255, 255); text-decoration-thickness: initial; text-decoration-style: initial; text-decoration-color: initial;">headers format</h2><div class="table-wrap" style="margin: 10px 0px 0px; padding: 0px; overflow-x: auto; color: rgb(23, 43, 77); font-family: -apple-system, BlinkMacSystemFont, "Seg
oe UI", Roboto, Oxygen, Ubuntu, "Fira Sans", "Droid Sans", "Helvetica Neue", sans-serif; font-size: 14px; font-style: normal; font-variant-ligatures: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; orphans: 2; text-align: start; text-indent: 0px; text-transform: none; white-space: normal; widows: 2; word-spacing: 0px; -webkit-text-stroke-width: 0px; background-color: rgb(255, 255, 255); text-decoration-thickness: initial; text-decoration-style: initial; text-decoration-color: initial;">
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
</div><!--EndFragment-->
</body>
</html>
### Use case
_No response_
### Are you willing to submit PR?
- [X] Yes, I am willing to submit a PR!
### Code of Conduct
- [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@inlong.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [incubator-inlong] dockerzhang closed issue #2075: [Feature] SDK Source of DataProxy support new Message format.
Posted by GitBox <gi...@apache.org>.
dockerzhang closed issue #2075:
URL: https://github.com/apache/incubator-inlong/issues/2075
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@inlong.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org