- {#if disabled || !expanded}
+ {#if !expanded}
{:else}
diff --git a/assets/svelte/consumers/GroupColumnsForm.svelte b/assets/svelte/consumers/GroupColumnsForm.svelte
index 151f55270..a390fc4de 100644
--- a/assets/svelte/consumers/GroupColumnsForm.svelte
+++ b/assets/svelte/consumers/GroupColumnsForm.svelte
@@ -17,7 +17,6 @@
let defaultGroupColumns = selectedTable?.default_group_columns || [];
let groupColumnError: string | null = null;
let useCustomGrouping = false;
- let isExpanded = false;
$: groupColumnError = errors.sequence_filter?.group_column_attnums?.[0];
$: defaultGroupColumns = selectedTable?.default_group_columns || [];
@@ -60,18 +59,22 @@
.join(", ")}`
: selectedTable?.is_event_table
? "Using source_database_id, source_table_oid, and record_pk for grouping, which is the default"
- : "Using primary keys for grouping, which is the default";
+ : defaultGroupColumns.length === 0
+ ? "No primary keys available. Custom grouping is required."
+ : "Using primary keys for grouping, which is the default";
{#if isEditMode}
-
-
-
- Message grouping
-
-
-
+
+
+ Message grouping
+
+
+
{#if !useCustomGrouping && !selectedTable.is_event_table}
Using primary keys for grouping.
@@ -83,16 +86,26 @@
readonly={true}
/>
{/if}
-
-
+
+
{:else if selectedTable && defaultGroupColumns.length === 0}
-
-
+
+
Message grouping
-
-
+
+
+
+
+ {summaryText}
+
+
+
+
No primary keys available. Custom grouping is required.
@@ -104,16 +117,14 @@
{#if groupColumnError}
{groupColumnError}
{/if}
-
-
+
+
{:else}
-
+
-
- Message grouping
-
+ Message grouping
diff --git a/assets/svelte/consumers/SinkConsumerForm.svelte b/assets/svelte/consumers/SinkConsumerForm.svelte
index 73dd7461a..a418fccb8 100644
--- a/assets/svelte/consumers/SinkConsumerForm.svelte
+++ b/assets/svelte/consumers/SinkConsumerForm.svelte
@@ -354,15 +354,19 @@
});
}
- let backfillSectionExpanded = false;
let showMessageTypeExampleModal = false;
let selectedExampleType: "change" | "record" = "change";
let transformSectionEnabled = false;
+ let transformSectionExpanded = false;
let backfillSectionEnabled = false;
+ let backfillSectionExpanded = false;
$: {
transformSectionEnabled = selectedTable && consumer.type !== "redis_stream";
+ transformSectionExpanded = transformSectionEnabled && !isEditMode;
+
backfillSectionEnabled = selectedTable && !isEditMode;
+ backfillSectionExpanded = backfillSectionEnabled && !isEditMode;
}
let transformRefreshState: "idle" | "refreshing" | "done" = "idle";
@@ -521,7 +525,10 @@
-
+
Transforms
@@ -582,7 +589,10 @@
{#if !isEditMode}
-
+
Initial backfill