From c759e2dd619a345b2939c6f7ed22a24bb87de41a Mon Sep 17 00:00:00 2001 From: tanvigour Date: Wed, 23 Mar 2022 09:18:25 -0400 Subject: [PATCH 01/12] run IT test for long values Signed-off-by: tanvigour --- .../java/io/dapr/it/pubsub/http/PubSubIT.java | 60 +++++++++++++++++++ .../it/pubsub/http/SubscriberController.java | 14 +++++ 2 files changed, 74 insertions(+) diff --git a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java index 35e77ce5ee..c179e7be28 100644 --- a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java +++ b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java @@ -66,6 +66,8 @@ public class PubSubIT extends BaseIT { // Topic to test binary data private static final String BINARY_TOPIC_NAME = "binarytopic"; + private static final String LONG_TOPIC_NAME = "testinglongvalues"; + /** * Parameters for this test. * Param #1: useGrpc. @@ -402,6 +404,55 @@ public void testPubSubTTLMetadata() throws Exception { daprRun.stop(); } + @Test + public void testlongValues() throws Exception { + final DaprRun daprRun = closeLater(startDaprApp( + this.getClass().getSimpleName(), + SubscriberService.SUCCESS_MESSAGE, + SubscriberService.class, + true, + 60000)); + // At this point, it is guaranteed that the service above is running and all ports being listened to. + if (this.useGrpc) { + daprRun.switchToGRPC(); + } else { + daprRun.switchToHTTP(); + } + + ConverLong value = new ConverLong(); + value.setVal(590518626939830271L); + try (DaprClient client = new DaprClientBuilder().build()) { + for (int i = 0; i < NUM_MESSAGES; i++) { + //Publishing messages + client.publishEvent( + PUBSUB_NAME, + LONG_TOPIC_NAME, + value, + Collections.singletonMap(Metadata.TTL_IN_SECONDS, "1")).block(); + + try { + Thread.sleep((long) (1000 * Math.random())); + } catch (InterruptedException e) { + e.printStackTrace(); + Thread.currentThread().interrupt(); + return; + } + } + } + + try (DaprClient client = new DaprClientBuilder().build()) { + callWithRetry(() -> { + System.out.println("Checking results for topic " + LONG_TOPIC_NAME); + final List messages = client.invokeMethod( + daprRun.getAppName(), + "messages/testinglongvalues", + null, + HttpExtension.GET, CLOUD_EVENT_LIST_TYPE_REF).block(); + assertEquals(590518626939830271L, messages.get(0).getData()); + }, 2000); + } + } + public static class MyObject { private String id; @@ -413,4 +464,13 @@ public void setId(String id) { this.id = id; } } + + public static class ConverLong { + public Long value; + + public void setVal(Long value) { + this.value = value; + } + } + } diff --git a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/SubscriberController.java b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/SubscriberController.java index 38bca7730a..c680cb58b5 100644 --- a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/SubscriberController.java +++ b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/SubscriberController.java @@ -115,6 +115,20 @@ public Mono handleMessageTTLTopic(@RequestBody(required = false) CloudEven }); } + @Topic(name = "testinglongvalues", pubsubName = "messagebus") + @PostMapping(path = "/testinglongvalues") + public Mono handleMessageLongValues(@RequestBody(required = false) CloudEvent cloudEvent) { + return Mono.fromRunnable(() -> { + try { + Long message = cloudEvent.getData().value; + System.out.println("Subscriber got: " + message); + messagesByTopic.compute("testinglongvalues", merge(cloudEvent)); + } catch (Exception e) { + throw new RuntimeException(e); + } + }); + } + private BiFunction>, List>> merge(final CloudEvent item) { return (key, value) -> { final List> list = value == null ? new ArrayList<>() : value; From afc31e6ea6d7fd1993e6a877f3009462bff855c8 Mon Sep 17 00:00:00 2001 From: tanvigour Date: Wed, 23 Mar 2022 11:22:15 -0400 Subject: [PATCH 02/12] Fix the class name Signed-off-by: tanvigour --- .../test/java/io/dapr/it/pubsub/http/SubscriberController.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/SubscriberController.java b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/SubscriberController.java index c680cb58b5..10ffc16704 100644 --- a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/SubscriberController.java +++ b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/SubscriberController.java @@ -117,7 +117,7 @@ public Mono handleMessageTTLTopic(@RequestBody(required = false) CloudEven @Topic(name = "testinglongvalues", pubsubName = "messagebus") @PostMapping(path = "/testinglongvalues") - public Mono handleMessageLongValues(@RequestBody(required = false) CloudEvent cloudEvent) { + public Mono handleMessageLongValues(@RequestBody(required = false) CloudEvent cloudEvent) { return Mono.fromRunnable(() -> { try { Long message = cloudEvent.getData().value; From fa8f19d4975b72dc1294f7aab752c39bedc5f5ca Mon Sep 17 00:00:00 2001 From: tanvigour Date: Wed, 23 Mar 2022 12:35:56 -0400 Subject: [PATCH 03/12] assert for all messages and fix class name Signed-off-by: tanvigour --- .../src/test/java/io/dapr/it/pubsub/http/PubSubIT.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java index c179e7be28..204168ccff 100644 --- a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java +++ b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java @@ -419,7 +419,7 @@ public void testlongValues() throws Exception { daprRun.switchToHTTP(); } - ConverLong value = new ConverLong(); + ConvertToLong value = new ConvertToLong(); value.setVal(590518626939830271L); try (DaprClient client = new DaprClientBuilder().build()) { for (int i = 0; i < NUM_MESSAGES; i++) { @@ -448,7 +448,9 @@ public void testlongValues() throws Exception { "messages/testinglongvalues", null, HttpExtension.GET, CLOUD_EVENT_LIST_TYPE_REF).block(); - assertEquals(590518626939830271L, messages.get(0).getData()); + for (int i = 0; i < NUM_MESSAGES; i++) { + assertEquals(590518626939830271L, messages.get(i).getData()); + } }, 2000); } } @@ -465,7 +467,7 @@ public void setId(String id) { } } - public static class ConverLong { + public static class ConvertToLong { public Long value; public void setVal(Long value) { From a31516f24052b921248027453a2340b1d3a0e0af Mon Sep 17 00:00:00 2001 From: tanvigour Date: Thu, 24 Mar 2022 21:28:09 -0400 Subject: [PATCH 04/12] test for Long.MAX_VALUE Signed-off-by: tanvigour --- sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java index 204168ccff..de8309de69 100644 --- a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java +++ b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java @@ -420,7 +420,7 @@ public void testlongValues() throws Exception { } ConvertToLong value = new ConvertToLong(); - value.setVal(590518626939830271L); + value.setVal(Long.MAX_VALUE); try (DaprClient client = new DaprClientBuilder().build()) { for (int i = 0; i < NUM_MESSAGES; i++) { //Publishing messages @@ -449,7 +449,7 @@ public void testlongValues() throws Exception { null, HttpExtension.GET, CLOUD_EVENT_LIST_TYPE_REF).block(); for (int i = 0; i < NUM_MESSAGES; i++) { - assertEquals(590518626939830271L, messages.get(i).getData()); + assertEquals(Long.MAX_VALUE, messages.get(i).getData()); } }, 2000); } From acd4a3212c122426493d13f2ad0a85aa42e7c63b Mon Sep 17 00:00:00 2001 From: tanvigour Date: Fri, 25 Mar 2022 09:12:32 -0400 Subject: [PATCH 05/12] revert back long number and print Signed-off-by: tanvigour --- sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java index de8309de69..085de9d537 100644 --- a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java +++ b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java @@ -420,7 +420,7 @@ public void testlongValues() throws Exception { } ConvertToLong value = new ConvertToLong(); - value.setVal(Long.MAX_VALUE); + value.setVal(590518626939830271L); try (DaprClient client = new DaprClientBuilder().build()) { for (int i = 0; i < NUM_MESSAGES; i++) { //Publishing messages @@ -449,7 +449,8 @@ public void testlongValues() throws Exception { null, HttpExtension.GET, CLOUD_EVENT_LIST_TYPE_REF).block(); for (int i = 0; i < NUM_MESSAGES; i++) { - assertEquals(Long.MAX_VALUE, messages.get(i).getData()); + System.out.println(messages.get(i).getData()) + assertEquals(590518626939830271L, messages.get(i).getData()); } }, 2000); } From bf825b1e6d4cbfb03bd7ccaa40378edab939d923 Mon Sep 17 00:00:00 2001 From: tanvigour Date: Fri, 25 Mar 2022 13:13:49 -0400 Subject: [PATCH 06/12] fix the typo Signed-off-by: tanvigour --- sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java index 085de9d537..01bd4e2124 100644 --- a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java +++ b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java @@ -449,7 +449,7 @@ public void testlongValues() throws Exception { null, HttpExtension.GET, CLOUD_EVENT_LIST_TYPE_REF).block(); for (int i = 0; i < NUM_MESSAGES; i++) { - System.out.println(messages.get(i).getData()) + System.out.println(messages.get(i).getData()); assertEquals(590518626939830271L, messages.get(i).getData()); } }, 2000); From ba294513c161c1e9f7880ee5e626b5fb3c698a4a Mon Sep 17 00:00:00 2001 From: tanvigour Date: Fri, 25 Mar 2022 13:57:02 -0400 Subject: [PATCH 07/12] update the latest dapr commit in workflow files Signed-off-by: tanvigour --- .github/workflows/build.yml | 2 +- .github/workflows/validate.yml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml index 915127e226..a74e8e2098 100644 --- a/.github/workflows/build.yml +++ b/.github/workflows/build.yml @@ -29,7 +29,7 @@ jobs: DAPR_RUNTIME_VER: 1.6.0-rc.2 DAPR_INSTALL_URL: https://raw.githubusercontent.com/dapr/cli/v1.6.0-rc.1/install/install.sh DAPR_CLI_REF: - DAPR_REF: 5a307f3deaa1b322f7945179adad0403de80eb7e + DAPR_REF: 4cf499448ef6ee87c83db6a11b84e83237e92665 steps: - uses: actions/checkout@v3 - name: Set up OpenJDK ${{ env.JDK_VER }} diff --git a/.github/workflows/validate.yml b/.github/workflows/validate.yml index 67f8cd1069..ce686db14b 100644 --- a/.github/workflows/validate.yml +++ b/.github/workflows/validate.yml @@ -40,7 +40,7 @@ jobs: DAPR_RUNTIME_VER: 1.6.0-rc.2 DAPR_INSTALL_URL: https://raw.githubusercontent.com/dapr/cli/v1.6.0-rc.1/install/install.sh DAPR_CLI_REF: - DAPR_REF: 5a307f3deaa1b322f7945179adad0403de80eb7e + DAPR_REF: 4cf499448ef6ee87c83db6a11b84e83237e92665 steps: - uses: actions/checkout@v3 - name: Set up OpenJDK ${{ env.JDK_VER }} From 4ba48595ee39c45f63f88b1fa7e13170bc736ebd Mon Sep 17 00:00:00 2001 From: tanvigour Date: Fri, 25 Mar 2022 15:16:41 -0400 Subject: [PATCH 08/12] log some more data to debug Signed-off-by: tanvigour --- sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java index 01bd4e2124..e4576aeb2a 100644 --- a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java +++ b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java @@ -449,7 +449,7 @@ public void testlongValues() throws Exception { null, HttpExtension.GET, CLOUD_EVENT_LIST_TYPE_REF).block(); for (int i = 0; i < NUM_MESSAGES; i++) { - System.out.println(messages.get(i).getData()); + System.out.println("The long value received!!!",messages.get(i).getData()); assertEquals(590518626939830271L, messages.get(i).getData()); } }, 2000); From 93a594304124f1c001cc5d0583e0de5104d8b81f Mon Sep 17 00:00:00 2001 From: tanvigour Date: Fri, 25 Mar 2022 16:08:10 -0400 Subject: [PATCH 09/12] debug Signed-off-by: tanvigour --- sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java index e4576aeb2a..130eb668a2 100644 --- a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java +++ b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java @@ -449,7 +449,7 @@ public void testlongValues() throws Exception { null, HttpExtension.GET, CLOUD_EVENT_LIST_TYPE_REF).block(); for (int i = 0; i < NUM_MESSAGES; i++) { - System.out.println("The long value received!!!",messages.get(i).getData()); + System.out.println("The long value received!!! " +messages.get(i).getData()); assertEquals(590518626939830271L, messages.get(i).getData()); } }, 2000); From 09c52afc2b9e036e58ca33815cf10606d00f05da Mon Sep 17 00:00:00 2001 From: tanvigour Date: Fri, 25 Mar 2022 17:12:05 -0400 Subject: [PATCH 10/12] get the value from messages Signed-off-by: tanvigour --- sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java index 130eb668a2..e32bc92055 100644 --- a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java +++ b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java @@ -449,8 +449,8 @@ public void testlongValues() throws Exception { null, HttpExtension.GET, CLOUD_EVENT_LIST_TYPE_REF).block(); for (int i = 0; i < NUM_MESSAGES; i++) { - System.out.println("The long value received!!! " +messages.get(i).getData()); - assertEquals(590518626939830271L, messages.get(i).getData()); + System.out.println("The long value received!!! " +messages.get(i).getData().value); + assertEquals(590518626939830271L, messages.get(i).getData().value); } }, 2000); } From 7fe8c65752e47929e2ffaa33e1a1728fc2dad0b0 Mon Sep 17 00:00:00 2001 From: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com> Date: Sat, 26 Mar 2022 12:12:34 +0530 Subject: [PATCH 11/12] fix long values assert Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com> --- .../java/io/dapr/it/pubsub/http/PubSubIT.java | 58 +++++++++++++++---- .../it/pubsub/http/SubscriberController.java | 2 +- 2 files changed, 49 insertions(+), 11 deletions(-) diff --git a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java index e32bc92055..111f37e9fd 100644 --- a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java +++ b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java @@ -26,6 +26,7 @@ import io.dapr.serializer.DaprObjectSerializer; import io.dapr.utils.TypeRef; import org.junit.After; +import org.junit.Assert; import org.junit.Test; import org.junit.runner.RunWith; import org.junit.runners.Parameterized; @@ -35,8 +36,13 @@ import java.util.Arrays; import java.util.Collection; import java.util.Collections; +import java.util.HashSet; +import java.util.Iterator; import java.util.LinkedHashMap; import java.util.List; +import java.util.Objects; +import java.util.Random; +import java.util.Set; import static io.dapr.it.Retry.callWithRetry; import static io.dapr.it.TestUtils.assertThrowsDaprException; @@ -51,6 +57,7 @@ public class PubSubIT extends BaseIT { private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper(); private static final TypeRef> CLOUD_EVENT_LIST_TYPE_REF = new TypeRef<>() {}; + private static final TypeRef>> CLOUD_EVENT_LONG_LIST_TYPE_REF = new TypeRef<>() {}; private static final TypeRef>> CLOUD_EVENT_MYOBJECT_LIST_TYPE_REF = new TypeRef<>() {}; //Number of messages to be sent: 10 @@ -405,7 +412,7 @@ public void testPubSubTTLMetadata() throws Exception { } @Test - public void testlongValues() throws Exception { + public void testLongValues() throws Exception { final DaprRun daprRun = closeLater(startDaprApp( this.getClass().getSimpleName(), SubscriberService.SUCCESS_MESSAGE, @@ -419,10 +426,21 @@ public void testlongValues() throws Exception { daprRun.switchToHTTP(); } - ConvertToLong value = new ConvertToLong(); - value.setVal(590518626939830271L); + Random random = new Random(590518626939830271L); + Set values = new HashSet<>(); + values.add(new ConvertToLong().setVal(590518626939830271L)); + ConvertToLong val; + for (int i = 0; i < NUM_MESSAGES - 1; i++) { + do { + val = new ConvertToLong().setVal(random.nextLong()); + } while (values.contains(val)); + values.add(val); + } + Iterator valuesIt = values.iterator(); try (DaprClient client = new DaprClientBuilder().build()) { for (int i = 0; i < NUM_MESSAGES; i++) { + ConvertToLong value = valuesIt.next(); + System.out.println("The long value sent " + value.getValue()); //Publishing messages client.publishEvent( PUBSUB_NAME, @@ -440,19 +458,21 @@ public void testlongValues() throws Exception { } } + Set actual = new HashSet<>(); try (DaprClient client = new DaprClientBuilder().build()) { callWithRetry(() -> { System.out.println("Checking results for topic " + LONG_TOPIC_NAME); - final List messages = client.invokeMethod( + final List> messages = client.invokeMethod( daprRun.getAppName(), "messages/testinglongvalues", null, - HttpExtension.GET, CLOUD_EVENT_LIST_TYPE_REF).block(); - for (int i = 0; i < NUM_MESSAGES; i++) { - System.out.println("The long value received!!! " +messages.get(i).getData().value); - assertEquals(590518626939830271L, messages.get(i).getData().value); + HttpExtension.GET, CLOUD_EVENT_LONG_LIST_TYPE_REF).block(); + Assert.assertNotNull(messages); + for (CloudEvent message : messages) { + actual.add(message.getData()); } }, 2000); + Assert.assertEquals(values, actual); } } @@ -469,10 +489,28 @@ public void setId(String id) { } public static class ConvertToLong { - public Long value; + private Long value; - public void setVal(Long value) { + public ConvertToLong setVal(Long value) { this.value = value; + return this; + } + + public Long getValue() { + return value; + } + + @Override + public boolean equals(Object o) { + if (this == o) return true; + if (o == null || getClass() != o.getClass()) return false; + ConvertToLong that = (ConvertToLong) o; + return Objects.equals(value, that.value); + } + + @Override + public int hashCode() { + return Objects.hash(value); } } diff --git a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/SubscriberController.java b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/SubscriberController.java index 10ffc16704..726e8990bc 100644 --- a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/SubscriberController.java +++ b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/SubscriberController.java @@ -120,7 +120,7 @@ public Mono handleMessageTTLTopic(@RequestBody(required = false) CloudEven public Mono handleMessageLongValues(@RequestBody(required = false) CloudEvent cloudEvent) { return Mono.fromRunnable(() -> { try { - Long message = cloudEvent.getData().value; + Long message = cloudEvent.getData().getValue(); System.out.println("Subscriber got: " + message); messagesByTopic.compute("testinglongvalues", merge(cloudEvent)); } catch (Exception e) { From d826a39c162d8c3c21913c3671a0bb0d7fd08cfc Mon Sep 17 00:00:00 2001 From: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com> Date: Thu, 31 Mar 2022 13:10:05 +0530 Subject: [PATCH 12/12] increasing TTL Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com> --- sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java index 8025a5b071..b7d5f65837 100644 --- a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java +++ b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java @@ -448,7 +448,7 @@ public void testLongValues() throws Exception { PUBSUB_NAME, LONG_TOPIC_NAME, value, - Collections.singletonMap(Metadata.TTL_IN_SECONDS, "1")).block(); + Collections.singletonMap(Metadata.TTL_IN_SECONDS, "30")).block(); try { Thread.sleep((long) (1000 * Math.random()));