Skip to content

KAFKA-10402: Upgrade system tests to python3#9196

Merged
guozhangwang merged 25 commits intoapache:trunkfrom
nizhikov:KAFKA-10402
Oct 7, 2020
Merged

KAFKA-10402: Upgrade system tests to python3#9196
guozhangwang merged 25 commits intoapache:trunkfrom
nizhikov:KAFKA-10402

Conversation

@nizhikov
Copy link
Copy Markdown
Contributor

For now, Kafka system tests use python2 which is outdated and not supported.
This PR upgrades python to the third version.

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

@nizhikov nizhikov changed the title KAFKA-10402: Upgrade system tests to python3 [WIP] KAFKA-10402: Upgrade system tests to python3 Aug 18, 2020
Copy link
Copy Markdown

@ivandasch ivandasch left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Hi, I have some remarks, that should be resolved.

Comment thread tests/kafkatest/benchmarks/core/benchmark_test.py Outdated
Comment thread tests/kafkatest/services/monitor/http.py Outdated
Comment thread tests/kafkatest/services/monitor/http.py Outdated
Comment thread tests/kafkatest/services/performance/producer_performance.py Outdated
Comment thread tests/kafkatest/services/security/security_config.py Outdated
Comment thread tests/kafkatest/tests/connect/connect_distributed_test.py Outdated
Comment thread tests/kafkatest/tests/end_to_end.py Outdated
Comment thread tests/kafkatest/tests/streams/streams_broker_bounce_test.py Outdated
Comment thread tests/kafkatest/tests/verifiable_consumer_test.py Outdated
Comment thread tests/kafkatest/version.py Outdated
Comment thread tests/kafkatest/version.py Outdated
Comment thread tests/kafkatest/services/performance/producer_performance.py Outdated
Comment thread tests/kafkatest/services/monitor/http.py Outdated
Comment thread tests/kafkatest/tests/connect/connect_distributed_test.py Outdated
Comment thread tests/kafkatest/tests/connect/connect_distributed_test.py Outdated
Comment thread tests/kafkatest/version.py Outdated
Comment thread tests/kafkatest/services/verifiable_consumer.py Outdated
Comment thread tests/kafkatest/tests/verifiable_consumer_test.py Outdated
Comment thread tests/kafkatest/utils/__init__.py Outdated
@nizhikov nizhikov changed the title [WIP] KAFKA-10402: Upgrade system tests to python3 KAFKA-10402: Upgrade system tests to python3 Aug 24, 2020
Copy link
Copy Markdown
Contributor

@edenhill edenhill left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Good stuff!

Comment thread tests/docker/Dockerfile Outdated
Comment thread tests/docker/Dockerfile Outdated
Comment thread tests/kafkatest/tests/core/network_degrade_test.py Outdated
Comment thread tests/kafkatest/tests/core/replica_scale_test.py Outdated
Comment thread tests/kafkatest/tests/streams/streams_broker_bounce_test.py Outdated
Comment thread tests/docker/Dockerfile Outdated
@nizhikov nizhikov changed the title KAFKA-10402: Upgrade system tests to python3 [DO NOT MERGE] KAFKA-10402: Upgrade system tests to python3 Sep 4, 2020
@guozhangwang
Copy link
Copy Markdown
Contributor

@nizhikov could you rebase your PR on trunk so I can trigger a system test run to verify?

@guozhangwang
Copy link
Copy Markdown
Contributor

test this please

@guozhangwang
Copy link
Copy Markdown
Contributor

@nizhikov
Copy link
Copy Markdown
Contributor Author

nizhikov commented Sep 20, 2020

Hello, @guozhangwang

  1. You can find the latest test results on my environment in the ticket

  2. I don't have access(error 404) to your run - https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4180/ Can you, please, provide me access or link to the results of the run.

@nizhikov
Copy link
Copy Markdown
Contributor Author

Hello, @guozhangwang

2 tests that fails in this branch fails in the trunk too.
I fixed them in #9312

Please, take a look.

  File "/opt/kafka-dev/tests/kafkatest/tests/streams/streams_static_membership_test.py", line 88, in test_rolling_bounces_will_not_trigger_rebalance_under_static_membership
    generation = int(generation)
ValueError: invalid literal for int() with base 10: "Generation{generationId=5,memberId='consumer-A-3-a9a925b2-2875-4756-8649-49f516b6cae1',protocol='stream'}\n"
  File "/opt/kafka-dev/tests/kafkatest/tests/streams/streams_upgrade_test.py", line 511, in do_rolling_bounce
    processor_generation = self.extract_highest_generation(processor_found)
  File "/opt/kafka-dev/tests/kafkatest/tests/streams/streams_upgrade_test.py", line 533, in extract_highest_generation
    return int(found_generations[-1])
