== Physical Plan ==
Execute SaveIntoDataSourceCommand (1)
+- SaveIntoDataSourceCommand (2)
+- Project (7)
+- Project (6)
+- Project (5)
+- Project (4)
+- LocalRelation (3)
(1) Execute SaveIntoDataSourceCommand
Output: []
(2) SaveIntoDataSourceCommand
Arguments: org.apache.spark.sql.kafka010.KafkaSourceProvider@5794c899, [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=20.50.251.154:50094,20.50.251.154:50194,20.50.251.154:50294, kafka.ssl.keystore.key=-----BEGIN PRIVATE KEY-----
MIIEvAIBADANBgkqhkiG9w0BAQEFAASCBKYwggSiAgEAAoIBAQCsqTR07Ofx898s
7Se0NycWg2FPBFx6hqu2IWm9+rc6+VsXdTRRc7pI9EdiVraHXqtSxFdqjPwViLEA
kUM9pgtYT9qrxIYMQ0sF5mSbR3GpjglHTBYcu7viVBUbx/t9O6aXiwOwG1Q2GiMI
YxyeVfObn6W1D8F3ToRB0KejPPMV6OIs0ssd+6DeqLcPGAXInmA+k7ftLYShbmeD
a8X4ztloUXvFRTb42CgE8tiTOlNHYRgtZGaiFWm5pYO/TUQyLpGewSvvd1GHEHHF
y54FCw4U/eapPxKzWOFNYbConP7sYezcn2L3HhuXNr0iV5hRoaQEzPbYBoMJcSG6
JUUTXGXbAgMBAAECggEAJaqQCAX6n5zdDfb6l2UEwPOOUeeYqR4h7YyifdBpEpN9
XMOz0yUU+X9Y50oVbbioVVkB3Pu+ro/wVThbW+KSTQS2powr1hcEEdhuEDXoxN14
hrZBiKkn1rsTE8lvwqU1tY+dEVkU6OyQwe6lOqFzkHqmcrZqNTXKwnTbbVAJk7ir
JTJXrx3Hds3+XUBiSbnwHDCY/2O9or1vrqVY8Y66CvzaqB2Qih3OQM+goYlk8ONu
egY9PbKXVJsOQpuR6SUqSxozT3eOln469Fygw0WsoBXlnS5jheltuvgxrOv61bIJ
ZDwXoiUEau0q/4mwHO31n8dOhd4nkkXDml1/htNdIQKBgQDm1KMvpfHgeqyjf+zk
wbSZRnTAlTv2YC6aUWEpCwwFTxA6m0sg6Jd7Ei/lW1NWqheHfYLe10AyceaDj45h
3NQD7z199GkJKrP+U0OYGlBLYfnU/sDviHxaeZYJd4PFVOehkZXXZBqzgBAg7qj0
uhazm7C4nBXh+UrnZj+hPHIg6wKBgQC/fNScpHjdZ87uxreJfN93ZLB71ETDhCTq
1ARsyBfRHQ2DU584W+F7P52XLekOKDZT6Anwb20usygJ84Ntac0EijUnsVb6vO5A
FTISocFeoLTuNgPdFBqc2Cp4kBhjQ7LSQzi/Vfp/ULm+cXHxxpkXvI2HLfF/qThw
uTBKm90S0QKBgFYtHntEdce7pMYplTRWCOmMPzxCuq8he2SLaz2abTNyL/nhTiwM
CbmdsZnr/XIGcGBaAEjXjZUHpuqI5rwsaE7Lu2ZRoAEXGzmgtkSL1lw+SLo3HaqP
hvV0HQqNvvkl2JAePRW7vqgy8FKLJzKuYplNT62sQBMsMcWwC6NTYLxfAoGABkpq
ja7VjaiAYtXCZ9DjYn+7UIYbsDSiJdjLQGueZK9Ip1zS6T4TfUIMwk+uzVlC16TS
1sRCWPtnwFPwqGKGarTDpEcuLVSRmydXGseXm6055G1/2P51FVwAoS9SrcgmksPE
lHyVmyMixv/hF2lH1EDMgXlf6qq7gPCEhp7yN1ECgYB5tTIRBznsGvQ0qVNX3OvF
FeqJpgXGAuTzn79oy0u/a2K1bBUDuHhY6oLJYbOwagLqmgC1VhSHkgQYI8DLnrjJ
72ay4Nt3Klsd5VT/hPeJCoDXEDmokF8FYvYTfIPVSim4llSA8Y0Nbe5XzBJFPMx+
xB26cmdk0rozugAuasNtDA==
-----END PRIVATE KEY-----, topic=prp-traceability-publish, kafka.ssl.truststore.type=PEM, kafka.ssl.keystore.certificate.chain=-----BEGIN CERTIFICATE-----
MIIG+jCCBOKgAwIBAgIRAPuM9Xo+r5DIIG3nMAvk4ycwDQYJKoZIhvcNAQELBQAw
eTELMAkGA1UEBhMCREUxDTALBgNVBAcMBEVVMTAxDzANBgNVBAoMBlNBUCBTRTEj
MCEGA1UECwwaU0FQIENsb3VkIFBsYXRmb3JtIENsaWVudHMxJTAjBgNVBAMMHFNB
UCBDbG91ZCBQbGF0Zm9ybSBDbGllbnQgQ0EwHhcNMjUwOTI0MDgzNDQzWhcNMjYw
OTI0MDkzNDQzWjCCAfExCzAJBgNVBAYTAkRFMQ8wDQYDVQQKDAZTQVAgU0UxIzAh
BgNVBAsMGlNBUCBDbG91ZCBQbGF0Zm9ybSBDbGllbnRzMRowGAYDVQQLDBFjZi1l
dTIwLXNhcC1rYWZrYTGCAWMwggFfBgNVBAcMggFWaWp4eWFyNzNoRjlGSlVfVkYy
UjMySndoTDk0NTNYUEk3NFUzUnhmQmlhOGljWTJTeDlJR1h1YzktQWVmZElFRGxy
X3dhRmV2dGwzVW9nYTBVMnJjMWtWMElEcVd3NTVodVJVajNfWjJHVTJLMzR3Y3NX
YzBXZVVuWHVrRmUyN1pXa0RTeVdJSUQzNTREUmdkME9SM0JoOGdiWkhnRmJ3Mm5x
Nmo3QTAzb25mWGdvQVI0SzJST2JobDU2NTJ0UFVOMVVpRlo4UXl6WlRFdWFyUHM3
OUtOREdvQ3hfSVRXZVd0elVDczZZWTZWemVJVkxnMllyVGI0YzkwX3hSQlR1M1V1
OFh6cC1WbktoY29iVXpmLXQzQ0NGa2M5N29mc1RWWkJWTERmUnBfR2JaU2JObnhF
TFBIeDlyWDc5NmZpMlpRdVNMeGlhWnF6VWNiMnJCOFRSeG1nMSkwJwYDVQQDDCBz
YnNzX2dreDRoanRoZHluLW9sZzZqYmhrZS0yZ3VodzCCASIwDQYJKoZIhvcNAQEB
BQADggEPADCCAQoCggEBAKypNHTs5/Hz3yztJ7Q3JxaDYU8EXHqGq7Yhab36tzr5
Wxd1NFFzukj0R2JWtodeq1LEV2qM/BWIsQCRQz2mC1hP2qvEhgxDSwXmZJtHcamO
CUdMFhy7u+JUFRvH+307ppeLA7AbVDYaIwhjHJ5V85ufpbUPwXdOhEHQp6M88xXo
4izSyx37oN6otw8YBcieYD6Tt+0thKFuZ4NrxfjO2WhRe8VFNvjYKATy2JM6U0dh
GC1kZqIVabmlg79NRDIukZ7BK+93UYcQccXLngULDhT95qk/ErNY4U1hsKic/uxh
7NyfYvceG5c2vSJXmFGhpATM9tgGgwlxIbolRRNcZdsCAwEAAaOCAQEwgf4wCQYD
VR0TBAIwADAfBgNVHSMEGDAWgBTtx8AzXhKk93kym3vuCviohXiMLzAdBgNVHQ4E
FgQUt8C7I370r3xOZAWUeSSBdSixdjkwDgYDVR0PAQH/BAQDAgWgMBMGA1UdJQQM
MAoGCCsGAQUFBwMCMIGLBgNVHR8EgYMwgYAwfqB8oHqGeGh0dHA6Ly9zYXAtY2xv
dWQtcGxhdGZvcm0tY2xpZW50LWNhLWV1MTAtY3Jscy5zMy5ldS1jZW50cmFsLTEu
YW1hem9uYXdzLmNvbS9jcmwvMmExYjQ5YWMtZmMwMi00YTQ4LTk5M2EtOWE0ZDBk
ZmVjMzNlLmNybDANBgkqhkiG9w0BAQsFAAOCAgEAE8KNaj6PLP2tdMtpMR7kOQ1E
GVNHNWpSuNHSZVWLg4t2l3MqiZbo2EIWqTyt3y1FaQH2fiLMJ4DmsICux/BsYqin
0bxEbWub1+b+Yh3RrKRzFB3I05w4oX6SycTtKZFIM1ISZIqRPe8G3LLK6yLS2Ogc
p6RXSYHHiwrk6tKl2Rrkf5f0eiN7Qn2+RdDfNurIGzrya36FhqomwK46Z3HQDi7V
KLevg0EJn3pU+wYMxkm7HskZ2eWli3GsHAS9dYM3ztC8g85liCG+IUiNvBdePZJ2
82OKiMYsl7ER/FCQRzKsuzuLeZv44gBUYpY2e0LMHi3LxlfvlipBp/r+9QCUlUKi
2BhXaHdDrkgAcjYWGIca+uEkw4CPCF/7IOc35n3j9Ne89jeSh6wuTJEvjoJmJm4/
TUO8jzblAErU8AcN2i5lnRcyrka46f1GO6Jl8HlBIf6DrI4WR+zh7KYOk4dIhOWW
95dSFobUQZmaUt4iQOymkNCfKlSuIKPsD/P3DhIK7FTCrnamUxA11dO7vgy3tR7N
STxtwY26d2FMELmn9yVL022xe4UPpFpJEnxJNCZaR6PNhsmAS7JFptE1CJVcOSgo
7sPRCPVMbjIz0SxLx9eRZC97l3piI/r71rle3wkytep0+IY3CotlyAinicHbqXu1
uGV7tiLb/50fcOfWPnE=
-----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: [traceabilityObject#6614965, uri#6614966, replenishmentRunId#6614967]
(4) Project
Arguments: [to_json(array(struct(traceabilityObject, traceabilityObject#6614965, uri, uri#6614966, replenishmentRunId, replenishmentRunId#6614967)), Some(UTC)) AS value#6614968]
(5) Project
Arguments: [UDF(value#6614968) AS value#6614969]
(6) Project
Arguments: [cast(value#6614969 as string) AS value#6614970]
(7) Project
Arguments: [value#6614970, array(struct(key, X-Tenant-ID, value, cast(8036878051404434378 as binary)), struct(key, X-Message-ID, value, cast(uuid(Some(-1498062919226677286)) as binary)), struct(key, X-Event-Type, value, cast(TraceabilityDataUpsert as binary)), struct(key, X-BTP-Tenant-ID, value, cast(4c1d9b05-9077-45fe-926f-f90e52e7b436 as binary))) AS headers#6614979]