Striim 3.9.4 / 3.9.5 documentation

KafkaWriter output with XMLFormatter

Each output record will include an extra element __striimmetadata with a nested element position containing information Striim can use to ensure that no duplicate records are written during recovery (see Recovering applications).

For input events of this user-defined Striim type:

CREATE TYPE emptype ( id int, name string);

output would be similar to:

<ID> 1 </ID>
<Name> User One </Name> 
</__striimmetadata> ...