ValueError: invalid literal for int() with base 10: "Generation{generationId=6,memberId='StreamsUpgradeTest-8a6ac110-1c65-40eb-af05-8bee270f1701-StreamThread-1-consumer-207de872-6588-407a-8485-101a19ba2bf0',protocol='stream'}\n"

@nizhikov
Copy link
Copy Markdown
Contributor Author

Hello, @guozhangwang

Do you have system tests run results?
Can you, please, show me it.

@edenhill
Copy link
Copy Markdown
Contributor

Excerpt from the Jenkins test run:

SESSION REPORT (ALL TESTS)
ducktape version: 0.7.9
session_id:       2020-09-20--001
run time:         400 minutes 59.682 seconds
tests run:        606
passed:           432
failed:           4
ignored:          170

.....

test_id:    kafkatest.tests.streams.streams_named_repartition_topic_test.StreamsNamedRepartitionTopicTest.test_upgrade_topology_with_named_repartition_topic
status:     FAIL
run time:   1 minute 59.478 seconds


    Server connection dropped: 
Traceback (most recent call last):
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/ducktape-0.7.9-py2.7.egg/ducktape/tests/runner_client.py", line 134, in run
    data = self.run_test()
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/ducktape-0.7.9-py2.7.egg/ducktape/tests/runner_client.py", line 192, in run_test
    return self.test_context.function(self.test)
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/tests/kafkatest/tests/streams/streams_named_repartition_topic_test.py", line 77, in test_upgrade_topology_with_named_repartition_topic
    verify_running(processor, 'UPDATED Topology')
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/tests/kafkatest/tests/streams/utils/util.py", line 18, in verify_running
    processor.start()
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/ducktape-0.7.9-py2.7.egg/ducktape/services/service.py", line 234, in start
    self.start_node(node)
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/tests/kafkatest/services/streams.py", line 308, in start_node
    node.account.create_file(self.CONFIG_FILE, prop_file)
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/ducktape-0.7.9-py2.7.egg/ducktape/cluster/remoteaccount.py", line 588, in create_file
    with self.sftp_client.open(path, "w") as f:
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/paramiko-2.6.0-py2.7.egg/paramiko/sftp_client.py", line 372, in open
    t, msg = self._request(CMD_OPEN, filename, imode, attrblock)
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/paramiko-2.6.0-py2.7.egg/paramiko/sftp_client.py", line 813, in _request
    return self._read_response(num)
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/paramiko-2.6.0-py2.7.egg/paramiko/sftp_client.py", line 845, in _read_response
    raise SSHException("Server connection dropped: {}".format(e))
SSHException: Server connection dropped: 


......


test_id:    kafkatest.tests.streams.streams_static_membership_test.StreamsStaticMembershipTest.test_rolling_bounces_will_not_trigger_rebalance_under_static_membership
status:     FAIL
run time:   2 minutes 2.957 seconds


    invalid literal for int() with base 10: "Generation{generationId=5,memberId='consumer-A-3-bf3848e8-0d61-4637-81d0-de9f42c95ddf',protocol='stream'} "
Traceback (most recent call last):
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/ducktape-0.7.9-py2.7.egg/ducktape/tests/runner_client.py", line 134, in run
    data = self.run_test()
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/ducktape-0.7.9-py2.7.egg/ducktape/tests/runner_client.py", line 192, in run_test
    return self.test_context.function(self.test)
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/tests/kafkatest/tests/streams/streams_static_membership_test.py", line 86, in test_rolling_bounces_will_not_trigger_rebalance_under_static_membership
    generation = int(generation)
ValueError: invalid literal for int() with base 10: "Generation{generationId=5,memberId='consumer-A-3-bf3848e8-0d61-4637-81d0-de9f42c95ddf',protocol='stream'} "

.......

test_id:    kafkatest.tests.streams.streams_upgrade_test.StreamsUpgradeTest.test_version_probing_upgrade
status:     FAIL
run time:   1 minute 22.265 seconds


    invalid literal for int() with base 10: "Generation{generationId=7,memberId='StreamsUpgradeTest-0cf34158-7f97-4699-8952-acec9013c8e0-StreamThread-1-consumer-5d625105-c972-4545-9967-b85e14274d0d',protocol='stream'} "
