I have a pipeline that reads Kafka records and I’m writing any errors to an S3 bucket. Most of the errors are related to tombstone records. Once my original pipeline runs, I plan on having another pipeline process the error files on S3. So far so good. I can get the error code from the SDC file in the record:errorCode() field. I also need the Kafka key from the S3 file. What is the highlighted record/field called and how do I obtain the value with an expression evaluator or other processor? Once I convert it to a map, that value is gone.
![](https://uploads-us-west-2.insided.com/streamsets-en/attachment/177a9c20-b1f4-4aff-9512-fb923fc51176.png)
Best answer by pkandra
View original