[ https://issues.apache.org/jira/browse/KAFKA-13767 ]
zhaobo deleted comment on KAFKA-13767:
was (Author: JIRAUSER287034):
https://github.com/apache/kafka/pull/11942
> consumer fetch request does not need to put to delayFetch queue when the
> pre
[
https://issues.apache.org/jira/browse/KAFKA-13767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhaobo updated KAFKA-13767:
---
External issue URL: https://github.com/apache/kafka/pull/11942
> consumer fetch request does not need to put
[
https://issues.apache.org/jira/browse/KAFKA-13767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhaobo updated KAFKA-13767:
---
Fix Version/s: 3.2.0
(was: 3.3.0)
Affects Version/s: 3.2.0
xuexiaoyue created KAFKA-13768:
--
Summary: Transactional producer exits because of expiration in
RecordAccumulator
Key: KAFKA-13768
URL: https://issues.apache.org/jira/browse/KAFKA-13768
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhaobo updated KAFKA-13767:
---
External issue URL: (was: https://github.com/apache/kafka/pull/11942)
Description:
{code:java
lkokhreidze commented on pull request #11923:
URL: https://github.com/apache/kafka/pull/11923#issuecomment-1077305642
FYI, I'll cherry-pick this to 3.2 branch once it's merged.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/KAFKA-13767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhaobo updated KAFKA-13767:
---
Summary: consumer fetch request does not need to put into delayFetch queue
when the preferred read replica n
[
https://issues.apache.org/jira/browse/KAFKA-13768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511644#comment-17511644
]
xuexiaoyue commented on KAFKA-13768:
I found that KAFKA-8805; Bump producer epoch on
[
https://issues.apache.org/jira/browse/KAFKA-13768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511644#comment-17511644
]
xuexiaoyue edited comment on KAFKA-13768 at 3/24/22, 7:24 AM:
[
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-13768 ]
xuexiaoyue deleted comment on KAFKA-13768:
was (Author: ddrid):
I found that KAFKA-8805; Bump producer epoch on recoverable errors (#7389) fix
this by automatically aborting the transaction
[
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:
---
Language: scala
Summary: consumer fetch request does not need to put into delayFetch queue
when the pre
[
https://issues.apache.org/jira/browse/KAFKA-13767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511651#comment-17511651
]
zhaobo edited comment on KAFKA-13767 at 3/24/22, 7:41 AM:
--
http
showuon commented on pull request #11937:
URL: https://github.com/apache/kafka/pull/11937#issuecomment-1077332498
Failed tests are unrelated:
```
Build / JDK 17 and Scala 2.13 /
org.apache.kafka.streams.integration.PurgeRepartitionTopicIntegrationTest.shouldRestoreState
Bui
showuon merged pull request #11937:
URL: https://github.com/apache/kafka/pull/11937
--
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-13767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhaobo updated KAFKA-13767:
---
Summary: Consumer fetch request does not need to put into delayFetch queue
when the preferred read replica n
[
https://issues.apache.org/jira/browse/KAFKA-13767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhaobo updated KAFKA-13767:
---
Summary: Fetch request does not need to put into delayFetch queue when
preferred read replica not local repl
zhishengzhang commented on pull request #10760:
URL: https://github.com/apache/kafka/pull/10760#issuecomment-1077361506
good job
--
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 comm
[
https://issues.apache.org/jira/browse/KAFKA-12541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511686#comment-17511686
]
zhangzhisheng commented on KAFKA-12541:
---
it is very useful(y)
> Extend ListOffset
[
https://issues.apache.org/jira/browse/KAFKA-13509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511688#comment-17511688
]
zhangzhisheng commented on KAFKA-13509:
---
(y)
> Support max timestamp in GetOffset
[
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
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
[
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
[
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-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
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
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
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
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
[
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
[
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-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
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-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
[
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-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
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...
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
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
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
[
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
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
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 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
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 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",
[
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
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
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
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
[
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
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
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
[
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
[
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
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
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
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
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 =
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_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
[
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
[
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-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-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-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-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-13421:
-
Assignee: (was: Kirk True)
> Fix
> ConsumerBounceTest#testRollingBrokerRestartsWithSmaller
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
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
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
[
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
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-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
>
>
>
[
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-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:
-
Affects Version/s: (was: 3.2.0)
> IQv2: revisit WindowKeyQuery and WindowRangeQuery
> --
[
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-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:
-
Affects Version/s: (was: 3.2.0)
> Make IQv2 query/store interface type safe
> --
[
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-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-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-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 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 resolved KAFKA-13554.
--
Resolution: Won't Fix
> Rename RangeQuery to KeyRangeQuery
> -
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-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
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
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
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
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
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 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
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
1 - 100 of 122 matches
Mail list logo