Traceback (most recent call last):
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/ducktape-0.7.9-py2.7.egg/ducktape/tests/runner_client.py", line 134, in run
    data = self.run_test()
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/ducktape-0.7.9-py2.7.egg/ducktape/tests/runner_client.py", line 192, in run_test
    return self.test_context.function(self.test)
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/tests/kafkatest/tests/streams/streams_upgrade_test.py", line 273, in test_version_probing_upgrade
    current_generation = self.do_rolling_bounce(p, counter, current_generation)
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/tests/kafkatest/tests/streams/streams_upgrade_test.py", line 511, in do_rolling_bounce
    processor_generation = self.extract_highest_generation(processor_found)
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/tests/kafkatest/tests/streams/streams_upgrade_test.py", line 533, in extract_highest_generation
    return int(found_generations[-1])
ValueError: invalid literal for int() with base 10: "Generation{generationId=7,memberId='StreamsUpgradeTest-0cf34158-7f97-4699-8952-acec9013c8e0-StreamThread-1-consumer-5d625105-c972-4545-9967-b85e14274d0d',protocol='stream'} "


......

test_id:    kafkatest.tests.connect.connect_distributed_test.ConnectDistributedTest.test_bounce.connect_protocol=compatible.clean=True
status:     FAIL
run time:   6 minutes 14.893 seconds


    Failed to see connector transition to the RUNNING state
Traceback (most recent call last):
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/ducktape-0.7.9-py2.7.egg/ducktape/tests/runner_client.py", line 134, in run
    data = self.run_test()
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/ducktape-0.7.9-py2.7.egg/ducktape/tests/runner_client.py", line 192, in run_test
    return self.test_context.function(self.test)
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/ducktape-0.7.9-py2.7.egg/ducktape/mark/_mark.py", line 429, in wrapper
    return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs)
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/tests/kafkatest/tests/connect/connect_distributed_test.py", line 405, in test_bounce
    err_msg="Failed to see connector transition to the RUNNING state")
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/ducktape-0.7.9-py2.7.egg/ducktape/utils/util.py", line 41, in wait_until
    raise TimeoutError(err_msg() if callable(err_msg) else err_msg)
TimeoutError: Failed to see connector transition to the RUNNING state


The IGNORED tests seems to be mostly kafkatest.tests.streams.streams_upgrade_test.StreamsUpgradeTest.test_upgrade_downgrade_brokers..

@nizhikov
Copy link
Copy Markdown
Contributor Author

kafkatest.tests.streams.streams_static_membership_test.StreamsStaticMembershipTest.test_rolling_bounces_will_not_trigger_rebalance_under_static_membership
kafkatest.tests.streams.streams_upgrade_test.StreamsUpgradeTest.test_version_probing_upgrade

These two tests are fixed by #9312

AFAIK two others are failing in the trunk too. Is it correct?

@nizhikov
Copy link
Copy Markdown
Contributor Author

@edenhill

The IGNORED tests seems to be mostly kafkatest.tests.streams.streams_upgrade_test.StreamsUpgradeTest.test_upgrade_downgrade_brokers..

Are they ignored in the trunk?

@guozhangwang
Copy link
Copy Markdown
Contributor

#9312 has been merged it. Could you rebase this PR so I can re-trigger the system test suite?

As for the ignored test cases, they are known issues and we can keep them "ignored" for now.

@nizhikov
Copy link
Copy Markdown
Contributor Author

@guozhangwang

Could you rebase this PR

done.

@guozhangwang
Copy link
Copy Markdown
Contributor

@nizhikov
Copy link
Copy Markdown
Contributor Author

Hello, @guozhangwang

Can you, please, share the results of the tests run?

@guozhangwang
Copy link
Copy Markdown
Contributor

Only one test failed this time, and honestly I'm not sure if it is related to your PR or not, here you go:


Module: kafkatest.tests.streams.streams_broker_down_resilience_test Class:  StreamsBrokerDownResilience Method: test_streams_resilient_to_broker_down | This test validates that Streams is resilient to a broker     being down longer than specified timeouts in configs | 3 minutes 56.586 seconds
-- | -- | --


