fvaleri commented on code in PR #12159:
URL: https://github.com/apache/kafka/pull/12159#discussion_r890306188
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -603,23 +603,18 @@ private void verifyChannelExpiry(KafkaChannel channel)
throws Excep
fvaleri commented on code in PR #12159:
URL: https://github.com/apache/kafka/pull/12159#discussion_r890306188
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -603,23 +603,18 @@ private void verifyChannelExpiry(KafkaChannel channel)
throws Excep
fvaleri commented on code in PR #12159:
URL: https://github.com/apache/kafka/pull/12159#discussion_r890306188
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -603,23 +603,18 @@ private void verifyChannelExpiry(KafkaChannel channel)
throws Excep
fvaleri commented on code in PR #12159:
URL: https://github.com/apache/kafka/pull/12159#discussion_r890306188
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -603,23 +603,18 @@ private void verifyChannelExpiry(KafkaChannel channel)
throws Excep
fvaleri commented on code in PR #12159:
URL: https://github.com/apache/kafka/pull/12159#discussion_r890306188
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -603,23 +603,18 @@ private void verifyChannelExpiry(KafkaChannel channel)
throws Excep
fvaleri commented on code in PR #12159:
URL: https://github.com/apache/kafka/pull/12159#discussion_r890306188
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -603,23 +603,18 @@ private void verifyChannelExpiry(KafkaChannel channel)
throws Excep
fvaleri commented on code in PR #12159:
URL: https://github.com/apache/kafka/pull/12159#discussion_r890306188
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -603,23 +603,18 @@ private void verifyChannelExpiry(KafkaChannel channel)
throws Excep
fvaleri commented on code in PR #12159:
URL: https://github.com/apache/kafka/pull/12159#discussion_r890306188
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -603,23 +603,18 @@ private void verifyChannelExpiry(KafkaChannel channel)
throws Excep
fvaleri commented on code in PR #12159:
URL: https://github.com/apache/kafka/pull/12159#discussion_r890306188
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -603,23 +603,18 @@ private void verifyChannelExpiry(KafkaChannel channel)
throws Excep
fvaleri commented on code in PR #12159:
URL: https://github.com/apache/kafka/pull/12159#discussion_r881564718
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -1030,10 +1025,7 @@ private void blockingConnect(String node) throws
IOException {
fvaleri commented on code in PR #12159:
URL: https://github.com/apache/kafka/pull/12159#discussion_r881564718
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -1030,10 +1025,7 @@ private void blockingConnect(String node) throws
IOException {
fvaleri commented on code in PR #12159:
URL: https://github.com/apache/kafka/pull/12159#discussion_r881564718
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -1030,10 +1025,7 @@ private void blockingConnect(String node) throws
IOException {
fvaleri commented on code in PR #12159:
URL: https://github.com/apache/kafka/pull/12159#discussion_r881564718
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -1030,10 +1025,7 @@ private void blockingConnect(String node) throws
IOException {
fvaleri commented on code in PR #12159:
URL: https://github.com/apache/kafka/pull/12159#discussion_r881564718
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -1030,10 +1025,7 @@ private void blockingConnect(String node) throws
IOException {
fvaleri commented on code in PR #12159:
URL: https://github.com/apache/kafka/pull/12159#discussion_r881564718
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -1030,10 +1025,7 @@ private void blockingConnect(String node) throws
IOException {
fvaleri commented on code in PR #12159:
URL: https://github.com/apache/kafka/pull/12159#discussion_r881564718
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -1030,10 +1025,7 @@ private void blockingConnect(String node) throws
IOException {
fvaleri commented on code in PR #12159:
URL: https://github.com/apache/kafka/pull/12159#discussion_r881556147
##
clients/src/test/java/org/apache/kafka/common/network/NetworkTestUtils.java:
##
@@ -87,13 +88,23 @@ public static void checkClientConnection(Selector selector,
Strin
17 matches
Mail list logo