showuon commented on a change in pull request #11936:
URL: https://github.com/apache/kafka/pull/11936#discussion_r834992142
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -135,7 +135,11 @@ object GetOffsetShell {
val partitionOffsets = partition
dengziming commented on a change in pull request #11936:
URL: https://github.com/apache/kafka/pull/11936#discussion_r834991039
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -135,7 +135,11 @@ object GetOffsetShell {
val partitionOffsets = partit
showuon commented on a change in pull request #11936:
URL: https://github.com/apache/kafka/pull/11936#discussion_r834985220
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -135,7 +135,11 @@ object GetOffsetShell {
val partitionOffsets = partition
[
https://issues.apache.org/jira/browse/KAFKA-13687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17496312#comment-17496312
]
Sergio Troiano edited comment on KAFKA-13687 at 3/25/22, 6:24 AM:
dengziming commented on a change in pull request #11936:
URL: https://github.com/apache/kafka/pull/11936#discussion_r834982567
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -135,7 +135,11 @@ object GetOffsetShell {
val partitionOffsets = partit
dengziming commented on a change in pull request #11936:
URL: https://github.com/apache/kafka/pull/11936#discussion_r834982567
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -135,7 +135,11 @@ object GetOffsetShell {
val partitionOffsets = partit
dengziming commented on a change in pull request #11936:
URL: https://github.com/apache/kafka/pull/11936#discussion_r834983243
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -70,7 +70,7 @@ object GetOffsetShell {
.withRequir
dengziming commented on a change in pull request #11936:
URL: https://github.com/apache/kafka/pull/11936#discussion_r834982567
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -135,7 +135,11 @@ object GetOffsetShell {
val partitionOffsets = partit
[
https://issues.apache.org/jira/browse/KAFKA-13687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergio Troiano reassigned KAFKA-13687:
--
Assignee: Sergio Troiano
> Limit number of batches when using kafka-dump-log.sh
> ---
RivenSun2 commented on pull request #11947:
URL: https://github.com/apache/kafka/pull/11947#issuecomment-1078645801
Hi @dajac @hachikuji @guozhangwang
please help to review the PR .
Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
RivenSun2 opened a new pull request #11947:
URL: https://github.com/apache/kafka/pull/11947
Improve the description of principal under different mechanisms of sasl.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/KAFKA-13770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-13770.
---
Reviewer: Konstantine Karantasis
Resolution: Fixed
> Regression when Connect uses 0.10
[
https://issues.apache.org/jira/browse/KAFKA-13770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-13770:
--
Fix Version/s: (was: 2.5.2)
> Regression when Connect uses 0.10.x brokers due to recently
[
https://issues.apache.org/jira/browse/KAFKA-13770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17512192#comment-17512192
]
Randall Hauch commented on KAFKA-13770:
---
Merged the changes to `trunk` after the P
[
https://issues.apache.org/jira/browse/KAFKA-13770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-13770:
--
Description:
KAFKA-12879 recently modified Connect's `KafkaBasedLog` class to add retry
logic
[
https://issues.apache.org/jira/browse/KAFKA-13770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch reassigned KAFKA-13770:
-
Assignee: Randall Hauch
> Regression when Connect uses 0.10.x brokers due to recently a
vvcephei commented on a change in pull request #11945:
URL: https://github.com/apache/kafka/pull/11945#discussion_r834933864
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerde.java
##
@@ -64,7 +64,7 @@
[
https://issues.apache.org/jira/browse/KAFKA-13771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17512177#comment-17512177
]
RivenSun commented on KAFKA-13771:
--
Hi [~guozhang] [~dajac] [~ijuma]
Could you give s
RivenSun created KAFKA-13771:
Summary: Support to explicitly delete delegationTokens that have
expired but have not been automatically cleaned up
Key: KAFKA-13771
URL: https://issues.apache.org/jira/browse/KAFKA-13771
rhauch commented on pull request #11946:
URL: https://github.com/apache/kafka/pull/11946#issuecomment-1078597932
No Connect-related failures in the builds, and a [system test run of the
Connect
tests](https://jenkins.confluent.io/view/All/job/system-test-kafka-branch-builder/4823/)
passed
rhauch merged pull request #11946:
URL: https://github.com/apache/kafka/pull/11946
--
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..
showuon commented on a change in pull request #11936:
URL: https://github.com/apache/kafka/pull/11936#discussion_r834906233
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -135,7 +135,11 @@ object GetOffsetShell {
val partitionOffsets = partition
showuon commented on a change in pull request #11936:
URL: https://github.com/apache/kafka/pull/11936#discussion_r834905197
##
File path: core/src/test/scala/kafka/tools/GetOffsetShellTest.scala
##
@@ -166,6 +166,13 @@ class GetOffsetShellTest extends KafkaServerTestHarness
wi
showuon commented on a change in pull request #11936:
URL: https://github.com/apache/kafka/pull/11936#discussion_r834904926
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -70,7 +70,7 @@ object GetOffsetShell {
.withRequiredA
dengziming commented on a change in pull request #11936:
URL: https://github.com/apache/kafka/pull/11936#discussion_r834896331
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -135,7 +135,11 @@ object GetOffsetShell {
val partitionOffsets = partit
showuon commented on pull request #10976:
URL: https://github.com/apache/kafka/pull/10976#issuecomment-1078578578
@wycc , it's been a while since your last update, could you please
rebase to the latest trunk before I start the review? Thank you!
--
This is an automated message from t
bozhao12 commented on a change in pull request #11942:
URL: https://github.com/apache/kafka/pull/11942#discussion_r834860157
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1028,6 +1028,7 @@ class ReplicaManager(val config: KafkaConfig,
var bytes
jeff303 edited a comment on pull request #11792:
URL: https://github.com/apache/kafka/pull/11792#issuecomment-1078447241
Something I've learned, that I feel is not adequately covered by [this
wiki](https://github.com/mockito/mockito/wiki/Mockito-vs-EasyMock):
EasyMock expectations se
jeff303 commented on pull request #11792:
URL: https://github.com/apache/kafka/pull/11792#issuecomment-1078447241
Something I've learned, that I feel is not
[adequately](https://github.com/mockito/mockito/wiki/Mockito-vs-EasyMock)
covered by this wiki:
EasyMock expectations seem to
[
https://issues.apache.org/jira/browse/KAFKA-13770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-13770:
--
Description:
KAFKA-12879 recently modified Connect's `KafkaBasedLog` class to add retry
logic
rhauch opened a new pull request #11946:
URL: https://github.com/apache/kafka/pull/11946
The `retryEndOffsets(…)` method in `TopicAdmin` recently added (KAFKA-12879,
#11797) to allow the `KafkaBasedLog.start()` method to retry any failures
reading the last offsets for a topic. However, thi
[
https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13554.
--
Resolution: Won't Fix
> Rename RangeQuery to KeyRangeQuery
> -
[
https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler closed KAFKA-13554.
> Rename RangeQuery to KeyRangeQuery
> --
>
> Key: KAF
[
https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17512096#comment-17512096
]
John Roesler commented on KAFKA-13554:
--
I thought that I filed this because it had
[
https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13554:
-
Affects Version/s: (was: 3.2.0)
> Rename RangeQuery to KeyRangeQuery
> -
[
https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13554:
-
Priority: Minor (was: Blocker)
> Rename RangeQuery to KeyRangeQuery
> -
[
https://issues.apache.org/jira/browse/KAFKA-13622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13622:
-
Priority: Minor (was: Blocker)
> Revisit the complexity of position tracking in state stores
>
[
https://issues.apache.org/jira/browse/KAFKA-13622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13622:
-
Affects Version/s: (was: 3.2.0)
> Revisit the complexity of position tracking in state store
[
https://issues.apache.org/jira/browse/KAFKA-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13541:
-
Affects Version/s: (was: 3.2.0)
> Make IQv2 query/store interface type safe
> --
[
https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-13554:
Assignee: John Roesler (was: Vicky Papavasileiou)
> Rename RangeQuery to KeyRangeQuery
>
[
https://issues.apache.org/jira/browse/KAFKA-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13541:
-
Priority: Minor (was: Blocker)
> Make IQv2 query/store interface type safe
> --
[
https://issues.apache.org/jira/browse/KAFKA-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13526:
-
Priority: Minor (was: Blocker)
> IQv2: Consider more generic logic for mapping between binary a
[
https://issues.apache.org/jira/browse/KAFKA-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13526:
-
Affects Version/s: (was: 3.2.0)
> IQv2: Consider more generic logic for mapping between bina
[
https://issues.apache.org/jira/browse/KAFKA-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13548:
-
Priority: Minor (was: Blocker)
> IQv2: revisit WindowKeyQuery and WindowRangeQuery
> --
[
https://issues.apache.org/jira/browse/KAFKA-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13548:
-
Affects Version/s: (was: 3.2.0)
> IQv2: revisit WindowKeyQuery and WindowRangeQuery
> --
[
https://issues.apache.org/jira/browse/KAFKA-13479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13479:
-
Fix Version/s: (was: 3.2.0)
> Interactive Query v2
>
>
>
Randall Hauch created KAFKA-13770:
-
Summary: Regression when Connect uses 0.10.x brokers due to
recently added retry logic in KafkaBasedLog
Key: KAFKA-13770
URL: https://issues.apache.org/jira/browse/KAFKA-13770
[
https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13542:
--
Fix Version/s: 3.3.0
(was: 3.2.0)
> Utilize the new Consumer#enforceReb
[
https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17512046#comment-17512046
]
Bruno Cadonna commented on KAFKA-13542:
---
OK, I will move this ticket to the next r
vvcephei commented on pull request #11944:
URL: https://github.com/apache/kafka/pull/11944#issuecomment-1077954224
Thanks, all! Merged and cherry-picked to 3.2
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
vvcephei merged pull request #11944:
URL: https://github.com/apache/kafka/pull/11944
--
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
mjsax commented on a change in pull request #11945:
URL: https://github.com/apache/kafka/pull/11945#discussion_r834631843
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerde.java
##
@@ -64,7 +64,7 @@ pu
[
https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-13421:
-
Assignee: (was: Kirk True)
> Fix
> ConsumerBounceTest#testRollingBrokerRestartsWithSmaller
[
https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-13421:
-
Assignee: Kirk True
> Fix
> ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSiz
[
https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17512018#comment-17512018
]
Matthias J. Sax commented on KAFKA-13542:
-
SGTM.
> Utilize the new Consumer#enf
[
https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511960#comment-17511960
]
Hao Li commented on KAFKA-13542:
Most likely I don't have bandwidth to investigate this
[
https://issues.apache.org/jira/browse/KAFKA-13692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13692.
---
Fix Version/s: 3.3.0
(was: 3.2.0)
Resolution: Fixed
> stream t
[
https://issues.apache.org/jira/browse/KAFKA-13692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reassigned KAFKA-13692:
-
Assignee: Rohan Desai
> stream thread blocked-time-ns-total metric does not include pro
rhauch commented on a change in pull request #11908:
URL: https://github.com/apache/kafka/pull/11908#discussion_r834528693
##
File path: docs/connect.html
##
@@ -74,6 +74,7 @@ Running
Kafka Connectconfig.storage.topic (default
connect-configs) - topic to use for storing conne
rhauch commented on a change in pull request #11908:
URL: https://github.com/apache/kafka/pull/11908#discussion_r834528693
##
File path: docs/connect.html
##
@@ -74,6 +74,7 @@ Running
Kafka Connectconfig.storage.topic (default
connect-configs) - topic to use for storing conne
guozhangwang closed pull request #11805:
URL: https://github.com/apache/kafka/pull/11805
--
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-unsu
rhauch commented on a change in pull request #11908:
URL: https://github.com/apache/kafka/pull/11908#discussion_r834525760
##
File path: tests/kafkatest/services/connect.py
##
@@ -279,12 +282,34 @@ def append_to_environment_variable(self, envvar, value):
env_opts =
C0urante edited a comment on pull request #11869:
URL: https://github.com/apache/kafka/pull/11869#issuecomment-1077834292
No worries @kpatelatwork, good to hear from you!
@showuon no worries, thanks for taking a look. Definitely better to move
cautiously than to merge something you'r
C0urante commented on pull request #11869:
URL: https://github.com/apache/kafka/pull/11869#issuecomment-1077834292
No worries @kpatelatwork, good to hear from you!
@showuon no worries, thanks for taking a look. Definitely better to move
cautiously than to merge something you're not c
kpatelatwork commented on pull request #11869:
URL: https://github.com/apache/kafka/pull/11869#issuecomment-1077823237
@C0urante Thanks a lot this indeed seems like a bug and sorry for the late
reply as I was busy. LGTM from my side
--
This is an automated message from the Apache Git Ser
[
https://issues.apache.org/jira/browse/KAFKA-13769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksandr Sorokoumov reassigned KAFKA-13769:
Assignee: Aleksandr Sorokoumov
> KTable FK join can miss records if an up
[
https://issues.apache.org/jira/browse/KAFKA-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13689:
--
Fix Version/s: 3.3.0
(was: 3.2.0)
> AbstractConfig log print informatio
guozhangwang merged pull request #11940:
URL: https://github.com/apache/kafka/pull/11940
--
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-unsu
guozhangwang commented on a change in pull request #11940:
URL: https://github.com/apache/kafka/pull/11940#discussion_r834502144
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
##
@@ -530,6 +530,9 @@ private TransactionManager
configur
[
https://issues.apache.org/jira/browse/KAFKA-13766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-13766:
---
Assignee: David Jacot
> Use `max.poll.interval.ms` as the timeout during complete-rebalance
dajac commented on a change in pull request #11936:
URL: https://github.com/apache/kafka/pull/11936#discussion_r834419560
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -135,7 +135,11 @@ object GetOffsetShell {
val partitionOffsets = partitionIn
Aleksandr Sorokoumov created KAFKA-13769:
Summary: KTable FK join can miss records if an upstream
non-key-changing operation changes key serializer
Key: KAFKA-13769
URL: https://issues.apache.org/jira/brow
divijvaidya commented on pull request #11943:
URL: https://github.com/apache/kafka/pull/11943#issuecomment-1077705543
@abbccdda @hachikuji , this is my first code change to Apache Kafka 🎉 .
Kindly review.
--
This is an automated message from the Apache Git Service.
To respond to the me
[
https://issues.apache.org/jira/browse/KAFKA-13128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-13128.
---
Resolution: Fixed
> Flaky Test
> StoreQueryIntegrationTest.shouldQueryStoresAfterAddingAndR
ijuma commented on a change in pull request #11743:
URL: https://github.com/apache/kafka/pull/11743#discussion_r834371938
##
File path: gradle/dependencies.gradle
##
@@ -189,14 +188,15 @@ libs += [
powermockJunit4: "org.powermock:powermock-module-junit4:$versions.powermock",
vvcephei opened a new pull request #11944:
URL: https://github.com/apache/kafka/pull/11944
Added an extra notice about IQv2's API compatibility, as discussed in the
KIP-796 vote thread.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
ijuma commented on pull request #11743:
URL: https://github.com/apache/kafka/pull/11743#issuecomment-1077678693
We should add something to the notable changes in `upgrade.html`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
ijuma commented on a change in pull request #11743:
URL: https://github.com/apache/kafka/pull/11743#discussion_r834356826
##
File path: gradle/dependencies.gradle
##
@@ -189,14 +188,15 @@ libs += [
powermockJunit4: "org.powermock:powermock-module-junit4:$versions.powermock",
ijuma commented on a change in pull request #11743:
URL: https://github.com/apache/kafka/pull/11743#discussion_r834356644
##
File path: gradle/dependencies.gradle
##
@@ -177,7 +177,6 @@ libs += [
kafkaStreams_28: "org.apache.kafka:kafka-streams:$versions.kafka_28",
kafkaS
[
https://issues.apache.org/jira/browse/KAFKA-10095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511876#comment-17511876
]
Divij Vaidya commented on KAFKA-10095:
--
Since the first pull request had no activit
divijvaidya opened a new pull request #11943:
URL: https://github.com/apache/kafka/pull/11943
Changes:
1. Add a stricter assertion in LogCleanerManagerTest
2. Minor cosmetic simplification in Scala
Testing:
LogCleanerManagerTest run is successful. All unit test runs are suc
dengziming commented on a change in pull request #11936:
URL: https://github.com/apache/kafka/pull/11936#discussion_r834344701
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -135,7 +135,11 @@ object GetOffsetShell {
val partitionOffsets = partit
dengziming commented on a change in pull request #11936:
URL: https://github.com/apache/kafka/pull/11936#discussion_r834344420
##
File path: core/src/test/scala/kafka/tools/GetOffsetShellTest.scala
##
@@ -166,6 +166,13 @@ class GetOffsetShellTest extends KafkaServerTestHarness
ijuma merged pull request #11939:
URL: https://github.com/apache/kafka/pull/11939
--
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...
[
https://issues.apache.org/jira/browse/KAFKA-13479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511853#comment-17511853
]
Bruno Cadonna commented on KAFKA-13479:
---
[~vvcephei] As far as I understand, the m
[
https://issues.apache.org/jira/browse/KAFKA-13479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13479:
--
Fix Version/s: 3.2.0
(was: 3.3.0)
> Interactive Query v2
>
[
https://issues.apache.org/jira/browse/KAFKA-13128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511841#comment-17511841
]
Bruno Cadonna commented on KAFKA-13128:
---
[~wcarlson5] Do you think we can close th
dajac commented on a change in pull request #11942:
URL: https://github.com/apache/kafka/pull/11942#discussion_r834269788
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1028,6 +1028,7 @@ class ReplicaManager(val config: KafkaConfig,
var bytesRea
[
https://issues.apache.org/jira/browse/KAFKA-9366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511814#comment-17511814
]
Bruno Cadonna commented on KAFKA-9366:
--
[~brandonk] Actually, I removed it from the
[
https://issues.apache.org/jira/browse/KAFKA-13768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuexiaoyue updated KAFKA-13768:
---
Description:
Hi team, I'm using a transactional producer and set request.timeout.ms to a
rather sma
[
https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511796#comment-17511796
]
Bruno Cadonna commented on KAFKA-13542:
---
[~lihaosky] Code freeze for 3.2 is March
bozhao12 commented on a change in pull request #11942:
URL: https://github.com/apache/kafka/pull/11942#discussion_r834172924
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1028,6 +1028,7 @@ class ReplicaManager(val config: KafkaConfig,
var bytes
bozhao12 commented on a change in pull request #11942:
URL: https://github.com/apache/kafka/pull/11942#discussion_r834172924
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1028,6 +1028,7 @@ class ReplicaManager(val config: KafkaConfig,
var bytes
bozhao12 commented on a change in pull request #11942:
URL: https://github.com/apache/kafka/pull/11942#discussion_r834168741
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1028,6 +1028,7 @@ class ReplicaManager(val config: KafkaConfig,
var bytes
dajac commented on a change in pull request #11942:
URL: https://github.com/apache/kafka/pull/11942#discussion_r834125268
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1037,6 +1038,8 @@ class ReplicaManager(val config: KafkaConfig,
errorRea
mimaison commented on pull request #11929:
URL: https://github.com/apache/kafka/pull/11929#issuecomment-1077446695
Unit tests are now passing. Before pushing this further I'd like to get some
agreement from the community about supporting different platforms. See
https://lists.apache.org/th
[
https://issues.apache.org/jira/browse/KAFKA-13757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RivenSun updated KAFKA-13757:
-
Description:
DelegationToken is a great and lightweight feature, but when users actually use
it, they g
[
https://issues.apache.org/jira/browse/KAFKA-13768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuexiaoyue updated KAFKA-13768:
---
Description:
Hi team, I'm using a transactional producer and set request.timeout.ms to a
rather sma
[
https://issues.apache.org/jira/browse/KAFKA-13767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhaobo updated KAFKA-13767:
---
Summary: Fetch response did not need delay return when the preferred read
replica not local replica (was: F
mimaison commented on a change in pull request #11908:
URL: https://github.com/apache/kafka/pull/11908#discussion_r834048496
##
File path: docs/connect.html
##
@@ -74,6 +74,7 @@ Running
Kafka Connectconfig.storage.topic (default
connect-configs) - topic to use for storing con
1 - 100 of 122 matches
Mail list logo
