[
https://issues.apache.org/jira/browse/KAFKA-13128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-13128:
---
Fix Version/s: (was: 2.8.1)
(was: 3.0.0)
> Flaky
[
https://issues.apache.org/jira/browse/KAFKA-13128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reopened KAFKA-13128:
Assignee: (was: A. Sophie Blee-Goldman)
Failed again for a different
dielhennr commented on a change in pull request #11179:
URL: https://github.com/apache/kafka/pull/11179#discussion_r683960767
##
File path: core/src/main/scala/kafka/raft/RaftManager.scala
##
@@ -214,6 +220,12 @@ class KafkaRaftManager[T](
KafkaRaftManager.createLogDirecto
guozhangwang commented on pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#issuecomment-893993452
LGTM! Please feel free to merge after green builds.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
guozhangwang commented on a change in pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#discussion_r683938654
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java
##
@@ -67,13 +72,31 @@
public class Name
guozhangwang commented on a change in pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#discussion_r683938587
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyMetadata.java
##
@@ -53,44 +56,162 @@
private static f
showuon commented on a change in pull request #11175:
URL: https://github.com/apache/kafka/pull/11175#discussion_r683905633
##
File path: config/kraft/README.md
##
@@ -26,7 +27,7 @@ xtzWWN4bTjitpL3kfd9s5g
## Format Storage Directories
-The next step is to format your s
ableegoldman commented on a change in pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#discussion_r683902306
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -517,9 +526,9 @@ void handleRevocation(final
ableegoldman commented on a change in pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#discussion_r683902306
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -517,9 +526,9 @@ void handleRevocation(final
showuon commented on a change in pull request #11184:
URL: https://github.com/apache/kafka/pull/11184#discussion_r683900989
##
File path: docs/streams/upgrade-guide.html
##
@@ -52,6 +52,15 @@ Upgrade Guide and API Changes
restart all new ({{fullDotVersion}}) applicati
ableegoldman commented on a change in pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#discussion_r683901855
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -775,26 +806,16 @@ private void completeTask
dielhennr commented on a change in pull request #11179:
URL: https://github.com/apache/kafka/pull/11179#discussion_r683894514
##
File path: core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala
##
@@ -262,6 +262,8 @@ class KafkaConfigTest {
props.put(KafkaConfig.Proc
zhaohaidao commented on pull request #11182:
URL: https://github.com/apache/kafka/pull/11182#issuecomment-893935065
@jsancio Could you please review this pr if you have time, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
dielhennr commented on a change in pull request #11179:
URL: https://github.com/apache/kafka/pull/11179#discussion_r683880423
##
File path: core/src/test/scala/unit/kafka/raft/RaftManagerTest.scala
##
@@ -34,21 +34,30 @@ import org.mockito.Mockito._
class RaftManagerTest {
[
https://issues.apache.org/jira/browse/KAFKA-13132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-13132.
-
Resolution: Fixed
> Upgrading to topic IDs in LISR requests has gaps introduced in 3.0
>
dielhennr commented on a change in pull request #11179:
URL: https://github.com/apache/kafka/pull/11179#discussion_r683879932
##
File path: core/src/test/scala/unit/kafka/raft/RaftManagerTest.scala
##
@@ -34,21 +34,30 @@ import org.mockito.Mockito._
class RaftManagerTest {
hachikuji merged pull request #11171:
URL: https://github.com/apache/kafka/pull/11171
--
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-unsubsc
ableegoldman commented on a change in pull request #11184:
URL: https://github.com/apache/kafka/pull/11184#discussion_r683876709
##
File path: docs/streams/upgrade-guide.html
##
@@ -52,6 +52,15 @@ Upgrade Guide and API Changes
restart all new ({{fullDotVersion}}) appl
ableegoldman commented on a change in pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#discussion_r683874039
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -719,6 +723,8 @@ void runOnce() {
ableegoldman commented on a change in pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#discussion_r683872205
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyMetadata.java
##
@@ -53,44 +56,162 @@
private static f
Michael Jaschob created KAFKA-13174:
---
Summary: Log Compaction Blocked Forever by Unstable
Offset/Unclosed Transaction
Key: KAFKA-13174
URL: https://issues.apache.org/jira/browse/KAFKA-13174
Project:
jsancio commented on a change in pull request #11179:
URL: https://github.com/apache/kafka/pull/11179#discussion_r683859800
##
File path: core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala
##
@@ -262,6 +262,8 @@ class KafkaConfigTest {
props.put(KafkaConfig.Proces
ableegoldman commented on a change in pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#discussion_r683851998
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -1193,6 +1189,18 @@ public void updateTaskEn
guozhangwang commented on pull request #11184:
URL: https://github.com/apache/kafka/pull/11184#issuecomment-893876355
ping @ableegoldman @cadonna for reviews.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
guozhangwang opened a new pull request #11184:
URL: https://github.com/apache/kafka/pull/11184
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including
[
https://issues.apache.org/jira/browse/KAFKA-13170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394358#comment-17394358
]
Guozhang Wang commented on KAFKA-13170:
---
I think I know the reason of this flaky t
guozhangwang commented on a change in pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#discussion_r683823753
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyMetadata.java
##
@@ -53,44 +56,162 @@
private static f
ableegoldman commented on pull request #11183:
URL: https://github.com/apache/kafka/pull/11183#issuecomment-893863088
Merged to trunk and cherrypicked to 3.0 to help stabilize system tests (cc
@kkonstantine)
--
This is an automated message from the Apache Git Service.
To respond to the m
ableegoldman merged pull request #11183:
URL: https://github.com/apache/kafka/pull/11183
--
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
ableegoldman commented on pull request #11183:
URL: https://github.com/apache/kafka/pull/11183#issuecomment-893861008
One unrelated flaky test failure in `
kafka.api.PlaintextConsumerTest.testListTopics()`
--
This is an automated message from the Apache Git Service.
To respond to the mes
[
https://issues.apache.org/jira/browse/KAFKA-13173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394319#comment-17394319
]
Jason Gustafson commented on KAFKA-13173:
-
I upgraded this bug to a blocker beca
[
https://issues.apache.org/jira/browse/KAFKA-13173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-13173:
Description:
In `ReplicationControlManager.fenceStaleBrokers`, we find all of the current
vvcephei merged pull request #11153:
URL: https://github.com/apache/kafka/pull/11153
--
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-13172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394313#comment-17394313
]
Guozhang Wang commented on KAFKA-13172:
---
Yes, that's correct.
> Document in Strea
[
https://issues.apache.org/jira/browse/KAFKA-13173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niket Goel reassigned KAFKA-13173:
--
Assignee: Niket Goel
> KRaft controller does not handle simultaneous broker expirations corre
[
https://issues.apache.org/jira/browse/KAFKA-13173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-13173:
Fix Version/s: 3.0.0
> KRaft controller does not handle simultaneous broker expirations co
[
https://issues.apache.org/jira/browse/KAFKA-13173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-13173:
Priority: Blocker (was: Major)
> KRaft controller does not handle simultaneous broker exp
guozhangwang merged pull request #11151:
URL: https://github.com/apache/kafka/pull/11151
--
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
Jason Gustafson created KAFKA-13173:
---
Summary: KRaft controller does not handle simultaneous broker
expirations correctly
Key: KAFKA-13173
URL: https://issues.apache.org/jira/browse/KAFKA-13173
Proj
ableegoldman merged pull request #11156:
URL: https://github.com/apache/kafka/pull/11156
--
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
ableegoldman commented on a change in pull request #11156:
URL: https://github.com/apache/kafka/pull/11156#discussion_r683763243
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -142,12 +142,11 @@ private boolean
[
https://issues.apache.org/jira/browse/KAFKA-13172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394279#comment-17394279
]
A. Sophie Blee-Goldman commented on KAFKA-13172:
Just to clarify, a roll
jzaralim opened a new pull request #11183:
URL: https://github.com/apache/kafka/pull/11183
The streams static membership test has failed several times due to hitting
the Kafka shutdown timeout, but the logs were showing that the shutdown did
actually succeed after the 60 second timeout.
Guozhang Wang created KAFKA-13172:
-
Summary: Document in Streams 3.0 that due to rocksDB footer
version in-filght downgrade is not supported
Key: KAFKA-13172
URL: https://issues.apache.org/jira/browse/KAFKA-13172
mjsax commented on pull request #11172:
URL: https://github.com/apache/kafka/pull/11172#issuecomment-893689864
Merged to `trunk` and cherry-picked to `3.0` branch.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
mjsax merged pull request #11172:
URL: https://github.com/apache/kafka/pull/11172
--
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...
dielhennr commented on a change in pull request #11179:
URL: https://github.com/apache/kafka/pull/11179#discussion_r683690243
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1949,6 +1951,17 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
Boo
hachikuji commented on a change in pull request #11171:
URL: https://github.com/apache/kafka/pull/11171#discussion_r683680618
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -553,6 +553,17 @@ class Log(@volatile var logStartOffset: Long,
/** Only used for ZK cl
junrao commented on a change in pull request #11154:
URL: https://github.com/apache/kafka/pull/11154#discussion_r683680502
##
File path: core/src/main/scala/kafka/log/UnifiedLog.scala
##
@@ -1738,12 +1747,12 @@ object Log extends Logging {
logDirFailureChannel: Log
[
https://issues.apache.org/jira/browse/KAFKA-12616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-12616:
---
Fix Version/s: 3.1.0
> Convert integration tests to use ClusterTest
mumrah commented on a change in pull request #11179:
URL: https://github.com/apache/kafka/pull/11179#discussion_r68365
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1949,6 +1951,17 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
Boolea
[
https://issues.apache.org/jira/browse/KAFKA-13168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-13168:
-
Fix Version/s: 3.1.0
> KRaft observers should not have a replica id
> --
[
https://issues.apache.org/jira/browse/KAFKA-13168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur resolved KAFKA-13168.
--
Resolution: Fixed
> KRaft observers should not have a replica id
> ---
[
https://issues.apache.org/jira/browse/KAFKA-13167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-13167.
-
Fix Version/s: 3.0.0
Resolution: Fixed
> KRaft broker should heartbeat immediatel
dielhennr commented on a change in pull request #11179:
URL: https://github.com/apache/kafka/pull/11179#discussion_r683626287
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1949,6 +1951,17 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
Boo
kowshik commented on a change in pull request #11154:
URL: https://github.com/apache/kafka/pull/11154#discussion_r683616272
##
File path: core/src/main/scala/kafka/log/UnifiedLog.scala
##
@@ -248,16 +250,16 @@ case object SnapshotGenerated extends
LogStartOffsetIncrementReason
wcarlson5 edited a comment on pull request #11153:
URL: https://github.com/apache/kafka/pull/11153#issuecomment-893137087
@vvcephei looks like it is working now
EDIT: nvm odd failure, I don't think that should be a failure. Trying to
reproduce locally
`java.lang.AssertionError
wcarlson5 edited a comment on pull request #11153:
URL: https://github.com/apache/kafka/pull/11153#issuecomment-893137087
@vvcephei looks like it is working now
EDIT: nvm odd failure
`java.lang.AssertionError: Unexpected exception thrown while getting the
value from store.
wcarlson5 edited a comment on pull request #11153:
URL: https://github.com/apache/kafka/pull/11153#issuecomment-893137087
@vvcephei looks like it is working now
EDIT: nvm odd failure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
ccding commented on a change in pull request #0:
URL: https://github.com/apache/kafka/pull/0#discussion_r683573626
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java
##
@@ -253,9 +253,9 @@ public RemoteLogManagerC
ccding commented on a change in pull request #0:
URL: https://github.com/apache/kafka/pull/0#discussion_r683573626
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java
##
@@ -253,9 +253,9 @@ public RemoteLogManagerC
ccding commented on a change in pull request #0:
URL: https://github.com/apache/kafka/pull/0#discussion_r683573626
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java
##
@@ -253,9 +253,9 @@ public RemoteLogManagerC
ccding commented on a change in pull request #0:
URL: https://github.com/apache/kafka/pull/0#discussion_r683573626
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java
##
@@ -253,9 +253,9 @@ public RemoteLogManagerC
zhaohaidao opened a new pull request #11182:
URL: https://github.com/apache/kafka/pull/11182
The current implement of MockLog doesn't implement maybeClean. It is
expected that MockLog has the same semantic as KafkaMetadataLog. This is
assumed to be true for a few of the tests suite like th
mumrah commented on pull request #11178:
URL: https://github.com/apache/kafka/pull/11178#issuecomment-893549648
cherry-picked to 3.0 as 765d2006a32d7a
--
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 g
mumrah merged pull request #11178:
URL: https://github.com/apache/kafka/pull/11178
--
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..
mumrah commented on a change in pull request #11179:
URL: https://github.com/apache/kafka/pull/11179#discussion_r683552057
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1949,6 +1951,17 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
Boolea
satishd commented on pull request #11058:
URL: https://github.com/apache/kafka/pull/11058#issuecomment-893543468
@junrao: Please review this PR once
https://github.com/apache/kafka/pull/11060 is reviewed and merged.
--
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/KAFKA-12935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-12935.
--
> Flaky Test
> RestoreIntegrationTest.shouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNot
[
https://issues.apache.org/jira/browse/KAFKA-13171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Claudio Carcaci updated KAFKA-13171:
Priority: Trivial (was: Major)
> KIP-500 Setup and named docker volumes
> ---
[
https://issues.apache.org/jira/browse/KAFKA-13171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Claudio Carcaci updated KAFKA-13171:
Priority: Major (was: Trivial)
> KIP-500 Setup and named docker volumes
> ---
Claudio Carcaci created KAFKA-13171:
---
Summary: KIP-500 Setup and named docker volumes
Key: KAFKA-13171
URL: https://issues.apache.org/jira/browse/KAFKA-13171
Project: Kafka
Issue Type: Impr
mimaison commented on pull request #11174:
URL: https://github.com/apache/kafka/pull/11174#issuecomment-893504255
Thanks for the PR, it looks good. Is it possible to add a test for it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
tombentley commented on a change in pull request #10807:
URL: https://github.com/apache/kafka/pull/10807#discussion_r683481734
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -692,6 +692,7 @@ class KafkaApis(val requestChannel: RequestChannel,
fetchR
mimaison commented on a change in pull request #10277:
URL: https://github.com/apache/kafka/pull/10277#discussion_r683463480
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java
##
@@ -489,7 +489,17 @@ boolean isCycle(String top
[
https://issues.apache.org/jira/browse/KAFKA-5966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-5966:
Assignee: Luke Chen
> Support ByteBuffer serialization in Kafka Streams
>
ijuma commented on pull request #0:
URL: https://github.com/apache/kafka/pull/0#issuecomment-893407158
Thanks for explaining the motivation @ccding. In my opinion, this is a bit
confusing. What makes remote log configs special when compared to local log
configs? The same arguments
mimaison commented on a change in pull request #10807:
URL: https://github.com/apache/kafka/pull/10807#discussion_r683367337
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -692,6 +692,7 @@ class KafkaApis(val requestChannel: RequestChannel,
fetchReq
satishd commented on a change in pull request #0:
URL: https://github.com/apache/kafka/pull/0#discussion_r683370891
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java
##
@@ -253,9 +253,9 @@ public RemoteLogManager
junrao commented on a change in pull request #11154:
URL: https://github.com/apache/kafka/pull/11154#discussion_r682801773
##
File path: core/src/main/scala/kafka/log/UnifiedLog.scala
##
@@ -248,16 +250,16 @@ case object SnapshotGenerated extends
LogStartOffsetIncrementReason
joel-hamill commented on pull request #11163:
URL: https://github.com/apache/kafka/pull/11163#issuecomment-892895687
LGTM, had one comment
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the spe
ableegoldman commented on pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#issuecomment-893124886
--
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 uns
mumrah merged pull request #11166:
URL: https://github.com/apache/kafka/pull/11166
--
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..
axrj commented on pull request #8906:
URL: https://github.com/apache/kafka/pull/8906#issuecomment-892663172
Hey,
Is there any plan to merge this? It would be great to have this patch
backported too if possible.
--
This is an automated message from the Apache Git Service.
To respon
cmccabe merged pull request #11130:
URL: https://github.com/apache/kafka/pull/11130
--
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.
cmccabe merged pull request #11168:
URL: https://github.com/apache/kafka/pull/11168
--
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.
ijuma merged pull request #11150:
URL: https://github.com/apache/kafka/pull/11150
--
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 a change in pull request #10602:
URL: https://github.com/apache/kafka/pull/10602#discussion_r682637061
##
File path: tests/kafkatest/tests/streams/streams_upgrade_test.py
##
@@ -25,15 +25,17 @@
from kafkatest.services.zookeeper import ZookeeperService
fr
hachikuji merged pull request #11177:
URL: https://github.com/apache/kafka/pull/11177
--
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-unsubsc
rondagostino commented on a change in pull request #11175:
URL: https://github.com/apache/kafka/pull/11175#discussion_r682834005
##
File path: config/kraft/README.md
##
@@ -14,8 +14,9 @@ Most important of all, KRaft mode is more scalable. We
expect to be able to [su
# Quicks
cmccabe commented on a change in pull request #11168:
URL: https://github.com/apache/kafka/pull/11168#discussion_r682803659
##
File path:
core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala
##
@@ -203,7 +203,15 @@ class BrokerMetadataPublisher(conf: KafkaCo
hachikuji commented on a change in pull request #11171:
URL: https://github.com/apache/kafka/pull/11171#discussion_r683019148
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -553,6 +553,14 @@ class Log(@volatile var logStartOffset: Long,
/** Only used for ZK cl
kowshik commented on a change in pull request #0:
URL: https://github.com/apache/kafka/pull/0#discussion_r683184053
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java
##
@@ -253,9 +253,9 @@ public RemoteLogManager
mumrah edited a comment on pull request #11166:
URL: https://github.com/apache/kafka/pull/11166#issuecomment-892067696
--
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 un
dielhennr closed pull request #11159:
URL: https://github.com/apache/kafka/pull/11159
--
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-unsubsc
ccding commented on a change in pull request #0:
URL: https://github.com/apache/kafka/pull/0#discussion_r683068699
##
File path: core/src/main/scala/kafka/log/LogConfig.scala
##
@@ -107,46 +107,52 @@ case class LogConfig(props: java.util.Map[_, _],
overriddenConfigs: S
jlprat commented on pull request #10784:
URL: https://github.com/apache/kafka/pull/10784#issuecomment-892521275
Pinging @vvcephei
Would you be able to merger this before more commits get in the way and we
need another rebase?
Thanks a ton!
--
This is an automated message from the A
mumrah commented on pull request #11166:
URL: https://github.com/apache/kafka/pull/11166#issuecomment-892891735
Spoke with @vvcephei about the streams smoke test and it is a known flaky.
We are good-to-go with enabling KRaft for this test.
--
This is an automated message from the Apache
junrao commented on a change in pull request #0:
URL: https://github.com/apache/kafka/pull/0#discussion_r682820398
##
File path: core/src/main/scala/kafka/log/LogConfig.scala
##
@@ -107,46 +107,52 @@ case class LogConfig(props: java.util.Map[_, _],
overriddenConfigs: S
jolshan commented on pull request #11171:
URL: https://github.com/apache/kafka/pull/11171#issuecomment-893066311
--
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 unsubscr
1 - 100 of 143 matches
Mail list logo
