hzh0425 opened a new pull request, #13133:
URL: https://github.com/apache/kafka/pull/13133
Fix some typos in storage module / remote.metadata.storage
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI
[
https://issues.apache.org/jira/browse/KAFKA-14367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-14367.
-
Fix Version/s: 3.5.0
Resolution: Fixed
> Introduce `GroupCoordinator` interface
>
dajac merged PR #13112:
URL: https://github.com/apache/kafka/pull/13112
--
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:
[
https://issues.apache.org/jira/browse/KAFKA-14642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hzh0425 updated KAFKA-14642:
Priority: Blocker (was: Major)
> TopicBased RemoteLogMetadataManager can't support reassign
showuon commented on code in PR #13099:
URL: https://github.com/apache/kafka/pull/13099#discussion_r1082162567
##
clients/src/main/java/org/apache/kafka/common/utils/Utils.java:
##
@@ -1496,4 +1496,32 @@ public static String replaceSuffix(String str, String
oldSuffix, String
hzh0425 created KAFKA-14643:
---
Summary: TopicBased RemoteLogMetadataManager can't support
reassign user-partitions
Key: KAFKA-14643
URL: https://issues.apache.org/jira/browse/KAFKA-14643
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679014#comment-17679014
]
hzh0425 commented on KAFKA-14642:
-
Hi, [~satishd] [~junrao] [~Hangleton] , Could you pls help to review
hzh0425 created KAFKA-14642:
---
Summary: TopicBased RemoteLogMetadataManager can't support
reassign user-partitions
Key: KAFKA-14642
URL: https://issues.apache.org/jira/browse/KAFKA-14642
Project: Kafka
yufeiyan1220 commented on PR #13125:
URL: https://github.com/apache/kafka/pull/13125#issuecomment-1397979098
> Seems like we aren't particularly consistent at removing these metrics and
sensors, fetcher would be another example. Mind making the clean up more
comprehensive?
Never
philipnee commented on PR #13125:
URL: https://github.com/apache/kafka/pull/13125#issuecomment-1397952270
Seems like we aren't particularly consistent at removing these metrics and
sensors, fetcher would be another example. Mind making the clean up more
comprehensive?
--
This is an
[
https://issues.apache.org/jira/browse/KAFKA-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678981#comment-17678981
]
A. Sophie Blee-Goldman commented on KAFKA-14639:
There's definitely something off, it
ableegoldman opened a new pull request, #13132:
URL: https://github.com/apache/kafka/pull/13132
While working on the 3.4 release I noticed we've built up an embarrassingly
long list of warnings within the Streams javadocs. It's unavoidable for some
links to break as the source code
[
https://issues.apache.org/jira/browse/KAFKA-14638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-14638.
-
Fix Version/s: 3.5.0
Resolution: Fixed
> Documentation for
mjsax merged PR #13129:
URL: https://github.com/apache/kafka/pull/13129
--
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:
yufeiyan1220 commented on PR #13125:
URL: https://github.com/apache/kafka/pull/13125#issuecomment-1397837046
> Thanks for the PR and the issue @yufeiyan1220 - I wonder if the clean up
is necessary, as the metrics will be closed upon the client closing. Willing to
hear what others say.
Ge commented on PR #13129:
URL: https://github.com/apache/kafka/pull/13129#issuecomment-1397815859
@hachikuji @jolshan I don't have Kafka committer privileges. Can you please
commit?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/KAFKA-7744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678943#comment-17678943
]
Yaroslav commented on KAFKA-7744:
-
Hi,
This was already fixed by KAFKA-6157 for 1.0.1 version and above.
Guozhang Wang created KAFKA-14641:
-
Summary: Cleanup CommitNeeded after EOS-V1 is removed
Key: KAFKA-14641
URL: https://issues.apache.org/jira/browse/KAFKA-14641
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-14641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-14641:
--
Component/s: streams
> Cleanup CommitNeeded after EOS-V1 is removed
>
Justine Olshan created KAFKA-14640:
--
Summary: Update AddPartitionsToTxn protocol to batch and handle
verifyOnly requests
Key: KAFKA-14640
URL: https://issues.apache.org/jira/browse/KAFKA-14640
[
https://issues.apache.org/jira/browse/KAFKA-14640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-14640:
--
Assignee: Justine Olshan
> Update AddPartitionsToTxn protocol to batch and handle
Ge commented on code in PR #13129:
URL: https://github.com/apache/kafka/pull/13129#discussion_r1081881848
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -318,7 +318,8 @@ public class ProducerConfig extends AbstractConfig {
/**
[
https://issues.apache.org/jira/browse/KAFKA-10586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reassigned KAFKA-10586:
-
Assignee: Chris Egerton (was: Viktor Somogyi-Vass)
> Full support for distributed
hachikuji commented on code in PR #13129:
URL: https://github.com/apache/kafka/pull/13129#discussion_r1081878202
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -318,7 +318,8 @@ public class ProducerConfig extends AbstractConfig {
Ge commented on code in PR #13129:
URL: https://github.com/apache/kafka/pull/13129#discussion_r1081848092
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -319,6 +319,7 @@ public class ProducerConfig extends AbstractConfig {
/**
dajac commented on code in PR #13112:
URL: https://github.com/apache/kafka/pull/13112#discussion_r1081788435
##
core/src/main/scala/kafka/coordinator/group/GroupCoordinatorAdapter.scala:
##
@@ -557,25 +557,25 @@ private[group] class GroupCoordinatorAdapter(
}
override
jolshan commented on code in PR #13112:
URL: https://github.com/apache/kafka/pull/13112#discussion_r1081688123
##
core/src/main/scala/kafka/coordinator/group/GroupCoordinatorAdapter.scala:
##
@@ -557,25 +557,25 @@ private[group] class GroupCoordinatorAdapter(
}
override
jolshan commented on code in PR #13112:
URL: https://github.com/apache/kafka/pull/13112#discussion_r1081688123
##
core/src/main/scala/kafka/coordinator/group/GroupCoordinatorAdapter.scala:
##
@@ -557,25 +557,25 @@ private[group] class GroupCoordinatorAdapter(
}
override
jolshan commented on code in PR #13129:
URL: https://github.com/apache/kafka/pull/13129#discussion_r1081661935
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -319,6 +319,7 @@ public class ProducerConfig extends AbstractConfig {
/**
[ https://issues.apache.org/jira/browse/KAFKA-14638 ]
Justine Olshan deleted comment on KAFKA-14638:
was (Author: jolshan):
This is a bit tricky – the timer updates when the producer contacts the
transaction coordinator for the
jeffkbkim commented on code in PR #12972:
URL: https://github.com/apache/kafka/pull/12972#discussion_r1081656322
##
clients/src/main/resources/common/message/ConsumerGroupHeartbeatResponse.json:
##
@@ -0,0 +1,70 @@
+// Licensed to the Apache Software Foundation (ASF) under one
jeffkbkim commented on code in PR #12972:
URL: https://github.com/apache/kafka/pull/12972#discussion_r1081655338
##
clients/src/main/resources/common/message/ConsumerGroupHeartbeatResponse.json:
##
@@ -0,0 +1,70 @@
+// Licensed to the Apache Software Foundation (ASF) under one
[
https://issues.apache.org/jira/browse/KAFKA-14637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Akhilesh Chaganti resolved KAFKA-14637.
---
Fix Version/s: 3.4.0
Resolution: Fixed
> Upgrade to 3.4 from old versions (<
[
https://issues.apache.org/jira/browse/KAFKA-14638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678840#comment-17678840
]
Justine Olshan commented on KAFKA-14638:
This is a bit tricky – the timer updates when the
hachikuji commented on code in PR #13129:
URL: https://github.com/apache/kafka/pull/13129#discussion_r1081629522
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -319,6 +319,7 @@ public class ProducerConfig extends AbstractConfig {
/**
hachikuji commented on code in PR #13129:
URL: https://github.com/apache/kafka/pull/13129#discussion_r1081629522
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -319,6 +319,7 @@ public class ProducerConfig extends AbstractConfig {
/**
[
https://issues.apache.org/jira/browse/KAFKA-14638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-14638:
Issue Type: Improvement (was: Bug)
> Documentation for transaction.timeout.ms should be
[
https://issues.apache.org/jira/browse/KAFKA-14638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-14638:
Component/s: docs
> Documentation for transaction.timeout.ms should be more precise
>
cadonna merged PR #12821:
URL: https://github.com/apache/kafka/pull/12821
--
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:
cadonna commented on PR #12821:
URL: https://github.com/apache/kafka/pull/12821#issuecomment-1397370205
Build failures are unrelated:
```
Build / JDK 11 and Scala 2.13 /
org.apache.kafka.clients.consumer.KafkaConsumerTest.testReturnRecordsDuringRebalance()
Build / JDK 11 and Scala
kirktrue commented on code in PR #13119:
URL: https://github.com/apache/kafka/pull/13119#discussion_r1081589480
##
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/HttpAccessTokenRetriever.java:
##
@@ -240,6 +240,9 @@ static String
dajac commented on PR #13112:
URL: https://github.com/apache/kafka/pull/13112#issuecomment-1397338100
@jolshan Updated the PR.
--
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
dajac commented on code in PR #13112:
URL: https://github.com/apache/kafka/pull/13112#discussion_r1081583343
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinator.java:
##
@@ -215,4 +223,86 @@ CompletableFuture deleteOffsets(
kirktrue commented on code in PR #13119:
URL: https://github.com/apache/kafka/pull/13119#discussion_r1081575409
##
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/HttpAccessTokenRetriever.java:
##
@@ -240,6 +240,9 @@ static String
kirktrue commented on code in PR #13119:
URL: https://github.com/apache/kafka/pull/13119#discussion_r1081575409
##
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/HttpAccessTokenRetriever.java:
##
@@ -240,6 +240,9 @@ static String
dajac commented on code in PR #13112:
URL: https://github.com/apache/kafka/pull/13112#discussion_r1081571516
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -3448,7 +3445,7 @@ class KafkaApisTest {
val expectedJoinGroupResponse = new
dajac commented on code in PR #13112:
URL: https://github.com/apache/kafka/pull/13112#discussion_r1081571061
##
core/src/main/scala/kafka/coordinator/group/GroupCoordinatorAdapter.scala:
##
@@ -511,4 +532,53 @@ class GroupCoordinatorAdapter(
future
}
+
+ override def
fvaleri commented on PR #13131:
URL: https://github.com/apache/kafka/pull/13131#issuecomment-1397311675
Take a look at `DumpLogSegments` to see how `CommandDefaultOptions` is used.
It is much better than building the option list at the start of the
`main/execute` method.
--
This is an
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678799#comment-17678799
]
Terry Beard commented on KAFKA-14565:
-
[~ChrisEgerton] I've updated the ticket to incorporate your
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Terry Beard updated KAFKA-14565:
Description:
The Consumer and Producer interceptor interfaces and their corresponding Kafka
bbejeck commented on PR #8431:
URL: https://github.com/apache/kafka/pull/8431#issuecomment-1397212359
cherry-picked to 3.4
--
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.
[
https://issues.apache.org/jira/browse/KAFKA-14636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678790#comment-17678790
]
Ismael Juma commented on KAFKA-14636:
-
KAFKA-7632 and KAFKA-13361 are somewhat related.
>
mumrah merged PR #13130:
URL: https://github.com/apache/kafka/pull/13130
--
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:
bbejeck commented on PR #8431:
URL: https://github.com/apache/kafka/pull/8431#issuecomment-1397198456
Hi @maseiler, can you do the same PR for the [3.3 version of the streams
developer
guide](https://github.com/apache/kafka-site/blob/asf-site/33/streams/developer-guide/dsl-api.html)?
bbejeck commented on PR #8431:
URL: https://github.com/apache/kafka/pull/8431#issuecomment-1397167523
Thanks for the contribution @maseiler !
--
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
bbejeck commented on PR #8431:
URL: https://github.com/apache/kafka/pull/8431#issuecomment-1397166959
Merged #8431 into trunk
--
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
bbejeck merged PR #8431:
URL: https://github.com/apache/kafka/pull/8431
--
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:
maseiler commented on PR #8431:
URL: https://github.com/apache/kafka/pull/8431#issuecomment-1397133912
@mjsax, I solved the merge conflict and rebased it on the latest version
--
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-14636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov reassigned KAFKA-14636:
-
Assignee: Christo Lolov
> Compression optimization: Use zstd dictionary based
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Terry Beard updated KAFKA-14565:
Description:
The Consumer and Producer interceptor interfaces and their corresponding Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Terry Beard updated KAFKA-14565:
Description:
The Consumer and Producer interceptor interfaces and their corresponding Kafka
clolov commented on code in PR #12821:
URL: https://github.com/apache/kafka/pull/12821#discussion_r1081305288
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerUtilTest.java:
##
@@ -187,151 +137,107 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Terry Beard updated KAFKA-14565:
Description:
The Consumer and Producer interceptor interfaces and their corresponding Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Terry Beard updated KAFKA-14565:
Description:
The Consumer and Producer interceptor interfaces and their corresponding Kafka
cadonna merged PR #12818:
URL: https://github.com/apache/kafka/pull/12818
--
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:
cadonna commented on PR #12818:
URL: https://github.com/apache/kafka/pull/12818#issuecomment-1397015212
Build failures are unrelated:
```
Build / JDK 11 and Scala 2.13 /
kafka.controller.ControllerIntegrationTest.testPartitionReassignmentToBrokerWithOfflineLogDir()
Build / JDK 8
[
https://issues.apache.org/jira/browse/KAFKA-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri reassigned KAFKA-14582:
---
Assignee: Federico Valeri
> Move JmxTool to tools
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri reassigned KAFKA-14577:
---
Assignee: (was: Federico Valeri)
> Move ConsoleProducer to tools
>
[
https://issues.apache.org/jira/browse/KAFKA-14577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri reassigned KAFKA-14577:
---
Assignee: Federico Valeri
> Move ConsoleProducer to tools
>
fvaleri commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1081230571
##
build.gradle:
##
@@ -1757,6 +1757,7 @@ project(':tools') {
archivesBaseName = "kafka-tools"
dependencies {
+implementation project(':core')
Review
fvaleri commented on PR #13131:
URL: https://github.com/apache/kafka/pull/13131#issuecomment-1396923697
@clolov @vamossagar12 @tinaselenge
--
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
fvaleri commented on PR #13131:
URL: https://github.com/apache/kafka/pull/13131#issuecomment-1396922639
@mimaison @ijuma
--
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.
fvaleri opened a new pull request, #13131:
URL: https://github.com/apache/kafka/pull/13131
These classes are required by most commands, so they must be migrated first.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
cadonna commented on code in PR #12821:
URL: https://github.com/apache/kafka/pull/12821#discussion_r1081170724
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerUtilTest.java:
##
@@ -187,151 +137,107 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bojan Blagojevic updated KAFKA-14639:
-
Description:
I have an application that runs 6 consumers in parallel. I am getting some
Bojan Blagojevic created KAFKA-14639:
Summary: Kafka CooperativeStickyAssignor revokes/assigns partition
in one rebalance cycle
Key: KAFKA-14639
URL: https://issues.apache.org/jira/browse/KAFKA-14639
yashmayya commented on code in PR #12984:
URL: https://github.com/apache/kafka/pull/12984#discussion_r1081145849
##
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java:
##
@@ -712,8 +733,16 @@ KafkaBasedLog
clolov commented on code in PR #12821:
URL: https://github.com/apache/kafka/pull/12821#discussion_r1081139070
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerUtilTest.java:
##
@@ -187,151 +137,107 @@ public void
fvaleri commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1081057443
##
build.gradle:
##
@@ -1757,6 +1757,7 @@ project(':tools') {
archivesBaseName = "kafka-tools"
dependencies {
+implementation project(':core')
Review
vamossagar12 commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1081021244
##
build.gradle:
##
@@ -1757,6 +1757,7 @@ project(':tools') {
archivesBaseName = "kafka-tools"
dependencies {
+implementation project(':core')
Review
cadonna commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1081015656
##
build.gradle:
##
@@ -1757,6 +1757,7 @@ project(':tools') {
archivesBaseName = "kafka-tools"
dependencies {
+implementation project(':core')
Review
vamossagar12 commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1081010418
##
build.gradle:
##
@@ -1757,6 +1757,7 @@ project(':tools') {
archivesBaseName = "kafka-tools"
dependencies {
+implementation project(':core')
Review
vamossagar12 commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1081009344
##
build.gradle:
##
@@ -1757,6 +1757,7 @@ project(':tools') {
archivesBaseName = "kafka-tools"
dependencies {
+implementation project(':core')
Review
clolov commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1081007952
##
build.gradle:
##
@@ -1757,6 +1757,7 @@ project(':tools') {
archivesBaseName = "kafka-tools"
dependencies {
+implementation project(':core')
Review
cadonna commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1081000404
##
build.gradle:
##
@@ -1757,6 +1757,7 @@ project(':tools') {
archivesBaseName = "kafka-tools"
dependencies {
+implementation project(':core')
Review
cadonna commented on code in PR #12821:
URL: https://github.com/apache/kafka/pull/12821#discussion_r1080946697
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerUtilTest.java:
##
@@ -187,151 +137,107 @@ public void
cadonna commented on PR #12739:
URL: https://github.com/apache/kafka/pull/12739#issuecomment-1396582822
@shekhar-rajak Do you have any updates for this PR?
--
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
87 matches
Mail list logo
