You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2018/02/20 17:48:14 UTC
[kafka] branch 1.1 updated: MINOR: Fix streams broker compatibility
test.
This is an automated email from the ASF dual-hosted git repository.
damianguy pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.1 by this push:
new fcdc4dd MINOR: Fix streams broker compatibility test.
fcdc4dd is described below
commit fcdc4dd0cf1ee5cad9dcab131b060dce05019c51
Author: Damian Guy <da...@gmail.com>
AuthorDate: Tue Feb 20 17:46:05 2018 +0000
MINOR: Fix streams broker compatibility test.
Change the string in the test condition to the one that is logged
Author: Damian Guy <da...@gmail.com>
Reviewers: Bill Bejeck <bi...@confluent.io>, Guozhang Wang <wa...@gmail.com>
Closes #4599 from dguy/broker-compatibility
(cherry picked from commit 57059d40223d6284d1b2c9f3034b30f6bd61c44f)
Signed-off-by: Damian Guy <da...@gmail.com>
---
tests/kafkatest/tests/streams/streams_broker_compatibility_test.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py b/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py
index 1eb46ef..b00b9bb 100644
--- a/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py
+++ b/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py
@@ -67,9 +67,9 @@ class StreamsBrokerCompatibility(Test):
processor.node.account.ssh(processor.start_cmd(processor.node))
with processor.node.account.monitor_log(processor.STDERR_FILE) as monitor:
- monitor.wait_until('FATAL: An unexpected exception org.apache.kafka.common.errors.UnsupportedVersionException: The broker does not support LIST_OFFSETS ',
+ monitor.wait_until("Exception in thread \"main\" org.apache.kafka.common.errors.UnsupportedVersionException: The broker does not support LIST_OFFSETS ",
timeout_sec=60,
- err_msg="Never saw 'FATAL: An unexpected exception org.apache.kafka.common.errors.UnsupportedVersionException: The broker does not support LIST_OFFSETS ' error message " + str(processor.node.account))
+ err_msg="Exception in thread \"main\" org.apache.kafka.common.errors.UnsupportedVersionException: The broker does not support LIST_OFFSETS " + str(processor.node.account))
self.kafka.stop()
--
To stop receiving notification emails like this one, please contact
damianguy@apache.org.