You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
CONSUMER consumer2 WITH (read_from = Datetime('2022-12-01T12:13:22Z')) -- Sets up the message write time starting from which the consumer will receive data.
72
+
CONSUMER consumer2 WITH (read_from = Datetime('1970-01-01T00:00:00Z')) -- Sets up the message write time starting from which the consumer will receive data.
73
73
-- Value type: Datetime OR Timestamp OR integer (unix-timestamp in the numeric format).
74
74
-- Default value: now
75
75
) WITH (
76
-
min_active_partitions = 5, -- Minimum number of topic partitions.
77
-
partition_count_limit = 10, -- Maximum number of active partitions in the topic. 0 is interpreted as unlimited.
78
-
retention_period = Interval('PT12H'), -- Data retention period in the topic. Value type: Interval, default value: 18h.
79
-
retention_storage_mb = 1, -- Limit on the maximum disk space occupied by the topic data.
76
+
min_active_partitions = 1, -- Minimum number of topic partitions.
77
+
partition_count_limit = 0, -- Maximum number of active partitions in the topic. 0 is interpreted as unlimited.
78
+
retention_period = Interval('PT18H'), -- Data retention period in the topic. Value type: Interval.
79
+
retention_storage_mb = 0, -- Limit on the maximum disk space occupied by the topic data.
80
80
-- When this value is exceeded, the older data is cleared, like under a retention policy.
81
81
-- 0 is interpreted as unlimited.
82
-
partition_write_speed_bytes_per_second = 2097152, -- Maximum allowed write speed per partition.
83
-
partition_write_burst_bytes = 2097152 -- Write quota allocated for write bursts.
84
-
-- When set to zero, the actual write_burst value is equalled to
85
-
-- the quota value (this allows write bursts of up to one second).
82
+
partition_write_speed_bytes_per_second = 1048576, -- Maximum allowed write speed per partition.
83
+
partition_write_burst_bytes = 0 -- Write quota allocated for write bursts.
84
+
-- When set to zero, the actual write_burst value is equalled to
85
+
-- the quota value (this allows write bursts of up to one second).
ADD CONSUMER new_consumer WITH (read_from = 0), -- Sets up the message write time starting from which the consumer will receive data.
93
-
-- Value type: Datetime OR Timestamp OR integer (unix-timestamp in the numeric format).
94
-
-- Default value: now
95
-
ALTER CONSUMER consumer1 SET (read_from = Datetime('2023-12-01T12:13:22Z')),
92
+
ADD CONSUMER new_consumer WITH (read_from = Datetime('1970-01-01T00:00:00Z')), -- Sets up the message write time starting from which the consumer will receive data.
93
+
-- Value type: Datetime OR Timestamp OR integer (unix-timestamp in the numeric format).
94
+
-- Default value: now
95
+
ALTER CONSUMER consumer1 SET (read_from = Datetime('1970-01-01T00:00:00Z')),
96
96
DROP CONSUMER consumer2,
97
97
SET (
98
-
min_active_partitions = 10, -- Minimum number of topic partitions.
99
-
partition_count_limit = 15, -- Maximum number of active partitions in the topic. 0 is interpreted as unlimited.
100
-
retention_period = Interval('PT36H'), -- Data retention period in the topic. Value type: Interval, default value: 18h.
101
-
retention_storage_mb = 10, -- Limit on the maximum disk space occupied by the topic data.
102
-
-- When this value is exceeded, the older data is cleared, like under a retention policy.
103
-
-- 0 is interpreted as unlimited.
104
-
partition_write_speed_bytes_per_second = 3145728, -- Maximum allowed write speed per partition.
105
-
partition_write_burst_bytes = 1048576 -- Write quota allocated for write bursts.
106
-
-- When set to zero, the actual write_burst value is equalled to
107
-
-- the quota value (this allows write bursts of up to one second).
98
+
min_active_partitions = 1, -- Minimum number of topic partitions.
99
+
partition_count_limit = 0, -- Maximum number of active partitions in the topic. 0 is interpreted as unlimited.
100
+
retention_period = Interval('PT18H'), -- Data retention period in the topic. Value type: Interval.
101
+
retention_storage_mb = 0, -- Limit on the maximum disk space occupied by the topic data.
102
+
-- When this value is exceeded, the older data is cleared, like under a retention policy.
103
+
-- 0 is interpreted as unlimited.
104
+
partition_write_speed_bytes_per_second = 1048576, -- Maximum allowed write speed per partition.
105
+
partition_write_burst_bytes = 0 -- Write quota allocated for write bursts.
106
+
-- When set to zero, the actual write_burst value is equalled to
107
+
-- the quota value (this allows write bursts of up to one second).
0 commit comments