@@ -128,102 +128,110 @@ Next, create a C# .NET console application in Visual Studio:
128
128
```json
129
129
130
130
{
131
- "msgCreatedBy": "nayenama",
132
- "message": {
133
- "entities": {
134
- "referredEntities": {
135
- "-1102395743156037": {
136
- "typeName": "azure_sql_column",
137
- "attributes": {
138
- "owner": null,
139
- "userTypeId": 61,
140
- "qualifiedName": "mssql://nayenamakafka.eventhub.sql.net/salespool/dbo/SalesOrderTable#OrderID",
141
- "precision": 23,
142
- "length": 8,
143
- "description": "Sales Order ID",
144
- "scale": 3,
145
- "name": "OrderID",
146
- "data_type": "int",
147
- "table": {
148
- "guid": "-1102395743156036",
149
- "typeName": "azure_sql_table",
150
- "entityStatus": "ACTIVE",
151
- "displayText": "SalesOrderTable",
152
- "uniqueAttributes": {
153
- "qualifiedName": "mssql://nayenamakafka.eventhub.sql.net/salespool/dbo/SalesOrderTable"
154
- }
131
+ "msgCreatedBy":"nayenama",
132
+ "message":{
133
+ "type":"ENTITY_CREATE_V2",
134
+ "user":"admin",
135
+ "entities":{
136
+ "entities":[
137
+ {
138
+ "typeName":"azure_sql_table",
139
+ "attributes":{
140
+ "owner":"admin",
141
+ "temporary":false,
142
+ "qualifiedName":"mssql://nayenamakafka.eventhub.sql.net/salespool/dbo/SalesOrderTable",
143
+ "name":"SalesOrderTable",
144
+ "description":"Sales Order Table added via Kafka"
145
+ },
146
+ "relationshipAttributes":{
147
+ "columns":[
148
+ {
149
+ "guid":"-1102395743156037",
150
+ "typeName":"azure_sql_column",
151
+ "uniqueAttributes":{
152
+ "qualifiedName":"mssql://nayenamakafka.eventhub.sql.net/salespool/dbo/SalesOrderTable#OrderID"
153
+ }
154
+ },
155
+ {
156
+ "guid":"-1102395743156038",
157
+ "typeName":"azure_sql_column",
158
+ "uniqueAttributes":{
159
+ "qualifiedName":"mssql://nayenamakafka.eventhub.sql.net/salespool/dbo/SalesOrderTable#OrderDate"
160
+ }
161
+ }
162
+ ]
163
+ },
164
+ "guid":"-1102395743156036",
165
+ "version":0
166
+ }
167
+ ],
168
+ "referredEntities":{
169
+ "-1102395743156037":{
170
+ "typeName":"azure_sql_column",
171
+ "attributes":{
172
+ "owner":null,
173
+ "userTypeId":61,
174
+ "qualifiedName":"mssql://nayenamakafka.eventhub.sql.net/salespool/dbo/SalesOrderTable#OrderID",
175
+ "precision":23,
176
+ "length":8,
177
+ "description":"Sales Order ID",
178
+ "scale":3,
179
+ "name":"OrderID",
180
+ "data_type":"int"
181
+ },
182
+ "relationshipAttributes":{
183
+ "table":{
184
+ "guid":"-1102395743156036",
185
+ "typeName":"azure_sql_table",
186
+ "entityStatus":"ACTIVE",
187
+ "displayText":"SalesOrderTable",
188
+ "uniqueAttributes":{
189
+ "qualifiedName":"mssql://nayenamakafka.eventhub.sql.net/salespool/dbo/SalesOrderTable"
190
+ }
191
+ }
192
+ },
193
+ "guid":"-1102395743156037",
194
+ "version":2
195
+ },
196
+ "-1102395743156038":{
197
+ "typeName":"azure_sql_column",
198
+ "attributes":{
199
+ "owner":null,
200
+ "userTypeId":61,
201
+ "qualifiedName":"mssql://nayenamakafka.eventhub.sql.net/salespool/dbo/SalesOrderTable#OrderDate",
202
+ "description":"Sales Order Date",
203
+ "scale":3,
204
+ "name":"OrderDate",
205
+ "data_type":"datetime"
206
+ },
207
+ "relationshipAttributes":{
208
+ "table":{
209
+ "guid":"-1102395743156036",
210
+ "typeName":"azure_sql_table",
211
+ "entityStatus":"ACTIVE",
212
+ "displayText":"SalesOrderTable",
213
+ "uniqueAttributes":{
214
+ "qualifiedName":"mssql://nayenamakafka.eventhub.sql.net/salespool/dbo/SalesOrderTable"
215
+ }
216
+ }
217
+ },
218
+ "guid":"-1102395743156038",
219
+ "status":"ACTIVE",
220
+ "createdBy":"ServiceAdmin",
221
+ "version":0
222
+ }
155
223
}
156
- },
157
- "guid": "-1102395743156037",
158
- "version": 2
159
- },
160
- "-1102395743156038": {
161
- "typeName": "azure_sql_column",
162
- "attributes": {
163
- "owner": null,
164
- "userTypeId": 61,
165
- "qualifiedName": "mssql://nayenamakafka.eventhub.sql.net/salespool/dbo/SalesOrderTable#OrderDate",
166
- "description": "Sales Order Date",
167
- "scale": 3,
168
- "name": "OrderDate",
169
- "data_type": "datetime",
170
- "table": {
171
- "guid": "-1102395743156036",
172
- "typeName": "azure_sql_table",
173
- "entityStatus": "ACTIVE",
174
- "displayText": "SalesOrderTable",
175
- "uniqueAttributes": {
176
- "qualifiedName": "mssql://nayenamakafka.eventhub.sql.net/salespool/dbo/SalesOrderTable"
177
- }
178
- }
179
- },
180
- "guid": "-1102395743156038",
181
- "status": "ACTIVE",
182
- "createdBy": "ServiceAdmin",
183
- "version": 0
184
224
}
185
- },
186
- "entity":
187
- {
188
- "typeName": "azure_sql_table",
189
- "attributes": {
190
- "owner": "admin",
191
- "temporary": false,
192
- "qualifiedName": "mssql://nayenamakafka.eventhub.sql.net/salespool/dbo/SalesOrderTable",
193
- "name" : "SalesOrderTable",
194
- "description": "Sales Order Table added via Kafka",
195
- "columns": [
196
- {
197
- "guid": "-1102395743156037",
198
- "typeName": "azure_sql_column",
199
- "uniqueAttributes": {
200
- "qualifiedName": "mssql://nayenamakafka.eventhub.sql.net/salespool/dbo/SalesOrderTable#OrderID"
201
- }
202
- },
203
- {
204
- "guid": "-1102395743156038",
205
- "typeName": "azure_sql_column",
206
- "uniqueAttributes": {
207
- "qualifiedName": "mssql://nayenamakafka.eventhub.sql.net/salespool/dbo/SalesOrderTable#OrderDate"
208
- }
209
- }
210
- ]
211
- },
212
- "guid": "-1102395743156036",
213
- "version": 0
214
- }
215
- },
216
- "type": "ENTITY_CREATE_V2",
217
- "user": "admin"
218
- },
219
- "version": {
220
- "version": "1.0.0"
221
- },
222
- "msgCompressionKind": "NONE",
223
- "msgSplitIdx": 1,
224
- "msgSplitCount": 1
225
+ },
226
+ "version":{
227
+ "version":"1.0.0"
228
+ },
229
+ "msgCompressionKind":"NONE",
230
+ "msgSplitIdx":1,
231
+ "msgSplitCount":1
225
232
}
226
233
234
+
227
235
```
228
236
229
237
## Consume messages from Purview
0 commit comments