[
https://issues.apache.org/jira/browse/KAFKA-8084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8084:
---
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> Flaky Test
> DescribeConsumerG
[
https://issues.apache.org/jira/browse/KAFKA-8138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8138:
---
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> Flaky Test PlaintextConsumerTes
[
https://issues.apache.org/jira/browse/KAFKA-8075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211365#comment-17211365
]
Bill Bejeck commented on KAFKA-8075:
No failures reported for this in over a year. As
[
https://issues.apache.org/jira/browse/KAFKA-8075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8075.
Resolution: Fixed
> Flaky Test
> GroupAuthorizerIntegrationTest#testTransactionalProducerTopicAuth
[
https://issues.apache.org/jira/browse/KAFKA-8075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8075:
---
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> Flaky Test
> GroupAuthorizerIn
[
https://issues.apache.org/jira/browse/KAFKA-8087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211366#comment-17211366
]
Bill Bejeck commented on KAFKA-8087:
No failures reported for this in over a year. As
[
https://issues.apache.org/jira/browse/KAFKA-8077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8077:
---
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> Flaky Test AdminClientIntegrati
[
https://issues.apache.org/jira/browse/KAFKA-8077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8077.
Resolution: Fixed
> Flaky Test AdminClientIntegrationTest#testConsumeAfterDeleteRecords
> -
[
https://issues.apache.org/jira/browse/KAFKA-8087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8087:
---
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> Flaky Test PlaintextConsumerTes
[
https://issues.apache.org/jira/browse/KAFKA-8077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211367#comment-17211367
]
Bill Bejeck commented on KAFKA-8077:
No failures reported for this in over a year. As
[
https://issues.apache.org/jira/browse/KAFKA-8087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8087.
Resolution: Fixed
> Flaky Test PlaintextConsumerTest#testConsumingWithNullGroupId
> ---
[
https://issues.apache.org/jira/browse/KAFKA-8113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8113:
---
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> Flaky Test ListOffsetsRequestTe
[
https://issues.apache.org/jira/browse/KAFKA-8113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8113.
Resolution: Fixed
> Flaky Test ListOffsetsRequestTest#testResponseIncludesLeaderEpoch
> ---
[
https://issues.apache.org/jira/browse/KAFKA-8113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211369#comment-17211369
]
Bill Bejeck commented on KAFKA-8113:
No failures reported for this in over a year. As
[
https://issues.apache.org/jira/browse/KAFKA-7988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-7988:
---
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> Flaky Test DynamicBrokerReconfi
[
https://issues.apache.org/jira/browse/KAFKA-7988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-7988.
Resolution: Fixed
> Flaky Test DynamicBrokerReconfigurationTest#testThreadPoolResize
>
[
https://issues.apache.org/jira/browse/KAFKA-8079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8079.
Resolution: Fixed
> Flaky Test
> EpochDrivenReplicationProtocolAcceptanceTest#shouldSurviveFastLea
[
https://issues.apache.org/jira/browse/KAFKA-7988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211370#comment-17211370
]
Bill Bejeck commented on KAFKA-7988:
No failures reported for this in over a year. As
[
https://issues.apache.org/jira/browse/KAFKA-8079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8079:
---
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> Flaky Test
> EpochDrivenReplic
[
https://issues.apache.org/jira/browse/KAFKA-8079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211371#comment-17211371
]
Bill Bejeck commented on KAFKA-8079:
No failures reported for this in over a year. As
[
https://issues.apache.org/jira/browse/KAFKA-8303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8303:
---
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> Flaky Test SaslSslAdminClientIn
[
https://issues.apache.org/jira/browse/KAFKA-8303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211372#comment-17211372
]
Bill Bejeck commented on KAFKA-8303:
No failures reported for this in over a year. As
[
https://issues.apache.org/jira/browse/KAFKA-8108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211374#comment-17211374
]
Bill Bejeck commented on KAFKA-8108:
No failures reported for this in over a year. As
[
https://issues.apache.org/jira/browse/KAFKA-8303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8303.
Resolution: Fixed
> Flaky Test SaslSslAdminClientIntegrationTest#testLogStartOffsetCheckpoint
> ---
[
https://issues.apache.org/jira/browse/KAFKA-8137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8137.
Resolution: Fixed
> Flaky Test LegacyAdminClientTest#testOffsetsForTimesWhenOffsetNotFound
> --
[
https://issues.apache.org/jira/browse/KAFKA-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-7647:
---
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> Flaky test
> LogCleanerParamet
[
https://issues.apache.org/jira/browse/KAFKA-8108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8108:
---
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> Flaky Test kafka.api.ClientIdQu
[
https://issues.apache.org/jira/browse/KAFKA-8137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8137:
---
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> Flaky Test LegacyAdminClientTes
[
https://issues.apache.org/jira/browse/KAFKA-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211376#comment-17211376
]
Bill Bejeck commented on KAFKA-7647:
No failures reported for this in over a year. As
[
https://issues.apache.org/jira/browse/KAFKA-8108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8108.
Resolution: Fixed
> Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer
>
[
https://issues.apache.org/jira/browse/KAFKA-8137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211375#comment-17211375
]
Bill Bejeck commented on KAFKA-8137:
No failures reported for this in over a year. As
[
https://issues.apache.org/jira/browse/KAFKA-8076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8076.
Resolution: Fixed
> Flaky Test ProduceRequestTest#testSimpleProduceRequest
> --
[
https://issues.apache.org/jira/browse/KAFKA-8076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8076:
---
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> Flaky Test ProduceRequestTest#t
[
https://issues.apache.org/jira/browse/KAFKA-8076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211378#comment-17211378
]
Bill Bejeck commented on KAFKA-8076:
No failures reported for this in over a year. As
[
https://issues.apache.org/jira/browse/KAFKA-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-7647.
Resolution: Fixed
> Flaky test
> LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactA
[
https://issues.apache.org/jira/browse/KAFKA-8092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211379#comment-17211379
]
Bill Bejeck commented on KAFKA-8092:
No failures reported for this in over a year. As
[
https://issues.apache.org/jira/browse/KAFKA-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8139:
---
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> Flaky Test SaslSslAdminClientIn
[
https://issues.apache.org/jira/browse/KAFKA-8092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8092:
---
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> Flaky Test
> GroupAuthorizerIn
[
https://issues.apache.org/jira/browse/KAFKA-8092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8092.
Resolution: Fixed
> Flaky Test
> GroupAuthorizerIntegrationTest#testSendOffsetsWithNoConsumerGroup
[
https://issues.apache.org/jira/browse/KAFKA-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211380#comment-17211380
]
Bill Bejeck commented on KAFKA-8139:
No failures reported for this in over a year. As
[
https://issues.apache.org/jira/browse/KAFKA-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8139.
Resolution: Fixed
> Flaky Test SaslSslAdminClientIntegrationTest#testMetadataRefresh
>
[
https://issues.apache.org/jira/browse/KAFKA-8257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8257.
Resolution: Fixed
> Flaky Test DynamicConnectionQuotaTest#testDynamicListenerConnectionQuota
>
[
https://issues.apache.org/jira/browse/KAFKA-8257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8257:
---
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> Flaky Test DynamicConnectionQuo
[
https://issues.apache.org/jira/browse/KAFKA-8257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211381#comment-17211381
]
Bill Bejeck commented on KAFKA-8257:
No failures reported for this in over a year. As
[
https://issues.apache.org/jira/browse/KAFKA-6824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211385#comment-17211385
]
Bill Bejeck commented on KAFKA-6824:
No failures reported for this in over a year. As
[
https://issues.apache.org/jira/browse/KAFKA-6824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-6824.
Resolution: Fixed
> Flaky Test DynamicBrokerReconfigurationTest#testAddRemoveSslListener
>
[
https://issues.apache.org/jira/browse/KAFKA-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211386#comment-17211386
]
Bill Bejeck commented on KAFKA-10140:
-
Since this is not a blocker, there is no acti
[
https://issues.apache.org/jira/browse/KAFKA-6824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-6824:
---
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> Flaky Test DynamicBrokerReconfi
[
https://issues.apache.org/jira/browse/KAFKA-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-10140.
-
Resolution: Fixed
> Incremental config api excludes plugin config changes
>
[
https://issues.apache.org/jira/browse/KAFKA-8398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211387#comment-17211387
]
Bill Bejeck commented on KAFKA-8398:
Since this is not a blocker, and the PR is close
[
https://issues.apache.org/jira/browse/KAFKA-8398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8398:
---
Fix Version/s: (was: 2.7.0)
> NPE when unmapping files after moving log directories using
> Alte
[
https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211391#comment-17211391
]
Bill Bejeck commented on KAFKA-8940:
As part of the 2.7.0 release process, I'm optimi
[
https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8940:
---
Fix Version/s: (was: 2.6.1)
(was: 2.5.2)
(was: 2.7.0
[
https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8940.
Resolution: Fixed
> Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance
> ---
[
https://issues.apache.org/jira/browse/KAFKA-6078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211394#comment-17211394
]
Bill Bejeck commented on KAFKA-6078:
No failures reported for this in 10 months. As p
[
https://issues.apache.org/jira/browse/KAFKA-6078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-6078.
Resolution: Fixed
> Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster
>
[
https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211395#comment-17211395
]
Bill Bejeck commented on KAFKA-5453:
No progress since the last release, I'm clearing
[
https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-5453:
---
Fix Version/s: (was: 2.7.0)
> Controller may miss requests sent to the broker when zk session tim
[
https://issues.apache.org/jira/browse/KAFKA-10509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-10509.
-
Resolution: Fixed
Resolved via [https://github.com/apache/kafka/pull/9317] merged on 9/28.
> Ad
[
https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211400#comment-17211400
]
Bill Bejeck commented on KAFKA-10343:
-
[~bchen225242] From the comments above, I'm g
[
https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-10343:
Fix Version/s: (was: 2.7.0)
2.8.0
> Remove 2.7 IBP for redirection enableme
[
https://issues.apache.org/jira/browse/KAFKA-9705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211403#comment-17211403
]
Bill Bejeck commented on KAFKA-9705:
[~bchen225242] will this make it for the 2.7.0 r
splett2 commented on pull request #9386:
URL: https://github.com/apache/kafka/pull/9386#issuecomment-706405628
@apovzner
Updated PR to address comments.
This is an automated message from the Apache Git Service.
To respond
ryannedolan commented on a change in pull request #9395:
URL: https://github.com/apache/kafka/pull/9395#discussion_r502672494
##
File path:
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/ReplicationPolicy.java
##
@@ -57,4 +57,9 @@ default boolean isInterna
junrao merged pull request #7929:
URL: https://github.com/apache/kafka/pull/7929
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
[
https://issues.apache.org/jira/browse/KAFKA-9837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211415#comment-17211415
]
Bill Bejeck commented on KAFKA-9837:
I'm changing the fix version for this ticket as
[
https://issues.apache.org/jira/browse/KAFKA-9837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-9837:
---
Fix Version/s: (was: 2.7.0)
2.8.0
> New RPC for notifying controller of failed
[
https://issues.apache.org/jira/browse/KAFKA-9393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-9393.
Fix Version/s: 2.7.0
Assignee: Gardner Vickers
Resolution: Fixed
merged to trunk.
> Delete
[
https://issues.apache.org/jira/browse/KAFKA-10143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211421#comment-17211421
]
Bill Bejeck commented on KAFKA-10143:
-
[~hachikuji] do you think this will go with t
[
https://issues.apache.org/jira/browse/KAFKA-10233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211422#comment-17211422
]
Bill Bejeck commented on KAFKA-10233:
-
[~rsivaram] do you think this will be complet
[
https://issues.apache.org/jira/browse/KAFKA-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211431#comment-17211431
]
Bill Bejeck commented on KAFKA-8744:
Not a blocker issue so as part of the 2.7.0 rele
[
https://issues.apache.org/jira/browse/KAFKA-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8744:
---
Fix Version/s: (was: 2.7.0)
> Add Support to Scala API for KIP-307 and KIP-479
>
[
https://issues.apache.org/jira/browse/KAFKA-9333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-9333:
---
Fix Version/s: (was: 2.7.0)
> Shim `core` module that targets default scala version (KIP-531)
> -
[
https://issues.apache.org/jira/browse/KAFKA-9333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211434#comment-17211434
]
Bill Bejeck commented on KAFKA-9333:
Not a blocker so I'm clearing the fix version as
mjsax commented on a change in pull request #9384:
URL: https://github.com/apache/kafka/pull/9384#discussion_r502683615
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -192,12 +191,11 @@ public String toStrin
mjsax commented on a change in pull request #9384:
URL: https://github.com/apache/kafka/pull/9384#discussion_r502683749
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -206,7 +204,6 @@ public void configure(f
mjsax commented on a change in pull request #9384:
URL: https://github.com/apache/kafka/pull/9384#discussion_r502683418
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -1091,8 +1096,4 @@ ConsumerRebalanceListener rebalan
vvcephei opened a new pull request #9408:
URL: https://github.com/apache/kafka/pull/9408
Previously, we would throw a confusing error, "the store has migrated,"
when users ask for a store that is not in the topology at all, or when the
type of the store doesn't match the QueryableStore
wushujames commented on pull request #9276:
URL: https://github.com/apache/kafka/pull/9276#issuecomment-706452504
@dongjinleekr All builds failed, but none of the failures seem related to my
change.
This is an automated mes
[
https://issues.apache.org/jira/browse/KAFKA-10509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211484#comment-17211484
]
James Cheng commented on KAFKA-10509:
-
Can we also update the documentation at
[htt
Yeva Byzek created KAFKA-10595:
--
Summary: Explain idempotent producer in
max.in.flight.requests.per.connection
Key: KAFKA-10595
URL: https://issues.apache.org/jira/browse/KAFKA-10595
Project: Kafka
ijuma commented on a change in pull request #8891:
URL: https://github.com/apache/kafka/pull/8891#discussion_r502724870
##
File path:
core/src/test/scala/integration/kafka/admin/ReassignPartitionsIntegrationTest.scala
##
@@ -162,6 +162,39 @@ class ReassignPartitionsIntegration
[
https://issues.apache.org/jira/browse/KAFKA-10200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211515#comment-17211515
]
John Roesler commented on KAFKA-10200:
--
Thanks, Sophie, yes, this is done.
> Mock
vvcephei commented on pull request #9338:
URL: https://github.com/apache/kafka/pull/9338#issuecomment-706474125
Thanks, @thake .
Ah, sorry about that: it was my change, and now I feel extra guilty for not
reviewing and merging your fix in a timely fashion.
It was intentional n
vvcephei commented on a change in pull request #9396:
URL: https://github.com/apache/kafka/pull/9396#discussion_r502737067
##
File path:
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/api/MockProcessorContext.java
##
@@ -0,0 +1,494 @@
+/*
+ * Licensed to t
vvcephei commented on a change in pull request #9396:
URL: https://github.com/apache/kafka/pull/9396#discussion_r502737231
##
File path:
streams/test-utils/src/test/java/org/apache/kafka/streams/test/wordcount/WindowedWordCountProcessorTest.java
##
@@ -136,54 +133,18 @@ public
[
https://issues.apache.org/jira/browse/KAFKA-10200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10200:
-
Fix Version/s: 2.7.0
> MockProcessorContext doesn't work with WindowStores
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-10215:
Assignee: John Roesler
> MockProcessorContext doesn't work with SessionStores
> -
[
https://issues.apache.org/jira/browse/KAFKA-10215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10215:
-
Fix Version/s: 2.7.0
> MockProcessorContext doesn't work with SessionStores
> --
[
https://issues.apache.org/jira/browse/KAFKA-10215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211525#comment-17211525
]
John Roesler commented on KAFKA-10215:
--
Note, this will be fixed for the new PAPI M
zhaohaidao commented on a change in pull request #9311:
URL: https://github.com/apache/kafka/pull/9311#discussion_r502740233
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
##
@@ -369,7 +372,9 @@ private TransactionalRequ
huxihx merged pull request #9399:
URL: https://github.com/apache/kafka/pull/9399
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
huxihx commented on pull request #9399:
URL: https://github.com/apache/kafka/pull/9399#issuecomment-706479905
@junrao Thanks for the review, merging to trunk.
This is an automated message from the Apache Git Service.
To respo
[
https://issues.apache.org/jira/browse/KAFKA-10584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huxihx resolved KAFKA-10584.
Fix Version/s: 2.7.0
Resolution: Fixed
> IndexSearchType should use sealed trait instead of Enumera
HaiyuanZhao created KAFKA-10596:
---
Summary: Adding some state to TransactionMetadata which explicitly
indicates that the transaction was timed out
Key: KAFKA-10596
URL: https://issues.apache.org/jira/browse/KAFKA-105
[
https://issues.apache.org/jira/browse/KAFKA-10596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
HaiyuanZhao updated KAFKA-10596:
{code:java}
The code assumes that if we get a receive an EndTxn request and
lastProducerEpoch has bee
zhaohaidao commented on a change in pull request #9311:
URL: https://github.com/apache/kafka/pull/9311#discussion_r502744351
##
File path:
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala
##
@@ -381,9 +386,16 @@ class TransactionCoordinator(broker
zhaohaidao commented on a change in pull request #9311:
URL: https://github.com/apache/kafka/pull/9311#discussion_r502751077
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
##
@@ -1589,7 +1607,8 @@ public void handleRespo
[
https://issues.apache.org/jira/browse/KAFKA-10576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211577#comment-17211577
]
huxihx commented on KAFKA-10576:
`commitAsync` does need subsequent `poll` calls to take
zhaohaidao commented on a change in pull request #9311:
URL: https://github.com/apache/kafka/pull/9311#discussion_r502752681
##
File path: core/src/test/scala/integration/kafka/api/TransactionsTest.scala
##
@@ -555,11 +555,11 @@ class TransactionsTest extends KafkaServerTestHar
201 - 300 of 301 matches
Mail list logo
