We should not honour duplicated context within a kafka interceptor

vert-x3 · Oct 4, 2024 · 9bce37e · 9bce37e
1 parent 5737a69
commit 9bce37e
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/src/test/java/io/vertx/kafka/client/tests/ProducerTest.java b/src/test/java/io/vertx/kafka/client/tests/ProducerTest.java
@@ -199,13 +199,10 @@ public void testInterceptor(TestContext testCtx) throws Exception {
  producer.exceptionHandler(testCtx::fail);
  ProducerRecord<String, String> record = new ProducerRecord<>(topicName, 0, "key-0", "value-0");
  ContextInternal ctx = (ContextInternal) vertx.getOrCreateContext();
- ContextInternal dup = ctx.duplicate();
  Async async = testCtx.async();
- dup.runOnContext(v1 -> {
+ ctx.runOnContext(v1 -> {
  TestInterceptor.list.clear();
  producer.write(record).onComplete(testCtx.asyncAssertSuccess(v2 -> {
- testCtx.assertEquals(1, TestInterceptor.list.size());
- testCtx.assertEquals(dup, TestInterceptor.list.get(0));
  async.complete();
  }));
  });