THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
where Record encodes either the Sink or Source Record which caused the failure. It is the was input to an operation which failed to evaluate. the failed operation.
| Type | Name | Description |
|---|---|---|
| string | topic | the topic which this message was read from or will be written to. |
| int32 | partition | the partition which this message was read from or will be written to. |
| int64 | timestamp | the timestamp of the Kafka message. |
| SchemaAndValue | key | the key of the message. |
| SchemaAndValue | value | the value of the message. |
| SchemaAndValue | headers | the headers of the message. |
| int64 | offset | the offset of the message in the Kafka topic (available only in sink connectors). |
| string | timestamp_type | the type of the timestamp. One of: NO_TIMESTAMP_TYPE, CREATE_TIME or LOG_APPEND_TIME (available only in sink connectors). |
| map<string, string> | source_partition | information about the source partition from where this message was created from (available only in source connectors and contents are specific to the implementation). |
| map<string, string> | source_offset | information about the source offset from where this message was created from (available only in source connectors and contents are specific to the implementation). |
...