Connection of kafka with ecllipse ditto

[gunjan-it-engg]

hello everyone ,
I hope you guys doing well , basically I'm stuck with connection of kafka with ecllipse ditto regarding the connection i am providing my policy.json and connection.json and as well as i also attaching my connection logs screen shot.

This is my connection.json file

{
"targetActorSelection": "/system/sharding/connection",
"headers": {
"aggregate": false
},
"piggybackCommand": {
"type": "connectivity.commands:createConnection",
"connection": {
"id": "kafka-example-connection-123",
"connectionType": "kafka",
"connectionStatus": "open",
"failoverEnabled": true,
"uri": "tcp://localhost:9092",
"specificConfig": {
"bootstrapServers": "localhost:9092,other.host:9092",
"saslMechanism": "plain"
},
"sources": [
{
"addresses": ["ditto_kafka"],
"consumerCount": 1,
"qos": 1,
"authorizationContext": ["nginx:ditto"],
"enforcement": {
"input": "{{ header:device_id }}",
"filters": ["{{ entity:id }}"]
},
"headerMapping": {},
"payloadMapping": ["Ditto"],
"replyTarget": {
"enabled": true,
"address": "theReplyTopic",
"headerMapping": {},
"expectedResponseTypes": ["response", "error", "nack"]
},
"acknowledgementRequests": {
"includes": []
},
"declaredAcks": []
}
],
"targets": [
{
"address": "ditto_kafka",
"topics": [
"//things/twin/events",
"//things/live/messages"
],
"authorizationContext": ["nginx:ditto"]
}],
"mappingContext": {
"mappingEngine": "JavaScript",
"options": {
"incomingScript": "function mapToDittoProtocolMsg(headers, textPayload, bytePayload, contentType) {const jsonString = String.fromCharCode.apply(null, new Uint8Array(bytePayload));const jsonData = JSON.parse(jsonString); const thingId = jsonData.thingId.split(':'); const value = { temp_sensor: { properties: { value: jsonData.temp } },altitude: { properties: { value: jsonData.alt } } }; return Ditto.buildDittoProtocolMsg(thingId[0], thingId[1], 'things', 'twin', 'commands', 'modify', '/features', headers, value);}"
}
}
}
}
}

This is my Policy.json

{
"entries": {
"owner": {
"subjects": {
"nginx:ditto": {
"type": "nginx basic auth user"
}
},
"resources": {
"thing:/": {
"grant": [
"READ","WRITE"
],
"revoke": []
},
"policy:/": {
"grant": [
"READ","WRITE"
],
"revoke": []
},
"message:/": {
"grant": [
"READ","WRITE"
],
"revoke": []
}
}
}
}
}'

Please some one can help me !

[gunjan-it-engg]

Hey every one i found out the connection error and solved error .
Basically i modified the config files of kafka and ditto connection json file regarding to my tcp/ip connection .