Spark lineage msg send to Kyuubi event handler with kyuubi.backend.server.event.loggers=KAFKA, what is the message KEY in Kafka?

[madeirak]

For example, normal KyuubiOperationEvent msg’ s key in Kafka is kyuubi_operation

Lineage Value in Doc is like below, what does the key like? Msg is too much ,I am afraid of missing Spark lineage msg, or It just do not work right, I dont know...

{
   "inputTables": ["spark_catalog.default.test_table0"],
   "outputTables": [],
   "columnLineage": [{
      "column": "col0",
      "originalColumns": ["spark_catalog.default.test_table0.a"]
   }, {
      "column": "col1",
      "originalColumns": ["spark_catalog.default.test_table0.b"]
   }]
}