undefined | Better HN

0 pointsmoatra10y ago0 comments

That sounds great if your messages in the logs are the complete state for that key, but I'm not seeing how to use that compaction system if the messages are change events.

Is there a system designed for snapshotting the aggregate and logging the delta?

0 comments

kasey_junk10y ago

A common pattern is to publish a "checkpoint" message. Not sure if the concept is built into Kafka or not.

erichmond10y ago

It's easy to store messages in HDFS or S3 for long-term storage. It's also easy to replay messages from those mediums, if you need to re-ingest data later on.

j / k navigate · click thread line to collapse