diff --git a/packages/core/src/lib/message/version_0.spec.ts b/packages/core/src/lib/message/version_0.spec.ts
index 25ca5d1afb..32e0aa3970 100644
--- a/packages/core/src/lib/message/version_0.spec.ts
+++ b/packages/core/src/lib/message/version_0.spec.ts
@@ -9,7 +9,9 @@ describe("Waku Message version 0", function () {
   it("Round trip binary serialization", async function () {
     await fc.assert(
       fc.asyncProperty(fc.uint8Array({ minLength: 1 }), async (payload) => {
-        const encoder = createEncoder(TestContentTopic);
+        const encoder = createEncoder({
+          contentTopic: TestContentTopic,
+        });
         const bytes = await encoder.toWire({ payload });
         const decoder = createDecoder(TestContentTopic);
         const protoResult = await decoder.fromWireToProtoObj(bytes);
@@ -29,7 +31,10 @@ describe("Waku Message version 0", function () {
   it("Ephemeral field set to true", async function () {
     await fc.assert(
       fc.asyncProperty(fc.uint8Array({ minLength: 1 }), async (payload) => {
-        const encoder = createEncoder(TestContentTopic, true);
+        const encoder = createEncoder({
+          contentTopic: TestContentTopic,
+          ephemeral: true,
+        });
         const bytes = await encoder.toWire({ payload });
         const decoder = createDecoder(TestContentTopic);
         const protoResult = await decoder.fromWireToProtoObj(bytes);
diff --git a/packages/core/src/lib/message/version_0.ts b/packages/core/src/lib/message/version_0.ts
index 48ea0cb05f..0e680dce44 100644
--- a/packages/core/src/lib/message/version_0.ts
+++ b/packages/core/src/lib/message/version_0.ts
@@ -1,4 +1,5 @@
 import type {
+  EncoderOptions,
   IDecodedMessage,
   IDecoder,
   IEncoder,
@@ -99,14 +100,11 @@ export class Encoder implements IEncoder {
  * pass to { @link @waku/interfaces.LightPush.push } or
  * { @link @waku/interfaces.Relay.send } to automatically encode outgoing
  * messages.
- *
- * @param contentTopic The content topic to set on outgoing messages.
- * @param ephemeral An optional flag to mark message as ephemeral, ie, not to be stored by Waku Store nodes.
  */
-export function createEncoder(
-  contentTopic: string,
-  ephemeral = false
-): Encoder {
+export function createEncoder({
+  contentTopic,
+  ephemeral,
+}: EncoderOptions): Encoder {
   return new Encoder(contentTopic, ephemeral);
 }
 
diff --git a/packages/core/src/lib/waku.ts b/packages/core/src/lib/waku.ts
index 7e2d04b9d8..ed7dd202e4 100644
--- a/packages/core/src/lib/waku.ts
+++ b/packages/core/src/lib/waku.ts
@@ -263,7 +263,10 @@ export class WakuNode implements Waku {
 
     const relay = this.relay;
     if (relay && relayPeriodSecs !== 0) {
-      const encoder = createEncoder(RelayPingContentTopic, true);
+      const encoder = createEncoder({
+        contentTopic: RelayPingContentTopic,
+        ephemeral: true,
+      });
       this.relayKeepAliveTimers[peerIdStr] = setInterval(() => {
         log("Sending Waku Relay ping message");
         relay
diff --git a/packages/interfaces/src/message.ts b/packages/interfaces/src/message.ts
index ca2770d399..37acdaa3b1 100644
--- a/packages/interfaces/src/message.ts
+++ b/packages/interfaces/src/message.ts
@@ -30,6 +30,16 @@ export interface IMessage {
   rateLimitProof?: IRateLimitProof;
 }
 
+export interface EncoderOptions {
+  /** The content topic to set on outgoing messages. */
+  contentTopic: string;
+  /**
+   * An optional flag to mark message as ephemeral, i.e., not to be stored by Waku Store nodes.
+   * @defaultValue `false`
+   */
+  ephemeral?: boolean;
+}
+
 export interface IEncoder {
   contentTopic: string;
   ephemeral: boolean;
diff --git a/packages/message-encryption/src/ecies.spec.ts b/packages/message-encryption/src/ecies.spec.ts
index 0b1a30d25d..cab9b9dc2e 100644
--- a/packages/message-encryption/src/ecies.spec.ts
+++ b/packages/message-encryption/src/ecies.spec.ts
@@ -15,7 +15,10 @@ describe("Ecies Encryption", function () {
         async (payload, privateKey) => {
           const publicKey = getPublicKey(privateKey);
 
-          const encoder = createEncoder(TestContentTopic, publicKey);
+          const encoder = createEncoder({
+            contentTopic: TestContentTopic,
+            publicKey,
+          });
           const bytes = await encoder.toWire({ payload });
 
           const decoder = createDecoder(TestContentTopic, privateKey);
@@ -46,11 +49,11 @@ describe("Ecies Encryption", function () {
           const alicePublicKey = getPublicKey(alicePrivateKey);
           const bobPublicKey = getPublicKey(bobPrivateKey);
 
-          const encoder = createEncoder(
-            TestContentTopic,
-            bobPublicKey,
-            alicePrivateKey
-          );
+          const encoder = createEncoder({
+            contentTopic: TestContentTopic,
+            publicKey: bobPublicKey,
+            sigPrivKey: alicePrivateKey,
+          });
           const bytes = await encoder.toWire({ payload });
 
           const decoder = createDecoder(TestContentTopic, bobPrivateKey);
diff --git a/packages/message-encryption/src/ecies.ts b/packages/message-encryption/src/ecies.ts
index 1a79255df8..e1f2e5fe51 100644
--- a/packages/message-encryption/src/ecies.ts
+++ b/packages/message-encryption/src/ecies.ts
@@ -1,5 +1,6 @@
 import { Decoder as DecoderV0 } from "@waku/core/lib/message/version_0";
 import type {
+  EncoderOptions,
   IDecoder,
   IEncoder,
   IMessage,
@@ -63,6 +64,13 @@ export class Encoder implements IEncoder {
   }
 }
 
+export interface EciesEncoderOptions extends EncoderOptions {
+  /** The public key to encrypt the payload for. */
+  publicKey: Uint8Array;
+  /**  An optional private key to be used to sign the payload before encryption. */
+  sigPrivKey?: Uint8Array;
+}
+
 /**
  * Creates an encoder that encrypts messages using ECIES for the given public,
  * as defined in [26/WAKU2-PAYLOAD](https://rfc.vac.dev/spec/26/).
@@ -72,21 +80,15 @@ export class Encoder implements IEncoder {
  * pass to { @link @waku/interfaces.LightPush.push } or
  * { @link @waku/interfaces.Relay.send } to automatically encrypt
  * and encode outgoing messages.
- *
  * The payload can optionally be signed with the given private key as defined
  * in [26/WAKU2-PAYLOAD](https://rfc.vac.dev/spec/26/).
- *
- * @param contentTopic The content topic to set on outgoing messages.
- * @param publicKey The public key to encrypt the payload for.
- * @param sigPrivKey An optional private key to used to sign the payload before encryption.
- * @param ephemeral An optional flag to mark message as ephemeral, ie, not to be stored by Waku Store nodes.
  */
-export function createEncoder(
-  contentTopic: string,
-  publicKey: Uint8Array,
-  sigPrivKey?: Uint8Array,
-  ephemeral = false
-): Encoder {
+export function createEncoder({
+  contentTopic,
+  publicKey,
+  sigPrivKey,
+  ephemeral = false,
+}: EciesEncoderOptions): Encoder {
   return new Encoder(contentTopic, publicKey, sigPrivKey, ephemeral);
 }
 
diff --git a/packages/message-encryption/src/symmetric.spec.ts b/packages/message-encryption/src/symmetric.spec.ts
index 47219109fa..a12d68159b 100644
--- a/packages/message-encryption/src/symmetric.spec.ts
+++ b/packages/message-encryption/src/symmetric.spec.ts
@@ -13,7 +13,10 @@ describe("Symmetric Encryption", function () {
         fc.uint8Array({ minLength: 1 }),
         fc.uint8Array({ min: 1, minLength: 32, maxLength: 32 }),
         async (payload, symKey) => {
-          const encoder = createEncoder(TestContentTopic, symKey);
+          const encoder = createEncoder({
+            contentTopic: TestContentTopic,
+            symKey,
+          });
           const bytes = await encoder.toWire({ payload });
 
           const decoder = createDecoder(TestContentTopic, symKey);
@@ -41,7 +44,11 @@ describe("Symmetric Encryption", function () {
         async (payload, sigPrivKey, symKey) => {
           const sigPubKey = getPublicKey(sigPrivKey);
 
-          const encoder = createEncoder(TestContentTopic, symKey, sigPrivKey);
+          const encoder = createEncoder({
+            contentTopic: TestContentTopic,
+            symKey,
+            sigPrivKey,
+          });
           const bytes = await encoder.toWire({ payload });
 
           const decoder = createDecoder(TestContentTopic, symKey);
diff --git a/packages/message-encryption/src/symmetric.ts b/packages/message-encryption/src/symmetric.ts
index 1649f0f615..fbd3cf84e8 100644
--- a/packages/message-encryption/src/symmetric.ts
+++ b/packages/message-encryption/src/symmetric.ts
@@ -1,5 +1,6 @@
 import { Decoder as DecoderV0 } from "@waku/core/lib/message/version_0";
 import type {
+  EncoderOptions,
   IDecoder,
   IEncoder,
   IMessage,
@@ -61,6 +62,13 @@ export class Encoder implements IEncoder {
   }
 }
 
+export interface SymmetricEncoderOptions extends EncoderOptions {
+  /** The symmetric key to encrypt the payload with. */
+  symKey: Uint8Array;
+  /** An optional private key to be used to sign the payload before encryption. */
+  sigPrivKey?: Uint8Array;
+}
+
 /**
  * Creates an encoder that encrypts messages using symmetric encryption for the
  * given key, as defined in [26/WAKU2-PAYLOAD](https://rfc.vac.dev/spec/26/).
@@ -73,18 +81,13 @@ export class Encoder implements IEncoder {
  *
  * The payload can optionally be signed with the given private key as defined
  * in [26/WAKU2-PAYLOAD](https://rfc.vac.dev/spec/26/).
- *
- * @param contentTopic The content topic to set on outgoing messages.
- * @param symKey The symmetric key to encrypt the payload with.
- * @param sigPrivKey An optional private key to used to sign the payload before encryption.
- * @param ephemeral An optional flag to mark message as ephemeral, ie, not to be stored by Waku Store nodes.
  */
-export function createEncoder(
-  contentTopic: string,
-  symKey: Uint8Array,
-  sigPrivKey?: Uint8Array,
-  ephemeral = false
-): Encoder {
+export function createEncoder({
+  contentTopic,
+  symKey,
+  sigPrivKey,
+  ephemeral = false,
+}: SymmetricEncoderOptions): Encoder {
   return new Encoder(contentTopic, symKey, sigPrivKey, ephemeral);
 }
 
diff --git a/packages/tests/tests/ephemeral.node.spec.ts b/packages/tests/tests/ephemeral.node.spec.ts
index 2284d39e17..494eb1fefe 100644
--- a/packages/tests/tests/ephemeral.node.spec.ts
+++ b/packages/tests/tests/ephemeral.node.spec.ts
@@ -33,7 +33,9 @@ import {
 const log = debug("waku:test:ephemeral");
 
 const TestContentTopic = "/test/1/ephemeral/utf8";
-const TestEncoder = createEncoder(TestContentTopic);
+const TestEncoder = createEncoder({
+  contentTopic: TestContentTopic,
+});
 const TestDecoder = createDecoder(TestContentTopic);
 
 describe("Waku Message Ephemeral field", () => {
@@ -92,14 +94,20 @@ describe("Waku Message Ephemeral field", () => {
     const AsymContentTopic = "/test/1/ephemeral-asym/utf8";
     const SymContentTopic = "/test/1/ephemeral-sym/utf8";
 
-    const asymEncoder = eciesEncoder(
-      AsymContentTopic,
+    const asymEncoder = eciesEncoder({
+      contentTopic: AsymContentTopic,
       publicKey,
-      undefined,
-      true
-    );
-    const symEncoder = eciesEncoder(SymContentTopic, symKey, undefined, true);
-    const clearEncoder = createEncoder(TestContentTopic, true);
+      ephemeral: true,
+    });
+    const symEncoder = eciesEncoder({
+      contentTopic: SymContentTopic,
+      publicKey: symKey,
+      ephemeral: true,
+    });
+    const clearEncoder = createEncoder({
+      contentTopic: TestContentTopic,
+      ephemeral: true,
+    });
 
     const asymDecoder = eciesDecoder(AsymContentTopic, privateKey);
     const symDecoder = eciesDecoder(SymContentTopic, symKey);
@@ -159,7 +167,10 @@ describe("Waku Message Ephemeral field", () => {
   it("Ephemeral field is preserved - encoder v0", async function () {
     this.timeout(10000);
 
-    const ephemeralEncoder = createEncoder(TestContentTopic, true);
+    const ephemeralEncoder = createEncoder({
+      contentTopic: TestContentTopic,
+      ephemeral: true,
+    });
 
     const messages: DecodedMessage[] = [];
     const callback = (msg: DecodedMessage): void => {
@@ -199,13 +210,15 @@ describe("Waku Message Ephemeral field", () => {
 
     const symKey = generateSymmetricKey();
 
-    const ephemeralEncoder = symEncoder(
-      TestContentTopic,
+    const ephemeralEncoder = symEncoder({
+      contentTopic: TestContentTopic,
       symKey,
-      undefined,
-      true
-    );
-    const encoder = symEncoder(TestContentTopic, symKey);
+      ephemeral: true,
+    });
+    const encoder = symEncoder({
+      contentTopic: TestContentTopic,
+      symKey,
+    });
     const decoder = symDecoder(TestContentTopic, symKey);
 
     const messages: DecodedMessage[] = [];
@@ -247,13 +260,15 @@ describe("Waku Message Ephemeral field", () => {
     const privKey = generatePrivateKey();
     const pubKey = getPublicKey(privKey);
 
-    const ephemeralEncoder = eciesEncoder(
-      TestContentTopic,
-      pubKey,
-      undefined,
-      true
-    );
-    const encoder = eciesEncoder(TestContentTopic, pubKey);
+    const ephemeralEncoder = eciesEncoder({
+      contentTopic: TestContentTopic,
+      publicKey: pubKey,
+      ephemeral: true,
+    });
+    const encoder = eciesEncoder({
+      contentTopic: TestContentTopic,
+      publicKey: pubKey,
+    });
     const decoder = eciesDecoder(TestContentTopic, privKey);
 
     const messages: DecodedMessage[] = [];
diff --git a/packages/tests/tests/filter.node.spec.ts b/packages/tests/tests/filter.node.spec.ts
index 98ae599e83..a8a78c7cad 100644
--- a/packages/tests/tests/filter.node.spec.ts
+++ b/packages/tests/tests/filter.node.spec.ts
@@ -16,7 +16,7 @@ import { delay, makeLogFileName, NOISE_KEY_1, Nwaku } from "../src/index.js";
 const log = debug("waku:test");
 
 const TestContentTopic = "/test/1/waku-filter";
-const TestEncoder = createEncoder(TestContentTopic);
+const TestEncoder = createEncoder({ contentTopic: TestContentTopic });
 const TestDecoder = createDecoder(TestContentTopic);
 
 describe("Waku Filter", () => {
diff --git a/packages/tests/tests/light_push.node.spec.ts b/packages/tests/tests/light_push.node.spec.ts
index ba8bda1734..7f2832b8fe 100644
--- a/packages/tests/tests/light_push.node.spec.ts
+++ b/packages/tests/tests/light_push.node.spec.ts
@@ -17,7 +17,9 @@ import {
 const log = debug("waku:test:lightpush");
 
 const TestContentTopic = "/test/1/waku-light-push/utf8";
-const TestEncoder = createEncoder(TestContentTopic);
+const TestEncoder = createEncoder({
+  contentTopic: TestContentTopic,
+});
 
 describe("Waku Light Push [node only]", () => {
   let waku: LightNode;
diff --git a/packages/tests/tests/relay.node.spec.ts b/packages/tests/tests/relay.node.spec.ts
index 4c03cb247c..b47440bd15 100644
--- a/packages/tests/tests/relay.node.spec.ts
+++ b/packages/tests/tests/relay.node.spec.ts
@@ -37,7 +37,7 @@ import {
 const log = debug("waku:test");
 
 const TestContentTopic = "/test/1/waku-relay/utf8";
-const TestEncoder = createEncoder(TestContentTopic);
+const TestEncoder = createEncoder({ contentTopic: TestContentTopic });
 const TestDecoder = createDecoder(TestContentTopic);
 
 describe("Waku Relay [node only]", () => {
@@ -144,8 +144,8 @@ describe("Waku Relay [node only]", () => {
       const fooContentTopic = "foo";
       const barContentTopic = "bar";
 
-      const fooEncoder = createEncoder(fooContentTopic);
-      const barEncoder = createEncoder(barContentTopic);
+      const fooEncoder = createEncoder({ contentTopic: fooContentTopic });
+      const barEncoder = createEncoder({ contentTopic: barContentTopic });
 
       const fooDecoder = createDecoder(fooContentTopic);
       const barDecoder = createDecoder(barContentTopic);
@@ -193,8 +193,14 @@ describe("Waku Relay [node only]", () => {
       const symKey = generateSymmetricKey();
       const publicKey = getPublicKey(privateKey);
 
-      const eciesEncoder = createEciesEncoder(asymTopic, publicKey);
-      const symEncoder = createSymEncoder(symTopic, symKey);
+      const eciesEncoder = createEciesEncoder({
+        contentTopic: asymTopic,
+        publicKey,
+      });
+      const symEncoder = createSymEncoder({
+        contentTopic: symTopic,
+        symKey,
+      });
 
       const eciesDecoder = createEciesDecoder(asymTopic, privateKey);
       const symDecoder = createSymDecoder(symTopic, symKey);
@@ -240,7 +246,7 @@ describe("Waku Relay [node only]", () => {
           setTimeout(resolve, 500);
         }
       );
-      await waku1.relay.send(createEncoder(contentTopic), {
+      await waku1.relay.send(createEncoder({ contentTopic }), {
         payload: utf8ToBytes(messageText),
       });
 
diff --git a/packages/tests/tests/store.node.spec.ts b/packages/tests/tests/store.node.spec.ts
index acef44762a..785fedb596 100644
--- a/packages/tests/tests/store.node.spec.ts
+++ b/packages/tests/tests/store.node.spec.ts
@@ -34,7 +34,7 @@ import {
 const log = debug("waku:test:store");
 
 const TestContentTopic = "/test/1/waku-store/utf8";
-const TestEncoder = createEncoder(TestContentTopic);
+const TestEncoder = createEncoder({ contentTopic: TestContentTopic });
 const TestDecoder = createDecoder(TestContentTopic);
 
 describe("Waku Store", () => {
@@ -371,13 +371,19 @@ describe("Waku Store", () => {
     const symKey = generateSymmetricKey();
     const publicKey = getPublicKey(privateKey);
 
-    const eciesEncoder = createEciesEncoder(asymTopic, publicKey);
-    const symEncoder = createSymEncoder(symTopic, symKey);
+    const eciesEncoder = createEciesEncoder({
+      contentTopic: asymTopic,
+      publicKey,
+    });
+    const symEncoder = createSymEncoder({
+      contentTopic: symTopic,
+      symKey,
+    });
 
-    const otherEncoder = createEciesEncoder(
-      TestContentTopic,
-      getPublicKey(generatePrivateKey())
-    );
+    const otherEncoder = createEciesEncoder({
+      contentTopic: TestContentTopic,
+      publicKey: getPublicKey(generatePrivateKey()),
+    });
 
     const eciesDecoder = createEciesDecoder(asymTopic, privateKey);
     const symDecoder = createSymDecoder(symTopic, symKey);
diff --git a/packages/tests/tests/waku.node.spec.ts b/packages/tests/tests/waku.node.spec.ts
index ddc3b0abbb..a9b8854631 100644
--- a/packages/tests/tests/waku.node.spec.ts
+++ b/packages/tests/tests/waku.node.spec.ts
@@ -171,7 +171,10 @@ describe("Decryption Keys", () => {
     const symKey = generateSymmetricKey();
     const decoder = createDecoder(TestContentTopic, symKey);
 
-    const encoder = createEncoder(TestContentTopic, symKey);
+    const encoder = createEncoder({
+      contentTopic: TestContentTopic,
+      symKey,
+    });
     const messageText = "Message is encrypted";
     const messageTimestamp = new Date("1995-12-17T03:24:00");
     const message = {