[kafka] branch trunk updated (f770b49 -> 4fea3e4)
This is an automated email from the ASF dual-hosted git repository. cmccabe pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from f770b49 HOTFIX: Add comment to remind ordering restrictions on RegexSourceIntegrationTest (#7812) add 4fea3e4 KAFKA-9288: Do not allow the same object to be inserted multiple times into ImplicitLinkedHashCollection (#7809) No new revisions were added by this update. Summary of changes: .../common/utils/ImplicitLinkedHashCollection.java| 3 +++ .../utils/ImplicitLinkedHashCollectionTest.java | 13 + .../apache/kafka/message/MessageDataGenerator.java| 19 +-- .../org/apache/kafka/message/MessageGenerator.java| 3 +++ 4 files changed, 36 insertions(+), 2 deletions(-)
[kafka] branch trunk updated (39d68de -> f770b49)
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 39d68de MINOR: Simplify the timeout logic to handle protocol in Connect distributed system tests (#7806) add f770b49 HOTFIX: Add comment to remind ordering restrictions on RegexSourceIntegrationTest (#7812) No new revisions were added by this update. Summary of changes: .../apache/kafka/streams/integration/RegexSourceIntegrationTest.java | 4 1 file changed, 4 insertions(+)
[kafka] branch 2.3 updated: MINOR: Simplify the timeout logic to handle protocol in Connect distributed system tests (#7806)
This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a commit to branch 2.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.3 by this push:
new 8aaffd8 MINOR: Simplify the timeout logic to handle protocol in
Connect distributed system tests (#7806)
8aaffd8 is described below
commit 8aaffd8298e11a59d835095b0fc42fd59c9ff875
Author: Randall Hauch
AuthorDate: Tue Dec 10 12:30:49 2019 -0600
MINOR: Simplify the timeout logic to handle protocol in Connect
distributed system tests (#7806)
---
tests/kafkatest/tests/connect/connect_distributed_test.py | 14 ++
1 file changed, 2 insertions(+), 12 deletions(-)
diff --git a/tests/kafkatest/tests/connect/connect_distributed_test.py
b/tests/kafkatest/tests/connect/connect_distributed_test.py
index e50efb5..0dddeee 100644
--- a/tests/kafkatest/tests/connect/connect_distributed_test.py
+++ b/tests/kafkatest/tests/connect/connect_distributed_test.py
@@ -311,14 +311,9 @@ class ConnectDistributedTest(Test):
self.cc.restart()
-if connect_protocol == 'compatible':
-timeout_sec = 120
-else:
-timeout_sec = 70
-
# we should still be paused after restarting
for node in self.cc.nodes:
-wait_until(lambda: self.is_paused(self.source, node),
timeout_sec=timeout_sec,
+wait_until(lambda: self.is_paused(self.source, node),
timeout_sec=120,
err_msg="Failed to see connector startup in PAUSED
state")
@cluster(num_nodes=6)
@@ -350,14 +345,9 @@ class ConnectDistributedTest(Test):
# only processing new data.
self.cc.restart()
-if connect_protocol == 'compatible':
-timeout_sec = 150
-else:
-timeout_sec = 70
-
for node in self.cc.nodes:
node.account.ssh("echo -e -n " + repr(self.SECOND_INPUTS) + " >> "
+ self.INPUT_FILE)
-wait_until(lambda: self._validate_file_output(self.FIRST_INPUT_LIST +
self.SECOND_INPUT_LIST), timeout_sec=timeout_sec, err_msg="Sink output file
never converged to the same state as the input file")
+wait_until(lambda: self._validate_file_output(self.FIRST_INPUT_LIST +
self.SECOND_INPUT_LIST), timeout_sec=150, err_msg="Sink output file never
converged to the same state as the input file")
@cluster(num_nodes=6)
@matrix(clean=[True, False], connect_protocol=['compatible', 'eager'])
[kafka] branch trunk updated (8968cdd -> 39d68de)
This is an automated email from the ASF dual-hosted git repository. rhauch pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 8968cdd MINOR: Remove line with addAll since collection passed into constructor call. (#7807) add 39d68de MINOR: Simplify the timeout logic to handle protocol in Connect distributed system tests (#7806) No new revisions were added by this update. Summary of changes: tests/kafkatest/tests/connect/connect_distributed_test.py | 14 ++ 1 file changed, 2 insertions(+), 12 deletions(-)
[kafka] branch 2.4 updated (522b517 -> d087eae)
This is an automated email from the ASF dual-hosted git repository. rhauch pushed a change to branch 2.4 in repository https://gitbox.apache.org/repos/asf/kafka.git. from 522b517 KAFKA-9212; Ensure LeaderAndIsr state updated in controller context during reassignment (#7795) add d087eae MINOR: Simplify the timeout logic to handle protocol in Connect distributed system tests (#7806) No new revisions were added by this update. Summary of changes: tests/kafkatest/tests/connect/connect_distributed_test.py | 14 ++ 1 file changed, 2 insertions(+), 12 deletions(-)
[kafka] branch trunk updated (72df28f -> 8968cdd)
This is an automated email from the ASF dual-hosted git repository. bbejeck pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 72df28f KAFKA-9025: Add a option for path existence check in ZkSecurityMigrator add 8968cdd MINOR: Remove line with addAll since collection passed into constructor call. (#7807) No new revisions were added by this update. Summary of changes: .../java/org/apache/kafka/streams/kstream/internals/AbstractStream.java | 1 - 1 file changed, 1 deletion(-)
[kafka] branch trunk updated (48da0c6 -> 72df28f)
This is an automated email from the ASF dual-hosted git repository. manikumar pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git. from 48da0c6 port paragrpah from CP docs (#7808) add 72df28f KAFKA-9025: Add a option for path existence check in ZkSecurityMigrator No new revisions were added by this update. Summary of changes: .../scala/kafka/admin/ZkSecurityMigrator.scala | 22 +++--- 1 file changed, 19 insertions(+), 3 deletions(-)