[INFO  - 2020-09-25 06:34:38,507 - kafka - bootstrap_servers - lineno:1007]: Bootstrap client port is: 9092
[INFO  - 2020-09-25 06:36:38,847 - runner_client - log - lineno:240]: RunnerClient: kafkatest.tests.streams.streams_broker_down_resilience_test.StreamsBrokerDownResilience.test_streams_resilient_to_broker_down: FAIL: Never saw output 'Discovered group coordinator' on ubuntu@worker3
Traceback (most recent call last):
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/ducktape-0.7.9-py2.7.egg/ducktape/tests/runner_client.py", line 134, in run
    data = self.run_test()
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/ducktape-0.7.9-py2.7.egg/ducktape/tests/runner_client.py", line 192, in run_test
    return self.test_context.function(self.test)
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py", line 68, in test_streams_resilient_to_broker_down
    err_msg=("Never saw output '%s' on " % self.connected_message) + str(processor.node.account))
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/ducktape-0.7.9-py2.7.egg/ducktape/cluster/remoteaccount.py", line 708, in wait_until
    allow_fail=True) == 0, **kwargs)
  File "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python2.7/site-packages/ducktape-0.7.9-py2.7.egg/ducktape/utils/util.py", line 41, in wait_until
    raise TimeoutError(err_msg() if callable(err_msg) else err_msg)
TimeoutError: Never saw output 'Discovered group coordinator' on ubuntu@worker3

@nizhikov
Copy link
Copy Markdown
Contributor Author

Hello, @guozhangwang

I ran a failed test locally and it passes.
Test passed in my previous runs, also.
You can take a look at the report I share in ticket - https://issues.apache.org/jira/secure/attachment/13010366/report.txt
Guess, the test is flaky.

Can you, please, advice me, what is the next step?
For now, this PR based on ducktape master branch.

Do we need a ducktape release for it?
I don't receive much feedback from ducktape maintainers - confluentinc/ducktape#245

[1:15:45]~/work/kafka/tests:[KAFKA-10402]$ ./docker/run_tests.sh

> Configure project :
Building project 'core' with Scala version 2.13.3
Building project 'streams-scala' with Scala version 2.13.3

Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.6/userguide/command_line_interface.html#sec:command_line_warnings

BUILD SUCCESSFUL in 2s
119 actionable tasks: 3 executed, 116 up-to-date
docker exec ducker01 bash -c "cd /opt/kafka-dev && ducktape --cluster-file /opt/kafka-dev/tests/docker/build/cluster.json  ./tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py::StreamsBrokerDownResilience.test_streams_resilient_to_broker_down"
[INFO:2020-09-25 15:15:53,329]: starting test run with session id 2020-09-25--001...
[INFO:2020-09-25 15:15:53,329]: running 1 tests...
[INFO:2020-09-25 15:15:53,330]: Triggering test 1 of 1...
[INFO:2020-09-25 15:15:53,360]: RunnerClient: Loading test {'directory': '/opt/kafka-dev/tests/kafkatest/tests/streams', 'file_name': 'streams_broker_down_resilience_test.py', 'cls_name': 'StreamsBrokerDownResilience', 'method_name': 'test_streams_resilient_to_broker_down', 'injected_args': None}
[INFO:2020-09-25 15:15:53,386]: RunnerClient: kafkatest.tests.streams.streams_broker_down_resilience_test.StreamsBrokerDownResilience.test_streams_resilient_to_broker_down: Setting up...
[INFO:2020-09-25 15:15:59,198]: RunnerClient: kafkatest.tests.streams.streams_broker_down_resilience_test.StreamsBrokerDownResilience.test_streams_resilient_to_broker_down: Running...
[INFO:2020-09-25 15:18:05,820]: RunnerClient: kafkatest.tests.streams.streams_broker_down_resilience_test.StreamsBrokerDownResilience.test_streams_resilient_to_broker_down: PASS
[INFO:2020-09-25 15:18:05,821]: RunnerClient: kafkatest.tests.streams.streams_broker_down_resilience_test.StreamsBrokerDownResilience.test_streams_resilient_to_broker_down: Tearing down...
[INFO:2020-09-25 15:18:18,192]: RunnerClient: kafkatest.tests.streams.streams_broker_down_resilience_test.StreamsBrokerDownResilience.test_streams_resilient_to_broker_down: Summary: 
[INFO:2020-09-25 15:18:18,194]: RunnerClient: kafkatest.tests.streams.streams_broker_down_resilience_test.StreamsBrokerDownResilience.test_streams_resilient_to_broker_down: Data: None
================================================================================
SESSION REPORT (ALL TESTS)
ducktape version: 0.8.0
session_id:       2020-09-25--001
run time:         2 minutes 24.908 seconds
tests run:        1
passed:           1
failed:           0
ignored:          0
================================================================================
test_id:    kafkatest.tests.streams.streams_broker_down_resilience_test.StreamsBrokerDownResilience.test_streams_resilient_to_broker_down
status:     PASS
run time:   2 minutes 24.806 seconds
--------------------------------------------------------------------------------

