Re: [PR] KAKFA-13410 Generate snapshot prior to metadata.version upgrade [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #12177: URL: https://github.com/apache/kafka/pull/12177#issuecomment-2562119649 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] KAFKA-13716 Added the DeleteRecordsCommandTest to test the CLI front end of the D… [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #12167: URL: https://github.com/apache/kafka/pull/12167#issuecomment-2562119642 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] KAFKA-13864: provide the construct interceptor for KafkaProducer and KafkaConsumer [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #12125: URL: https://github.com/apache/kafka/pull/12125#issuecomment-2562119632 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] Update README.md [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #12115: URL: https://github.com/apache/kafka/pull/12115#issuecomment-2562119621 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] MINOR: Adding client Base64 serializer and deserializer [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #12095: URL: https://github.com/apache/kafka/pull/12095#issuecomment-2562119618 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] Minor:Fix method scalaDoc in DelayedFetch.scala [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #12078: URL: https://github.com/apache/kafka/pull/12078#issuecomment-2562119593 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] KAFKA-13620: Use different metric name for KRaft SocketServer [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #12093: URL: https://github.com/apache/kafka/pull/12093#issuecomment-2562119606 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] KAFKA-13838: Improve the poll method of ConsumerNetworkClient [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #12070: URL: https://github.com/apache/kafka/pull/12070#issuecomment-2562119574 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] KAFKA-13768: Don't mark expired batches as unresolved when using transactional producer [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #11961: URL: https://github.com/apache/kafka/pull/11961#issuecomment-2562119493 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] MINOR:Fix test in ReplicaManagerTest.scala [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #12056: URL: https://github.com/apache/kafka/pull/12056#issuecomment-2562119560 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] KAFKA-12319: Change calculation of window size used to calculate `Rate` [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #12045: URL: https://github.com/apache/kafka/pull/12045#issuecomment-2562119551 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] KAFKA-12738: implement exponential backoff for tasks [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #12044: URL: https://github.com/apache/kafka/pull/12044#issuecomment-2562119537 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] KAFKA-13818: Add generation to consumer assignor logs [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #12020: URL: https://github.com/apache/kafka/pull/12020#issuecomment-2562119517 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] KAFKA-13810 Document behavior of KafkaProducer.flush() w.r.t callbacks [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #12042: URL: https://github.com/apache/kafka/pull/12042#issuecomment-2562119528 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] KIP-829: (console consumer) add print.topic property [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #12012: URL: https://github.com/apache/kafka/pull/12012#issuecomment-2562119507 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] KAFKA-13705: CoreUtils.swallow uses logging parameter instead of Logger [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #11841: URL: https://github.com/apache/kafka/pull/11841#issuecomment-2562119409 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] MINOR: Unify the log output of JaasContext.defaultContext [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #11919: URL: https://github.com/apache/kafka/pull/11919#issuecomment-2562119469 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] KAFKA-12908: Load raft snapshot heuristic (WIP) [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #11934: URL: https://github.com/apache/kafka/pull/11934#issuecomment-2562119486 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] [DO NOT MERGE] POC: type-safe processValues [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #11854: URL: https://github.com/apache/kafka/pull/11854#issuecomment-2562119416 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] MINOR: Improve the readability of the DelegationTokenManager code [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #11930: URL: https://github.com/apache/kafka/pull/11930#issuecomment-2562119477 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] KAFKA-13463: Make pause behavior consistent between cooperative and eager protocols [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #11911: URL: https://github.com/apache/kafka/pull/11911#issuecomment-2562119452 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] KAFKA-13667: Make listeners mandatory in kraft mode [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #11889: URL: https://github.com/apache/kafka/pull/11889#issuecomment-2562119443 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] Repair how often index entries are generated [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #11856: URL: https://github.com/apache/kafka/pull/11856#issuecomment-2562119432 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] MINOR: Do not throw exception when InterBrokerSecurityProtocolProp value is empty string [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #11831: URL: https://github.com/apache/kafka/pull/11831#issuecomment-2562119392 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] MINOR: Optimize the generateFieldToString method of MessageDataGenerator [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #11819: URL: https://github.com/apache/kafka/pull/11819#issuecomment-2562119381 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] KAFKA-13691: Rename target topic to custom name [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #11803: URL: https://github.com/apache/kafka/pull/11803#issuecomment-2562119369 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] MINOR: Optimize StorageTool#formatCommand, remove return result [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #11795: URL: https://github.com/apache/kafka/pull/11795#issuecomment-2562119352 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] toString pattern change like ProducerRecord.java [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #9090: URL: https://github.com/apache/kafka/pull/9090#issuecomment-2562118925 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] Fix trogdor coordinator client [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #9113: URL: https://github.com/apache/kafka/pull/9113#issuecomment-2562118944 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] Fix trogdor coordinator client [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] closed pull request #9113: Fix trogdor coordinator client URL: https://github.com/apache/kafka/pull/9113 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

Re: [PR] toString pattern change like ProducerRecord.java [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] closed pull request #9090: toString pattern change like ProducerRecord.java URL: https://github.com/apache/kafka/pull/9090 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the spe

Re: [PR] MINOR: Preserve Kafka exception from RebalanceListener [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] closed pull request #9084: MINOR: Preserve Kafka exception from RebalanceListener URL: https://github.com/apache/kafka/pull/9084 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

Re: [PR] MINOR: Preserve Kafka exception from RebalanceListener [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #9084: URL: https://github.com/apache/kafka/pull/9084#issuecomment-2562118906 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-10298: replace abstract Windows with a proper interface [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] closed pull request #9031: KAFKA-10298: replace abstract Windows with a proper interface URL: https://github.com/apache/kafka/pull/9031 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

Re: [PR] KAFKA-18277: fix e2e network_degrade_test [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #18247: URL: https://github.com/apache/kafka/pull/18247#issuecomment-2562118833 A label of 'needs-attention' was automatically added to this PR in order to raise the attention of the committers. Once this issue has been triaged, the `triage` label s

Re: [PR] Add connect-mirror-maker.bat for Windows platform [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] closed pull request #9019: Add connect-mirror-maker.bat for Windows platform URL: https://github.com/apache/kafka/pull/9019 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the sp

Re: [PR] KAFKA-10298: replace abstract Windows with a proper interface [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #9031: URL: https://github.com/apache/kafka/pull/9031#issuecomment-2562118881 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-8582 [WIP] Add ability to handle late messages in streams-aggregation [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] closed pull request #9017: KAFKA-8582 [WIP] Add ability to handle late messages in streams-aggregation URL: https://github.com/apache/kafka/pull/9017 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] Add connect-mirror-maker.bat for Windows platform [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #9019: URL: https://github.com/apache/kafka/pull/9019#issuecomment-2562118843 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-8582 [WIP] Add ability to handle late messages in streams-aggregation [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #9017: URL: https://github.com/apache/kafka/pull/9017#issuecomment-2562118818 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to r

Re: [PR] KAFKA-17421: Add IT for ConsumerRecord#leaderEpoch [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #18254: URL: https://github.com/apache/kafka/pull/18254#issuecomment-2562118816 A label of 'needs-attention' was automatically added to this PR in order to raise the attention of the committers. Once this issue has been triaged, the `triage` label s

Re: [PR] KAFKA-18299: Move connect data classes into a dedicated module [kafka]

2024-12-25 Thread via GitHub
github-actions[bot] commented on PR #18256: URL: https://github.com/apache/kafka/pull/18256#issuecomment-2562118804 A label of 'needs-attention' was automatically added to this PR in order to raise the attention of the committers. Once this issue has been triaged, the `triage` label s

Re: [PR] KAFKA-10532: Handle state updater failed tasks [kafka]

2024-12-25 Thread via GitHub
fonsdant commented on PR #17761: URL: https://github.com/apache/kafka/pull/17761#issuecomment-2562084069 @eduwercamacaro, spotlessJavaCheck has failed. We need to apply its code suggestions to fix the build. -- This is an automated message from the Apache Git Service. To respond to the me

Re: [PR] KAFKA-17607: Add CI step to verify LICENSE-binary [kafka]

2024-12-25 Thread via GitHub
xijiu commented on code in PR #18299: URL: https://github.com/apache/kafka/pull/18299#discussion_r1897535052 ## build.gradle: ## @@ -1328,6 +1328,43 @@ project(':core') { duplicatesStrategy 'exclude' } + task libLicenseCheck(dependsOn: 'releaseTarGz', type: Copy) { R

Re: [PR] KAFKA-17607: Add CI step to verify LICENSE-binary [kafka]

2024-12-25 Thread via GitHub
xijiu commented on PR #18299: URL: https://github.com/apache/kafka/pull/18299#issuecomment-2562055945 @mumrah @m1a2stI have fixed it, PTAL -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

Re: [PR] KAFKA-18111 Add kafka logo [kafka]

2024-12-25 Thread via GitHub
swikarpat commented on PR #18066: URL: https://github.com/apache/kafka/pull/18066#issuecomment-2561962646 > Hi @swikarpat > > Thanks for the patch. > > This logo doesn’t feel very balanced. Have you considered using the following version? > > > > https://kafka.a

Re: [PR] [WIP] KAFKA-18082: Add 0.11, 1.0, 1.1 and 2.0 to consumer upgrade e2e [kafka]

2024-12-25 Thread via GitHub
ijuma commented on PR #18193: URL: https://github.com/apache/kafka/pull/18193#issuecomment-2561940300 On a related note, I do think Kafka Streams should also trim their upgrade matrix, but I think they'll have to wait to 5.0 for that. -- This is an automated message from the Apache Git Se

Re: [PR] [WIP] KAFKA-18082: Add 0.11, 1.0, 1.1 and 2.0 to consumer upgrade e2e [kafka]

2024-12-25 Thread via GitHub
ijuma commented on PR #18193: URL: https://github.com/apache/kafka/pull/18193#issuecomment-2561939527 @chia7712 Kafka Streams is different - it has to handle its own state during upgrades (kind of like the broker). The same is not true for regular clients. Maintaining tests like this one is

Re: [PR] KAFKA-18274: Failed to restart controller in testing due to closed socket channel [1/2] [kafka]

2024-12-25 Thread via GitHub
chia7712 merged PR #18310: URL: https://github.com/apache/kafka/pull/18310 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache

Re: [PR] KAFKA-10730: KafkaApis#handleProduceRequest should use auto-generated protocol [kafka]

2024-12-25 Thread via GitHub
FrankYang0529 commented on PR #18216: URL: https://github.com/apache/kafka/pull/18216#issuecomment-2561878815 Hi @ijuma, thanks for the review. The good part is that we eliminate data conversion time. We don't need to convert data from `PartitionResponse` to `ProduceResponseData.PartitionPr

[jira] [Commented] (KAFKA-17171) Add test cases for `STATIC_BROKER_CONFIG`in kraft mode

2024-12-25 Thread TengYao Chi (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908198#comment-17908198 ] TengYao Chi commented on KAFKA-17171: - It seems that this issue is pending for a lon

[jira] [Assigned] (KAFKA-17171) Add test cases for `STATIC_BROKER_CONFIG`in kraft mode

2024-12-25 Thread TengYao Chi (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TengYao Chi reassigned KAFKA-17171: --- Assignee: TengYao Chi (was: Ming-Yen Chung) > Add test cases for `STATIC_BROKER_CONFIG`in

Re: [PR] KAFKA-18295: Remove deprecated function Partitioner#onNewBatch [kafka]

2024-12-25 Thread via GitHub
FrankYang0529 commented on code in PR #18282: URL: https://github.com/apache/kafka/pull/18282#discussion_r1897338025 ## clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java: ## @@ -1020,9 +1011,6 @@ private Future doSend(ProducerRecord record, Callback call

Re: [PR] KAFKA-17607: Add CI step to verify LICENSE-binary [kafka]

2024-12-25 Thread via GitHub
m1a2st commented on code in PR #18299: URL: https://github.com/apache/kafka/pull/18299#discussion_r1897336398 ## .github/workflows/build.yml: ## @@ -143,6 +143,9 @@ jobs: find ./site-docs/generated -type f -exec grep -L "." {} \; >&2 exit 1 f

[jira] [Updated] (KAFKA-18349) Consider add typing hint for system test

2024-12-25 Thread TaiJuWu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TaiJuWu updated KAFKA-18349: Description: Our system test is written by Python but it is not included typing hint right now. There is

[jira] [Created] (KAFKA-18349) Consider add typing hint for system test

2024-12-25 Thread TaiJuWu (Jira)
TaiJuWu created KAFKA-18349: --- Summary: Consider add typing hint for system test Key: KAFKA-18349 URL: https://issues.apache.org/jira/browse/KAFKA-18349 Project: Kafka Issue Type: Test R

Re: [PR] KAFKA-18243 Loggers breaks the use of root logger after migrating to log4j2 [kafka]

2024-12-25 Thread via GitHub
chia7712 commented on code in PR #18185: URL: https://github.com/apache/kafka/pull/18185#discussion_r1897309318 ## tests/kafkatest/tests/connect/connect_distributed_test.py: ## @@ -563,7 +563,14 @@ def test_dynamic_logging(self, metadata_quorum): # have been discarded

Re: [PR] MINOR: fix TopicCommand warning message.format.version output [kafka]

2024-12-25 Thread via GitHub
chia7712 commented on PR #18311: URL: https://github.com/apache/kafka/pull/18311#issuecomment-2561823345 I have backported this PR to the 3.8 branch only ([commit ab5490147537d9d4a581a6fde44dc43a27d6eb7c](https://github.com/apache/kafka/commit/ab5490147537d9d4a581a6fde44dc43a27d6eb7c)) sinc

Re: [PR] KAFKA-18142 switch Kafka's Gradle build shadow plugin to `com.gradleup.shadow` (and upgrade plugin version) [kafka]

2024-12-25 Thread via GitHub
dejan2609 commented on code in PR #18018: URL: https://github.com/apache/kafka/pull/18018#discussion_r1897305837 ## build.gradle: ## @@ -353,17 +353,14 @@ subprojects { if (!shouldPublishWithShadow) { from components.java } else { -

Re: [PR] MINOR: fix TopicCommand warning message.format.version output [kafka]

2024-12-25 Thread via GitHub
chia7712 merged PR #18311: URL: https://github.com/apache/kafka/pull/18311 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache

Re: [PR] MINOR: fix TopicCommand warning message.format.version output [kafka]

2024-12-25 Thread via GitHub
chia7712 commented on PR #18311: URL: https://github.com/apache/kafka/pull/18311#issuecomment-2561819684 the failed tests pass on my local, and I think they are unrelated to this PR -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

Re: [PR] MINOR: Replace enum name with state name to fix `ConsumerGroupDescription.state()` [kafka]

2024-12-25 Thread via GitHub
TaiJuWu commented on PR #18315: URL: https://github.com/apache/kafka/pull/18315#issuecomment-2561785198 I notice there is some error make our CI hanging bit I think it is not related this PR. https://github.com/apache/kafka/actions/runs/12486596513/job/34847313711?pr=18315#step:11:1301

[jira] [Assigned] (KAFKA-18348) Remove the deprecated MockConsumer#setException

2024-12-25 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reassigned KAFKA-18348: -- Assignee: kangning.li (was: Chia-Ping Tsai) > Remove the deprecated MockConsumer#set