This is an automated email from the ASF dual-hosted git repository.
manikumar pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new e647bdcee56 MINOR : Fix parantheses in console_consumer.py and
console_share_consumer.py (#20552)
e647bdcee56 is described below
commit e647bdcee5684154dcb569b758b0846628f4694e
Author: Shivsundar R <[email protected]>
AuthorDate: Thu Sep 18 02:23:12 2025 -0400
MINOR : Fix parantheses in console_consumer.py and
console_share_consumer.py (#20552)
*What*
We were missing a parantheses when we invoked a method
`supports_formatter_property()`. This would mean we would get the object
not call the function.
PR fixes this by including parantheses and invoking the actual function.
Reviewers: Manikumar Reddy <[email protected]>
---
tests/kafkatest/services/console_consumer.py | 2 +-
tests/kafkatest/services/console_share_consumer.py | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/tests/kafkatest/services/console_consumer.py
b/tests/kafkatest/services/console_consumer.py
index 0f95a0f7c79..467e7c3247c 100644
--- a/tests/kafkatest/services/console_consumer.py
+++ b/tests/kafkatest/services/console_consumer.py
@@ -179,7 +179,7 @@ class ConsoleConsumer(KafkaPathResolverMixin, JmxMixin,
BackgroundThreadService)
# This will be added in the properties file instead
cmd += " --timeout-ms %s" % self.consumer_timeout_ms
- formatter_property_arg = "--formatter-property" if
version.supports_formatter_property else "--property"
+ formatter_property_arg = "--formatter-property" if
version.supports_formatter_property() else "--property"
if self.print_timestamp:
cmd += " %s print.timestamp=true" % formatter_property_arg
diff --git a/tests/kafkatest/services/console_share_consumer.py
b/tests/kafkatest/services/console_share_consumer.py
index 2d7da50fe30..0761acddcc8 100644
--- a/tests/kafkatest/services/console_share_consumer.py
+++ b/tests/kafkatest/services/console_share_consumer.py
@@ -167,7 +167,7 @@ class ConsoleShareConsumer(KafkaPathResolverMixin,
JmxMixin, BackgroundThreadSer
# This will be added in the properties file instead
cmd += " --timeout-ms %s" % self.share_consumer_timeout_ms
- formatter_property_arg = "--formatter-property" if
version.supports_formatter_property else "--property"
+ formatter_property_arg = "--formatter-property" if
version.supports_formatter_property() else "--property"
if self.print_timestamp:
cmd += " %s print.timestamp=true" % formatter_property_arg
