core
core copied to clipboard
gazette
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
The [docs on deleting shard specs](https://gazette.readthedocs.io/en/latest/consumers-shardspecs.html#deleting-shardspecs) say that you can add `delete: true` under the `common` section. This does not work, though, since we unmarshal that field into a `pc.ShardSpec`,...
This fixes a bug which caused the shard supervisor to stall indefinitely. If it ran `shards unassign` and there was nothing to be unassigned, it would never increment the etcd...
Adds a prometheus collector implementation to the broker/client package that allows tracking of disk usage across file-backed appendBuffers. If AppendRPCs are retrying, or taking longer than normal, users can timeout...
Moves into client/resolver so that we can manage the life-cycle of the gauge with the shard it is measuring --- This change is [](https://reviewable.io/reviews/gazette/core/309)
"Properties" were originally added to the log FSM when it was a concern that files like `IDENTITY`, written by RocksDB on DB initialization and never changed, would prevent normal RocksDB...
Observed from a consumer application on a recent release, where gazette and the consumer were rolling in tandem (the consumer happened to pick a gazette broker that was exiting): ```...
During a recent automated GKE upgrade, all brokers and Etcd pods were simultaneously signaled to exit (not ideal, but also not the issue at hand). Etcd pods exited, and on...
The background for this is described in estuary/flow#192. The goal is to be able to verify whether a given `consumer.Checkpoint` is from a particular Gazette cluster, so that we could...
The storage bucket(s) backing a large and very busy cluster had a configuration change such that fragment uploads were refused for an extended period (hours), and the disks of many...
Return a more descriptive error if a `nil` `state` is passed into `NewJSONFileStore`. Didn't add/modify tests as the change is pretty trivial. LMK if you think otherwise. --- This change...
