== Physical Plan ==
Execute SaveIntoDataSourceCommand (1)
+- SaveIntoDataSourceCommand (2)
+- Project (6)
+- Project (5)
+- Project (4)
+- LocalRelation (3)
(1) Execute SaveIntoDataSourceCommand
Output: []
(2) SaveIntoDataSourceCommand
Arguments: org.apache.spark.sql.kafka010.KafkaSourceProvider@481a560c, [kafka.ssl.keystore.type=PEM, kafka.ssl.truststore.certificates=-----BEGIN CERTIFICATE-----
MIIGDzCCA/egAwIBAgIUJRTgKUjNpiA/y4yfE+RwMDi71fEwDQYJKoZIhvcNAQEL
BQAwgY4xCzAJBgNVBAYTAkRFMRswGQYDVQQIDBJCYWRlbi1XdWVydHRlbWJlcmcx
ETAPBgNVBAcMCFdhbGxkb3JmMQ8wDQYDVQQKDAZTQVAgU0UxHzAdBgNVBAsMFlNB
UCBDUCBEYXRhIE1hbmFnZW1lbnQxHTAbBgNVBAMMFFNBUCBTRSBLYWZrYSBSb290
IENBMB4XDTI0MDIwODEzMTY1NloXDTI3MDUyMzEzMTY1NlowgY4xCzAJBgNVBAYT
AkRFMRswGQYDVQQIDBJCYWRlbi1XdWVydHRlbWJlcmcxETAPBgNVBAcMCFdhbGxk
b3JmMQ8wDQYDVQQKDAZTQVAgU0UxHzAdBgNVBAsMFlNBUCBDUCBEYXRhIE1hbmFn
ZW1lbnQxHTAbBgNVBAMMFFNBUCBTRSBLYWZrYSBSb290IENBMIICIjANBgkqhkiG
9w0BAQEFAAOCAg8AMIICCgKCAgEAoLH563sTndme/L5sUH/LggOO5sgRk6D6eYJi
YgPZFX/o8a0dctgMTBK574kPAZeniwvOIUUeGhKM/Ho4ou/B3XDD/8WtoOIZt4lj
QGyeSlZVFtCI3Ip/ENj5gIuFhO6N209mpw9wIgjhCdCTU+g6uaAe440aqCMhVO5I
54bHp4hSHwkLdNZnsRjSopufEKxWbJm52w7lKHwBwNc0cAckiagne6FbBTliF4K/
bgmfRRwP9fzjcmgno+GGgKastNkJVh6Ku/2NCpOKSzQiGNAQAvqbZbpQIkCt4/PK
Nj4c5pjbRSajwt8JWNHRJ9muJz2Db7ZceQF7H/vcAwlu/IK/ARHygfA72IY164du
QN1qJyi1DkPs1qm5cuA8WbfL8KSqIFeiKoInHL524zeK2Yt5b89sS00ydtLSYbri
1kd31McUCHcj66DDX5xBbNg7bgRx09DNpfwKlUnwC7tphz1DLJprJ9OvhjEZi0w7
TNrL21yETIKGG0qSgebIhLPWTG650i2hEM2dF1t9RfVB4qdhaxS194rkwQPZ2lQ8
74hWnuqiZ3L4XhMp1AO86UoFEWyeCbIFsZ4YHnCNfBOO4t8LSPpUiV9bTIwqG549
upI9tWMZMVV59GiuA4M9oit7vYa1eNxpUhKWpqAVCA66tETln04umAKsywt06pUn
0udI1OsCAwEAAaNjMGEwHQYDVR0OBBYEFGRMbSqCPP1qeNX3hEYn4YAClp/cMB8G
A1UdIwQYMBaAFGRMbSqCPP1qeNX3hEYn4YAClp/cMA8GA1UdEwEB/wQFMAMBAf8w
DgYDVR0PAQH/BAQDAgGGMA0GCSqGSIb3DQEBCwUAA4ICAQBfn+8f1fmSSpUCe1ks
OB6A4KubhEDsQ3XUZ7myBU+nMhLAoPflra3+jcUcq3fqR/ybK2rfEK+Vngf8NBou
YP+1p/QaWJPgzzEEGEEAQx5U57HbnPw7DoDJaUkIoqT3gmLkWTw9R1t+AK+neHnL
tfUygvBkLevcXG4klLjFW1B5/8T9hIg7wK5httXgr+P6sic458tB2oImQWkUIaCh
3NkVAWtLjz81LiaM0fgiI0/kiufq0FZWqhazTTz8qY/qocdHbhEUmA4wSjL1XB/K
UrUC0yB7uN5vpCpunWC3EhkzCLgemIm+DPyREg7euGvg6URuP1VIsoaLstxX6caB
DROwWXY3P7kVZtzHXK6g6lrJAYxtP9tf6dyZhFHf0/XL7kwHVabU+s9MgvDvIaxA
V588fCGJbB9A+QrWxF2QKDzUrygHHd8y+EE6Oj6rbnNEgkxxuP+qDiza/46MVPVh
KzF6gepXlv9fgm2+v3Mu/HRKVAoHPOKefC3KeNv8wZkPn76dC4CEZHU+zB+YgvQ3
n1sgzPdcFfV+0wLOhLJkzbTWJ9znspJMZWYn6CR1VWbiWgDMfM9R18onHGxcAxn4
qfoGuXQDP5cnSOsIUVG75z6dfixzzn41hAaW0bQXP8nbMve5LcZhvmDQtxqNiFZu
/jpDfYNIFFeK2b96ea3PMzQYLg==
-----END CERTIFICATE-----, kafka.bootstrap.servers=132.220.198.208:50094,132.220.198.208:50194,132.220.198.208:50294, kafka.ssl.keystore.key=-----BEGIN PRIVATE KEY-----
MIIEvAIBADANBgkqhkiG9w0BAQEFAASCBKYwggSiAgEAAoIBAQDZh6wkSCIlrWOg
Y/75q3QvxBmWBWMsUuQ/NTF5bbZBvmYZj2BhtYr6YPhWxcSGbj4wDugL7NBWlpjk
ESSuCKM67jlrDOzgu1dl2UCHaN4mXgo6CULIPemYX/6fEayZh7sCW3K0ETpuHtD1
1GVxsHh8xhqTcJGgb3sefec+KZ2CQJMyJOiq0q6kNhOEEUxWY5T7q/W6PFzWXuSd
oCKg+J0dIotz3ay61TPryYN8tzxbbgXXeutJD81UqCyGILoBzAzILHJsUE0P/h/K
YzMIY0j3E5jznnp/oT5ZKZXJC9cmEIX6XHxaRv92UJQ0x6GxSNsTZtJj7Lb/vn/8
wGfPJWCPAgMBAAECggEAMsxwoj5oHwVZPSTs79Aev2LbmMGkUb7/x1T8Oz+oLr0w
aaqmVtsG3AaWJ+liRgRrqFxqyxIf6wCbLrNkLfIdcE8egIXRsX9+Xu33mEegjTQr
zjbIbiurJ+bO9sWxWV8tiFTjufJGA15V7PqPQBf2Yyj+Hs1MbLtr9IhxXn5oZniQ
zym7ijt/BbUCLzeq7kX3oOGmBfd4z3GNbekS7/md4jkHfFFeBCDjN2mgVb0rYxvH
sWb+w6lOmvSQ0AaVq6BDWUoUWOFBfTr+RDUyZ67Brr+dZE6xIFag+BH4IQFjSZFT
1E/xDoqOa5aRvbyvTeVnsVm0GR5AgIpxOLDLDdB1FQKBgQDtddvXU4uWx8jUk83W
Btdok3zA32Tztv2SlIb8u8b17jVt7xNbOL6W9wfg5Gxdx+P8BBm8xuWL6i3ky2FF
5Et4SxUIH72+lh8mYM2ieZSGnJrcznwaGf5+GFU/qSLN2UpKhe17M9vUVkKXJKgg
XQqk0VKUUZ9GlmtM6EhWBvcMcwKBgQDqg3Z2MpYQ5Aug1qgj30bkNPpkaHhN1W6S
CLjJJIWZtDWS2oLFXlgYDd/wxXJ8SH+lU4GQBDm5QL2cVWqxrQN6eiPswSZ8IpBs
f/uBkobX32wLiqQuFNTI9NSzeqNJqqL3AVJNj03WjxS7fvdrAWG9JCfwgslTj4Wz
4F9IvtSQdQKBgG+ZBEieKuwh2HCPRh1f+bxcFDVQx9ECHwnUY9xDI65Q1StlQGOO
t4ObdUhsEcHBP5QhGTdvAlJPLGJqcry2HgHax3eZ80KuqtUOiZXiLbtVvjInmItr
y/7W0Lmqc4Dqrc94QbO1G4sfPwxpXdpX37i152ltMr2p06PBRr2naFOhAoGAVLtB
Dv3CCMJMjUVhpOxkUcnuel7gsMaf17W9Bjfi6aEaBkBbJXKsA6znr7e3YL5VGGfu
lRlhvdRtbdHS5fVsH1GIL1+uRwW6BunK9or5m3/HKvhhz6CJLT6Ap4R1AQXdMb/R
e+J+LjquM/xw6sGqDcvFfnnSwhVGKrKz2rXQWY0CgYBtcLIXQMjU22Wi1Qa6ie+/
abDmT9liC4uJXwPRvh5mHUgDyvMiaxscr/SmQfNQr7vyXJVjezEiSkRNaFsa6VtU
v2D99HWZ1H8gdJ6Bf+bFkxdnd7ZUf/RkObFG32sh3XUGhpirqTQOXi/I9X1sdl9a
HG1hbQINTMIJjtIDbm5j0g==
-----END PRIVATE KEY-----, topic=SituationsTopic, kafka.ssl.truststore.type=PEM, kafka.ssl.keystore.certificate.chain=-----BEGIN CERTIFICATE-----
MIIG+jCCBOKgAwIBAgIRAMueG7onFxFz1xcCi5wVLkIwDQYJKoZIhvcNAQELBQAw
eTELMAkGA1UEBhMCREUxDTALBgNVBAcMBEVVMTAxDzANBgNVBAoMBlNBUCBTRTEj
MCEGA1UECwwaU0FQIENsb3VkIFBsYXRmb3JtIENsaWVudHMxJTAjBgNVBAMMHFNB
UCBDbG91ZCBQbGF0Zm9ybSBDbGllbnQgQ0EwHhcNMjYwNTE5MDcwNzQ4WhcNMjcw
NTE5MDgwNzQ4WjCCAfExCzAJBgNVBAYTAkRFMQ8wDQYDVQQKDAZTQVAgU0UxIzAh
BgNVBAsMGlNBUCBDbG91ZCBQbGF0Zm9ybSBDbGllbnRzMRowGAYDVQQLDBFjZi1l
dTIwLXNhcC1rYWZrYTGCAWMwggFfBgNVBAcMggFWRnNPdzFqWm55V3dkVjVGRkxM
bDVEaXJCaTlGQTVLVTdmTHgxYklvSkVZVUZPaTE1OHRMRzk5RTNURU96Y1FzM2tu
aVlPdGdQNE1iaVVMWUhoak8yRVZQZ2hEQ09OOVRKSW5iRWRZeU53LUdBMGJnME1R
SFgxb2tSMnJwMlA1M05nYUp1Q09uaHkxc0wzYVFsS1ZBMmZvR21Dakxvc19vZnB4
cHRHOGxZZXdybzd4eTJIejBYT2E4WGZYdTJNMFBqOHoxRUUzUllldWJCSTFxYUdW
ZExxUGlYR0R6ZHE4RGktRkFyNy1wV0JGcDNhR0FPU2lxUzFjLXUzODFsZzg2NC1l
UlJrclNQVnRjTTh0MzVWSkI3YzNDb0VLb0Rzc3ozSHRraVBwNm5RNmdlcVV2VXZi
OHRoWGVIZWJJcXdkcjZITWFUVnVwMnlYbjV6ODZGUW1tOHNBMSkwJwYDVQQDDCBz
YnNzX2l2Z2V6N2ZodnRxYXk0b2tnMnRsYjJhdmgyeTCCASIwDQYJKoZIhvcNAQEB
BQADggEPADCCAQoCggEBANmHrCRIIiWtY6Bj/vmrdC/EGZYFYyxS5D81MXlttkG+
ZhmPYGG1ivpg+FbFxIZuPjAO6Avs0FaWmOQRJK4IozruOWsM7OC7V2XZQIdo3iZe
CjoJQsg96Zhf/p8RrJmHuwJbcrQROm4e0PXUZXGweHzGGpNwkaBvex595z4pnYJA
kzIk6KrSrqQ2E4QRTFZjlPur9bo8XNZe5J2gIqD4nR0ii3PdrLrVM+vJg3y3PFtu
Bdd660kPzVSoLIYgugHMDMgscmxQTQ/+H8pjMwhjSPcTmPOeen+hPlkplckL1yYQ
hfpcfFpG/3ZQlDTHobFI2xNm0mPstv++f/zAZ88lYI8CAwEAAaOCAQEwgf4wCQYD
VR0TBAIwADAfBgNVHSMEGDAWgBTtx8AzXhKk93kym3vuCviohXiMLzAdBgNVHQ4E
FgQUgdZcpxA5k3deyQbE+UCnuO2HgWUwDgYDVR0PAQH/BAQDAgWgMBMGA1UdJQQM
MAoGCCsGAQUFBwMCMIGLBgNVHR8EgYMwgYAwfqB8oHqGeGh0dHA6Ly9zYXAtY2xv
dWQtcGxhdGZvcm0tY2xpZW50LWNhLWV1MTAtY3Jscy5zMy5ldS1jZW50cmFsLTEu
YW1hem9uYXdzLmNvbS9jcmwvMmExYjQ5YWMtZmMwMi00YTQ4LTk5M2EtOWE0ZDBk
ZmVjMzNlLmNybDANBgkqhkiG9w0BAQsFAAOCAgEALo/FgW8ViN4bjBBj9oHJsJ2Q
plCI5YBBFbHoHUQVZUG7sExYr+ZYmEd2OBmEX6G383Tm6alMSfgvuDaEvFk46brt
WQRYIIKl9qfNKCdeltsbSgkTrVByGeUJg3o+PCVTtkoYr5la83kvgZzwTpdI5xRU
OfNnmmHkH6qrBkg9ndksHcDcUVSiYX1q3Hnad/4sWKukcncfnUF9eMTNwDMG1f48
56rC36/JfHaWg3C3Wp9YCOF1du/AzT5/4OvtzM8P41odqnMJphs78bSn/xK86yca
/4clhGChyCRHiHIBXhHx7lvpmRBCDlCU8bSvtdywMlCobobAzGz6hFGHqWt10Pm2
kWXfUPVqfiS4gBPDQxhgfp5nni35UXYUBZH0pwBz6L6ReVtKa2TtPksYlbY0hK+q
0JmZBr4hWmTx02cbZ5ktI8AWfDQCzGExqb2fA789B5+pszaeskxk/EQXth915ZYD
NBkgcSYfhBXws0qwUNcrNztQSidM+p9pBiP/QLkVZ9YlsH34VKi59imbD/4CT/wT
1kcnfvWOwKhrc6ashj1HzupHjFJlKbIJCKDeEiUK/tEd7rLmPyYKaOeP6yjVLkvF
1chyqu8Qf2rQsDkUUlnPhmDlpCX49c+qAHdXy+nMsfpoVoOVldhun7rdUDBSsPiv
4oHoOCJwX+Gen9FfsT0=
-----END CERTIFICATE-----
-----BEGIN CERTIFICATE-----
MIIGYDCCBEigAwIBAgITcAAAAA0Y1cDKQ147YwAAAAAADTANBgkqhkiG9w0BAQsF
ADBNMQswCQYDVQQGEwJERTERMA8GA1UEBwwIV2FsbGRvcmYxDzANBgNVBAoMBlNB
UCBTRTEaMBgGA1UEAwwRU0FQIENsb3VkIFJvb3QgQ0EwHhcNMjMxMTIxMTAzNjE1
WhcNMzMxMTIxMTA0NjE1WjB5MQswCQYDVQQGEwJERTENMAsGA1UEBwwERVUxMDEP
MA0GA1UECgwGU0FQIFNFMSMwIQYDVQQLDBpTQVAgQ2xvdWQgUGxhdGZvcm0gQ2xp
ZW50czElMCMGA1UEAwwcU0FQIENsb3VkIFBsYXRmb3JtIENsaWVudCBDQTCCAiIw
DQYJKoZIhvcNAQEBBQADggIPADCCAgoCggIBAI8hpWjKK+OzKOPvXmlzD0EaWT9I
sINsnw7ek+BuxCtWnWWX1ILIqHjX+47dhD9IY/tUPiLFEI7WAFGoyzSmjY1qclx4
ZFkqvYhOoZe3r6LWL78TX/o1mRYLgg2SCDkDDsmnrT0l/X2fnW+2hb70s/d7q84M
mbrIC1gI0jtAJvFMZm0+82d+a0b3XYrUmmE6FTN0avFPcW4H83lFQJLJKwQ0HI72
Bno6ptle2k7QLZISkw0Mr76qJuHSi6DZxmGb0Ecp5g6X4Q++YdgmMu5gtQikkfIs
/qFnjPdRMKXblA0szRH2HlgNgmflpB3361oWz8jAwkujQz2VLeL+OGoVscAmLcUn
NYieXdUDnaAuUqgKYnc4QyGygVqMMx3g+1VTnXN+xwZ4oinaDucIWkolRZfuOIXo
g8gh50jAO2qy3Z+l783PCFA2RdncMThEuEctvSQXqQex2w/JpXKk+jkhnNOPYdWS
tbwOjofN/CRmlrOKNw8GRCT0YJCrQ/ZP6/C+yDlgAl617wbzjPNhfTi8T+7k1794
QPTKTRcPyJ6tBv6JOb0A7C6UfAA/pEVDhOX9NnB93mFYZxwEw6n2JLhRG/rNvEdf
7NKAs6M1EYhVNFD8iDWukpR2/jGJTgsxJvRk5nEPavgkIS2Mffv2zFnIpaPqv9ox
M01BXHJs6vK6rePfAgMBAAGjggELMIIBBzASBgNVHRMBAf8ECDAGAQH/AgEAMB0G
A1UdDgQWBBTtx8AzXhKk93kym3vuCviohXiMLzAfBgNVHSMEGDAWgBQcvGYrDsqN
S5+Nk3GpD8pnRmkTIjBKBgNVHR8EQzBBMD+gPaA7hjlodHRwOi8vY2RwLnBraS5j
by5zYXAuY29tL2NkcC9TQVAlMjBDbG91ZCUyMFJvb3QlMjBDQS5jcmwwVQYIKwYB
BQUHAQEESTBHMEUGCCsGAQUFBzAChjlodHRwOi8vYWlhLnBraS5jby5zYXAuY29t
L2FpYS9TQVAlMjBDbG91ZCUyMFJvb3QlMjBDQS5jcnQwDgYDVR0PAQH/BAQDAgEG
MA0GCSqGSIb3DQEBCwUAA4ICAQBWP3oZa36jJ+4JakH1kEkCcoKffY9UYFwuBCAL
3jdBruhHH8aLGseI2Zhl5r7os1rkD0Sl55xrM4i1gyeRAyTM/Pe28cBIxFs2vbBC
+4mpIfKPSuTw61P3FOeaqHUgvVJsIiHgfKbMIDzrvwAUMTr453a77DrKZ/oAXW3K
xelNxhfjiCDsWIs++6NbSIwZsQjxPZp39HyN0XBh6BoxN5dmwT9AnlzkqyBiIPwi
TrNxcdCB4MDrwLRZlW21nRb/nTDCfavITqJNAjz1vzNXpSfda74MINstrOwsAcsX
gkYJpxPK7q9VV3vx2ZfZwRIBIxXlisUD/wIkz7zteStT2yfkV8uoh2pweedBgdX1
yah+dWl5LXvSRtmxgGL2CsxZcbQHbnh10OBS9qXBbeN3UswwoXKigYy9v0JkKmKg
knhhNG5+SYVUUzWBCy9DyM2TDMH2VtiZcu2dFqRuzRTi68GXaN9HCIr6gxjqbaPf
yjtQppmfobrrHpBpuI7jM8RPPg2N3Kmj/Wzmf4uPNJT00WUiCG3FdWO4cCX/UxJs
dxAXH+QhykGB1t28JbYpzO1NQohd2shlShkpgqn4ldS6kPC5VWSGUod3139KCrFO
HYFN+t5tRFJ5amXg7nzYf2tGFzsWfa8qMLtuKZWBo+2hvDaxreSSlfTQ6M8QHvS7
TG767A==
-----END CERTIFICATE-----, kafka.security.protocol=SSL], ErrorIfExists
(3) LocalRelation
Arguments: <empty>, [anchorObject#578, messageVariables#579, triggerObject#580, situationStatus#581, situationType#582, marketUnit#583]
(4) Project
Arguments: [to_json(struct(anchorObject, anchorObject#578, messageVariables, messageVariables#579, triggerObject, triggerObject#580, situationStatus, situationStatus#581, situationType, situationType#582, marketUnit, marketUnit#583), Some(GMT)) AS value#584]
(5) Project
Arguments: [cast(value#584 as string) AS value#585]
(6) Project
Arguments: [value#585, array(struct(key, X-Tenant-ID, value, cast(6944346648028224943 as binary)), struct(key, X-Message-ID, value, cast(446d2bb7-5bf7-4637-aa3b-2cdd22551caf as binary)), struct(key, X-Event-Type, value, cast(SituationCreate as binary)), struct(key, X-BTP-Tenant-ID, value, cast(0059d9b2-605f-467b-887c-9c65d0e59daf as binary))) AS headers#594]