We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e4879b9 commit 26d0e0fCopy full SHA for 26d0e0f
1 file changed
tests/producer.test.js
@@ -185,9 +185,7 @@ const adminUrl = 'http://localhost:8080';
185
// 2. Create a producer with the custom message router
186
const producer = await client.createProducer({
187
topic: partitionedTopic, // Note: For producer, use the base topic name
188
- messageRouter: (message, topicMetadata) =>
189
- // Always route to the target partition for this test
190
- targetPartition,
+ messageRouter: (message, topicMetadata) => targetPartition,
191
messageRoutingMode: 'CustomPartition',
192
});
193
0 commit comments