mix format and prettier

Author: RTLS

assets/svelte/sinks/kafka/KafkaSinkCard.svelte

@@ -65,7 +65,8 @@
             <Tooltip.Content class="p-4 max-w-xs">
               <p class="text-sm text-muted-foreground font-normal">
                 {#if consumer.sink.producer_compression === "lz4"}
-                  Set via <code>KAFKA_PRODUCER_COMPRESSION=lz4</code> environment variable.
+                  Set via <code>KAFKA_PRODUCER_COMPRESSION=lz4</code> environment
+                  variable.
                 {:else}
                   Set <code>KAFKA_PRODUCER_COMPRESSION=lz4</code> to enable LZ4 compression.
                 {/if}

config/runtime.exs

@@ -72,19 +72,14 @@ sqs_config =
     }
   end
 
-# Enable via_sqs_for_new_sinks? flag for HttpPushSink
-config :sequin, Sequin.Consumers.HttpPushSink,
-  via_sqs_for_new_sinks?: System.get_env("HTTP_PUSH_VIA_SQS_NEW_SINKS") in ~w(true 1)
-
-# Configure the SQS pipeline with credentials
-config :sequin, Sequin.Runtime.HttpPushSqsPipeline,
-  sqs: sqs_config,
-  discards_disabled?: System.get_env("HTTP_PUSH_VIA_SQS_DISCARDS_DISABLED") in ~w(true 1)
-
 kafka_producer_compression =
   case System.get_env("KAFKA_PRODUCER_COMPRESSION") do
-    "lz4" -> :lz4
-    nil -> :no_compression
+    "lz4" ->
+      :lz4
+
+    nil ->
+      :no_compression
+
     other ->
       raise """
       Invalid value for KAFKA_PRODUCER_COMPRESSION: #{inspect(other)}
@@ -94,23 +89,31 @@ kafka_producer_compression =
       """
   end
 
-config :sequin, Sequin.Consumers.KafkaSink,
-  producer_compression: kafka_producer_compression
+# Enable via_sqs_for_new_sinks? flag for HttpPushSink
+config :sequin, Sequin.Consumers.HttpPushSink,
+  via_sqs_for_new_sinks?: System.get_env("HTTP_PUSH_VIA_SQS_NEW_SINKS") in ~w(true 1)
+
+config :sequin, Sequin.Consumers.KafkaSink, producer_compression: kafka_producer_compression
+
+# Configure the SQS pipeline with credentials
+config :sequin, Sequin.Runtime.HttpPushSqsPipeline,
+  sqs: sqs_config,
+  discards_disabled?: System.get_env("HTTP_PUSH_VIA_SQS_DISCARDS_DISABLED") in ~w(true 1)
 
 config :sequin, Sequin.Runtime.SlotProcessorServer,
   max_accumulated_bytes: ConfigParser.replication_flush_max_accumulated_bytes(env_vars),
   max_accumulated_messages: ConfigParser.replication_flush_max_accumulated_messages(env_vars),
+  # ## Using releases
+  #
+  # If you use `mix release`, you need to explicitly enable the server
+  # by passing the PHX_SERVER=true when you start it:
+  #
+  #     PHX_SERVER=true bin/sequin start
+  #
+  # Alternatively, you can use `mix phx.gen.release` to generate a `bin/server`
+  # script that automatically sets the env var above.
   max_accumulated_messages_time_ms: ConfigParser.replication_flush_max_accumulated_time_ms(env_vars)
 
-# ## Using releases
-#
-# If you use `mix release`, you need to explicitly enable the server
-# by passing the PHX_SERVER=true when you start it:
-#
-#     PHX_SERVER=true bin/sequin start
-#
-# Alternatively, you can use `mix phx.gen.release` to generate a `bin/server`
-# script that automatically sets the env var above.
 if System.get_env("PHX_SERVER") do
   config :sequin, SequinWeb.Endpoint, server: true
   config :sequin, SequinWeb.MetricsEndpoint, server: true

lib/sequin/consumers/kafka_sink.ex

@@ -179,7 +179,7 @@ defmodule Sequin.Consumers.KafkaSink do
     |> maybe_add_ssl(sink)
     |> Keyword.put(:query_api_versions, true)
     |> Keyword.put(:auto_start_producers, true)
-    |> Keyword.put(:default_producer_config, [compression: compression])
+    |> Keyword.put(:default_producer_config, compression: compression)
   end
 
   # Add SASL authentication if username/password are configured