"The output of this node includes key_schema_id, value and offsets which is an array of objects containing the partition, offset, error_code, and error for each of the messages published."
I don't see the output from the producer. Would love to have it so I can store or reference the offset. Would also like to see a way to add the logical or numerical offset in the Consumer node so you can read from the beginning or set to a specific offset by number or timestamp.
Looks like this repo hasn't been updated in a while, I'm hoping it warms back up. :-)
The producer information on the node says...
"The output of this node includes key_schema_id, value and offsets which is an array of objects containing the partition, offset, error_code, and error for each of the messages published."
I don't see the output from the producer. Would love to have it so I can store or reference the offset. Would also like to see a way to add the logical or numerical offset in the Consumer node so you can read from the beginning or set to a specific offset by number or timestamp.
Looks like this repo hasn't been updated in a while, I'm hoping it warms back up. :-)
Thanks.