@guozhangwang
Copy link
Copy Markdown
Contributor

Let me re-trigger the test and if the test passed we can merge it

@guozhangwang
Copy link
Copy Markdown
Contributor

@guozhangwang guozhangwang changed the title [DO NOT MERGE] KAFKA-10402: Upgrade system tests to python3 KAFKA-10402: Upgrade system tests to python3 Sep 27, 2020
@guozhangwang
Copy link
Copy Markdown
Contributor

The test tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py runs 5 times without failing. I think this is good to go.

@nizhikov
Copy link
Copy Markdown
Contributor Author

@guozhangwang Great news! Thanks for the help!

@guozhangwang
Copy link
Copy Markdown
Contributor

cc @cmccabe @vvcephei @mimaison for a final look and merge.

Copy link
Copy Markdown
Member

@mimaison mimaison left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The changes look fine, thanks for driving this important upgrade

@nizhikov
Copy link
Copy Markdown
Contributor Author

Hello, @guozhangwang , @mimaison

The only thing we need to have perfect merge is ducktape release that contains python3 fixes.
Can we go with the current PR, which points to ducktape master and works just fine, and switch to the specific release once it becomes available?

@edenhill
Copy link
Copy Markdown
Contributor

We'll want to use a released version of ducktape to get stable tests. I'm working on getting a ducktape release out.

@nizhikov
Copy link
Copy Markdown
Contributor Author

@edenhill Thanks for the help! Appreciate it

@nizhikov
Copy link
Copy Markdown
Contributor Author

nizhikov commented Oct 7, 2020

Hello @guozhangwang , @mimaison

This PR ready to be merged.
Can you, please, do it?

@guozhangwang guozhangwang merged commit 4e65030 into apache:trunk Oct 7, 2020
@guozhangwang
Copy link
Copy Markdown
Contributor

Merged to trunk, kudos to @nizhikov for the contribution!

javierfreire pushed a commit to javierfreire/kafka that referenced this pull request Oct 8, 2020
For now, Kafka system tests use python2 which is outdated and not supported.
This PR upgrades python to the third version.

Reviewers: Ivan Daschinskiy, Mickael Maison <mickael.maison@gmail.com>, Magnus Edenhill <magnus@edenhill.se>, Guozhang Wang <wangguoz@gmail.com>
ijuma added a commit to confluentinc/kafka that referenced this pull request Oct 8, 2020
* commit '2804257fe221f37e5098bd': (67 commits)
  KAFKA-10562: Properly invoke new StateStoreContext init (apache#9388)
  MINOR: trivial cleanups, javadoc errors, omitted StateStore tests, etc. (apache#8130)
  KAFKA-10564: only process non-empty task directories when internally cleaning obsolete state stores (apache#9373)
  KAFKA-9274: fix incorrect default value for `task.timeout.ms` config (apache#9385)
  KAFKA-10362: When resuming Streams active task with EOS, the checkpoint file is deleted (apache#9247)
  KAFKA-10028: Implement write path for feature versioning system (KIP-584) (apache#9001)
  KAFKA-10402: Upgrade system tests to python3 (apache#9196)
  KAFKA-10186; Abort transaction with pending data with TransactionAbortedException (apache#9280)
  MINOR: Remove `TargetVoters` from `DescribeQuorum` (apache#9376)
  Revert "KAFKA-10469: Resolve logger levels hierarchically (apache#9266)"
  MINOR: Don't publish javadocs for raft module (apache#9336)
  KAFKA-9929: fix: add missing default implementations (apache#9321)
  KAFKA-10188: Prevent SinkTask::preCommit from being called after SinkTask::stop (apache#8910)
  KAFKA-10338; Support PEM format for SSL key and trust stores (KIP-651) (apache#9345)
  KAFKA-10527; Voters should not reinitialize as leader in same epoch (apache#9348)
  MINOR: Refactor unit tests around RocksDBConfigSetter (apache#9358)
  KAFKA-6733: Printing additional ConsumerRecord fields in DefaultMessageFormatter (apache#9099)
  MINOR: Annotate test BlockingConnectorTest as integration test (apache#9379)
  MINOR: Fix failing test due to KAFKA-10556 PR (apache#9372)
  KAFKA-10439: Connect's Values to parse BigInteger as Decimal with zero scale. (apache#9320)
  ...
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

5 participants