Wayland Goodliffe created KAFKA-12732:
-
Summary: Possible Kerberos configuration bug in mirrormaker
Key: KAFKA-12732
URL: https://issues.apache.org/jira/browse/KAFKA-12732
Project: Kafka
hachikuji merged pull request #10480:
URL: https://github.com/apache/kafka/pull/10480
--
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.
For queries about this service,
[
https://issues.apache.org/jira/browse/KAFKA-12730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rajini Sivaram resolved KAFKA-12730.
Reviewer: Manikumar
Resolution: Fixed
> A single Kerberos login failure fails all
rajinisivaram merged pull request #10611:
URL: https://github.com/apache/kafka/pull/10611
--
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.
For queries about this service,
rajinisivaram commented on pull request #10611:
URL: https://github.com/apache/kafka/pull/10611#issuecomment-829240637
@omkreddy Thanks for the review, merging to trunk.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
Filip created KAFKA-12731:
-
Summary: High number of rebalances lead to GC Overhead limit
exceeded JVM crash
Key: KAFKA-12731
URL: https://issues.apache.org/jira/browse/KAFKA-12731
Project: Kafka
C0urante commented on a change in pull request #10563:
URL: https://github.com/apache/kafka/pull/10563#discussion_r623156186
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -631,13 +648,31 @@ private void rewind() {
C0urante commented on a change in pull request #10563:
URL: https://github.com/apache/kafka/pull/10563#discussion_r623156186
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -631,13 +648,31 @@ private void rewind() {
vitojeng commented on pull request #10597:
URL: https://github.com/apache/kafka/pull/10597#issuecomment-829215736
@ableegoldman Please take a look. :)
--
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
[
https://issues.apache.org/jira/browse/KAFKA-7260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1733#comment-1733
]
Sagar Pathak commented on KAFKA-7260:
-
Is this issue still open ?
We are facing same problem in
C0urante commented on pull request #10605:
URL: https://github.com/apache/kafka/pull/10605#issuecomment-829162686
Thanks for the ping @tombentley and thanks for the PR @ryannedolan! I've
left a more thorough summary of my thoughts on the ticket as I'm not sure a PR
is required at all at
[
https://issues.apache.org/jira/browse/KAFKA-12726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335592#comment-17335592
]
Ryanne Dolan commented on KAFKA-12726:
--
[~ChrisEgerton] ah, indeed I have conflated
satishd commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r623069794
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataSerde.java
##
@@ -0,0 +1,105 @@
[
https://issues.apache.org/jira/browse/KAFKA-12726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335638#comment-17335638
]
Chris Egerton commented on KAFKA-12726:
---
Ahhh, that makes sense. We wrestled with this a bit in
satishd commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r622766875
##
File path:
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentMetadata.java
##
@@ -270,9 +247,9 @@ public String
[
https://issues.apache.org/jira/browse/KAFKA-12265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-12265.
-
Resolution: Fixed
> Move the BatchAccumulator in KafkaRaftClient to LeaderState
>
ableegoldman commented on pull request #10608:
URL: https://github.com/apache/kafka/pull/10608#issuecomment-829526743
Handful of unrelated failures (as always, these days ) -- left a comment
on all their flaky test tickets
--
This is an automated message from the Apache Git Service.
ryannedolan commented on pull request #10605:
URL: https://github.com/apache/kafka/pull/10605#issuecomment-829527496
@C0urante thanks for pointing out the root of our confusion here. You're
right that task.stop() not being Task.stop() threw me.
I believe the problem still exists
jsancio commented on a change in pull request #10085:
URL: https://github.com/apache/kafka/pull/10085#discussion_r623370233
##
File path: raft/src/test/java/org/apache/kafka/raft/MockLog.java
##
@@ -363,33 +362,30 @@ public LogFetchInfo read(long startOffset, Isolation
spena opened a new pull request #10612:
URL: https://github.com/apache/kafka/pull/10612
Adds an internal flag that can be used to disable the fixes in KAFKA-10847.
It defaults to `true` if the flag is not set or has an invalid boolean value.
The flag is named
C0urante commented on a change in pull request #10563:
URL: https://github.com/apache/kafka/pull/10563#discussion_r623321728
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -680,13 +717,13 @@ public void
jsancio commented on a change in pull request #10085:
URL: https://github.com/apache/kafka/pull/10085#discussion_r623366415
##
File path: core/src/main/scala/kafka/tools/TestRaftServer.scala
##
@@ -226,7 +232,11 @@ class TestRaftServer(
reader.close()
}
jsancio commented on a change in pull request #10085:
URL: https://github.com/apache/kafka/pull/10085#discussion_r623370427
##
File path: raft/src/test/java/org/apache/kafka/raft/MockLog.java
##
@@ -426,48 +422,55 @@ public RawSnapshotWriter createSnapshot(OffsetAndEpoch
jsancio commented on a change in pull request #10085:
URL: https://github.com/apache/kafka/pull/10085#discussion_r623370656
##
File path:
raft/src/test/java/org/apache/kafka/raft/internals/RecordsIteratorTest.java
##
@@ -0,0 +1,190 @@
+/*
+ * Licensed to the Apache Software
Colin McCabe created KAFKA-12733:
Summary: KRaft: always bump leader epoch when changing the ISR for
a controlled shutdown
Key: KAFKA-12733
URL: https://issues.apache.org/jira/browse/KAFKA-12733
cmccabe merged pull request #10564:
URL: https://github.com/apache/kafka/pull/10564
--
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.
For queries about this service,
spena opened a new pull request #10613:
URL: https://github.com/apache/kafka/pull/10613
When users supply in-memory stores for left/outer joins, then the internal
shared outer store must be switch to in-memory store too. This will allow users
who want to keep all stores in memory to
ableegoldman merged pull request #10608:
URL: https://github.com/apache/kafka/pull/10608
--
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.
For queries about this service,
ableegoldman commented on pull request #10608:
URL: https://github.com/apache/kafka/pull/10608#issuecomment-829528563
I'm going to merge this now since Walker approved it (thanks!) and I'm
waiting to rebase the NamedTopology PR on top of these changes. If anyone comes
across this and has
jsancio commented on a change in pull request #10085:
URL: https://github.com/apache/kafka/pull/10085#discussion_r623367035
##
File path: raft/src/main/java/org/apache/kafka/raft/BatchReader.java
##
@@ -60,19 +61,21 @@
@Override
void close();
-class Batch {
+
[
https://issues.apache.org/jira/browse/KAFKA-12668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maksim Iakunin reassigned KAFKA-12668:
--
Assignee: Maksim Iakunin
> MockScheduler is not safe to use in concurrent code.
>
wcarlson5 commented on a change in pull request #10608:
URL: https://github.com/apache/kafka/pull/10608#discussion_r623295241
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImplTest.java
##
@@ -152,28 +150,6 @@ public void
C0urante commented on a change in pull request #10563:
URL: https://github.com/apache/kafka/pull/10563#discussion_r623409533
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -680,13 +717,13 @@ public void
jsancio commented on a change in pull request #10085:
URL: https://github.com/apache/kafka/pull/10085#discussion_r623368881
##
File path: raft/src/test/java/org/apache/kafka/raft/RaftClientTestContext.java
##
@@ -1081,24 +1103,25 @@ OptionalInt currentClaimedEpoch() {
rondagostino commented on pull request #10604:
URL: https://github.com/apache/kafka/pull/10604#issuecomment-829572710
> Could you also update the "Co-located Raft quorum" comment in the init
section with starting node id as 1?
Nice catch, @kamalcph! I think I fixed what you were
kowshik commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r623276793
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogSegmentMetadataTransform.java
##
@@ -0,0
[
https://issues.apache.org/jira/browse/KAFKA-7964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335780#comment-17335780
]
A. Sophie Blee-Goldman commented on KAFKA-7964:
---
Failed again, with a different error this
C0urante commented on a change in pull request #10563:
URL: https://github.com/apache/kafka/pull/10563#discussion_r623328064
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -680,13 +717,13 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-5492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335786#comment-17335786
]
A. Sophie Blee-Goldman commented on KAFKA-5492:
---
Failed again:
Stacktrace
[
https://issues.apache.org/jira/browse/KAFKA-6409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-6409.
---
Resolution: Duplicate
> LogRecoveryTest
[
https://issues.apache.org/jira/browse/KAFKA-12668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335684#comment-17335684
]
Maksim Iakunin commented on KAFKA-12668:
This is my first issue in the Kafka project and I'll
junrao commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r623251580
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/BytesApiMessageSerde.java
##
@@ -0,0 +1,68 @@
+/*
+
cmccabe commented on a change in pull request #10564:
URL: https://github.com/apache/kafka/pull/10564#discussion_r623286027
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -356,7 +367,9 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335773#comment-17335773
]
A. Sophie Blee-Goldman commented on KAFKA-9295:
---
Failed again, same stacktrace. I take back
jsancio commented on a change in pull request #10085:
URL: https://github.com/apache/kafka/pull/10085#discussion_r623369093
##
File path: raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java
##
@@ -717,7 +720,8 @@ void start(int nodeId) {
ableegoldman opened a new pull request #10615:
URL: https://github.com/apache/kafka/pull/10615
Basically just the API of https://github.com/apache/kafka/pull/10609, should
not contain any logical changes in Streams at this point (for example I also
stripped out the protocol change for
wenbingshen commented on pull request #10617:
URL: https://github.com/apache/kafka/pull/10617#issuecomment-829766268
@junrao @ijuma @chia7712 Can you take a look at this PR? Thanks. :)
--
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-12734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenbing Shen reassigned KAFKA-12734:
Assignee: Wenbing Shen
> LazyTimeIndex & LazyOffsetIndex may cause niobufferoverflow
feyman2016 commented on a change in pull request #10593:
URL: https://github.com/apache/kafka/pull/10593#discussion_r623574263
##
File path: raft/src/test/java/org/apache/kafka/snapshot/SnapshotWriterTest.java
##
@@ -38,7 +38,7 @@
@Test
public void
ableegoldman edited a comment on pull request #10559:
URL: https://github.com/apache/kafka/pull/10559#issuecomment-829797388
Do we really need to disable them or is there a fix in the works? I'm fine
with disabling so long as someone is actively looking into this, but given this
is such a
ableegoldman commented on pull request #10559:
URL: https://github.com/apache/kafka/pull/10559#issuecomment-829797388
Do we really need to disable them or is there a fix in the works? I'm fine
with disabling so long as someone is actively looking into this, but given this
is such a
[
https://issues.apache.org/jira/browse/KAFKA-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-10555:
---
Fix Version/s: 2.8.0
> Improve client state machine
>
ableegoldman edited a comment on pull request #10608:
URL: https://github.com/apache/kafka/pull/10608#issuecomment-829528563
I'm going to merge this now since Walker approved it (thanks!) and I'm
waiting to rebase the NamedTopology PR on top of these changes. If anyone comes
across this
wenbingshen opened a new pull request #10617:
URL: https://github.com/apache/kafka/pull/10617
The detailed stack information is linked to this jiraId
[KAFKA-12734](https://issues.apache.org/jira/browse/KAFKA-12734)
### Committer Checklist (excluded from commit message)
- [ ]
feyman2016 commented on a change in pull request #10593:
URL: https://github.com/apache/kafka/pull/10593#discussion_r623569039
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -2268,6 +2269,25 @@ private Long append(int epoch, List records,
feyman2016 commented on a change in pull request #10593:
URL: https://github.com/apache/kafka/pull/10593#discussion_r623574263
##
File path: raft/src/test/java/org/apache/kafka/snapshot/SnapshotWriterTest.java
##
@@ -38,7 +38,7 @@
@Test
public void
ableegoldman commented on pull request #10615:
URL: https://github.com/apache/kafka/pull/10615#issuecomment-829737080
@wcarlson5 @guozhangwang @rodesai -- Walker let me know if there's anything
else you need, but I think this should be sufficient to unblock work on the POC
while I
ableegoldman commented on a change in pull request #10615:
URL: https://github.com/apache/kafka/pull/10615#discussion_r623529336
##
File path: streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java
##
@@ -64,50 +97,98 @@ public static TaskId parse(final String
Wenbing Shen created KAFKA-12734:
Summary: LazyTimeIndex & LazyOffsetIndex may cause
niobufferoverflow when skip activeSegment sanityCheck
Key: KAFKA-12734
URL: https://issues.apache.org/jira/browse/KAFKA-12734
lwsbox commented on pull request #5997:
URL: https://github.com/apache/kafka/pull/5997#issuecomment-829737677
> Discussed with Jason and will create a new PR that avoids acquiring
`Partition#leaderIsrUpdateLock` while holding the lock.
which PR？
--
This is an automated message
[
https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337019#comment-17337019
]
Matthias J. Sax commented on KAFKA-12718:
-
Well, `gracePeriod` is a generic concept that applies
[
https://issues.apache.org/jira/browse/KAFKA-12726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337024#comment-17337024
]
Chris Egerton commented on KAFKA-12726:
---
Okay, that makes the problem clearer (y). Maybe we can
mjsax merged pull request #10548:
URL: https://github.com/apache/kafka/pull/10548
--
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.
For queries about this service, please
mjsax commented on pull request #10548:
URL: https://github.com/apache/kafka/pull/10548#issuecomment-829758387
Thanks for the PR @Nathan22177! Merged to `trunk`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
ableegoldman edited a comment on pull request #10608:
URL: https://github.com/apache/kafka/pull/10608#issuecomment-829528563
I'm going to merge this now since Walker approved it (thanks!) and I'm
waiting to rebase the NamedTopology PR on top of these changes. If anyone comes
across this
hachikuji opened a new pull request #10616:
URL: https://github.com/apache/kafka/pull/10616
This patch adds `Admin` support for the `listTransactions` API, which was
added by
feyman2016 commented on a change in pull request #10593:
URL: https://github.com/apache/kafka/pull/10593#discussion_r623566646
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -2268,6 +2269,25 @@ private Long append(int epoch, List records,
[
https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337048#comment-17337048
]
Luke Chen commented on KAFKA-12629:
---
I have a PR to disable the frequently failed tests. Still waiting
dengziming opened a new pull request #10618:
URL: https://github.com/apache/kafka/pull/10618
*More detailed description of your change*
`IntegrationTestHelper` is not right.
*Summary of testing strategy (including rationale)
for the feature or bug fix. Unit and/or
dengziming commented on pull request #10618:
URL: https://github.com/apache/kafka/pull/10618#issuecomment-829787194
@mumrah ,Hello, PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the
[
https://issues.apache.org/jira/browse/KAFKA-12663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-12663:
---
Fix Version/s: 3.0.0
> Update FindCoordinator to resolve multiple
[
https://issues.apache.org/jira/browse/KAFKA-12663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337059#comment-17337059
]
Konstantine Karantasis commented on KAFKA-12663:
According
[
https://issues.apache.org/jira/browse/KAFKA-12234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337067#comment-17337067
]
Konstantine Karantasis commented on KAFKA-12234:
According to
[
https://issues.apache.org/jira/browse/KAFKA-12234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-12234:
---
Fix Version/s: 3.0.0
> Extend OffsetFetch requests to accept multiple group
xjin-Confluent opened a new pull request #10614:
URL: https://github.com/apache/kafka/pull/10614
This is to resolve CVE: CVE-2021-28168
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
[
https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337042#comment-17337042
]
John Roesler commented on KAFKA-12718:
--
Thanks for reporting this, [~mjsax] !
What [~ableegoldman]
ableegoldman commented on pull request #6592:
URL: https://github.com/apache/kafka/pull/6592#issuecomment-829779733
Hey @yeralin one other thing, can you give the KIP document a quick pass and
make sure everything in there is up to date with what we've discussed and
anything else that's
[
https://issues.apache.org/jira/browse/KAFKA-12663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337059#comment-17337059
]
Konstantine Karantasis edited comment on KAFKA-12663 at 4/30/21, 4:27 AM:
Nathan22177 commented on pull request #10548:
URL: https://github.com/apache/kafka/pull/10548#issuecomment-829635490
> To avoid checkstyle and test issues, and reduce review turn-around time, I
would recommend to run unit tests and checkstyle locally before pushing update:
`./gradlew
C0urante commented on a change in pull request #10563:
URL: https://github.com/apache/kafka/pull/10563#discussion_r623442240
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -680,13 +717,13 @@ public void
C0urante commented on a change in pull request #10563:
URL: https://github.com/apache/kafka/pull/10563#discussion_r623442240
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -680,13 +717,13 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-12682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-12682:
--
Assignee: Justine Olshan
> Kraft MetadataPartitionsBuilder _localChanged and
[
https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336997#comment-17336997
]
A. Sophie Blee-Goldman commented on KAFKA-12718:
{quote}I was just looking into
vitojeng commented on pull request #10597:
URL: https://github.com/apache/kafka/pull/10597#issuecomment-829640637
Oh, I get your point. This make sense and totally agree. Thanks
@ableegoldman for explanation.
--
This is an automated message from the Apache Git Service.
To respond to the
ableegoldman commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r623436340
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -163,127 +159,180 @@ private
[
https://issues.apache.org/jira/browse/KAFKA-12682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-12682:
--
Assignee: (was: Justine Olshan)
> Kraft MetadataPartitionsBuilder _localChanged
[
https://issues.apache.org/jira/browse/KAFKA-12726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336550#comment-17336550
]
Ryanne Dolan commented on KAFKA-12726:
--
[~ChrisEgerton] Yeah, the problem is that we were seeing,
Nathan22177 commented on a change in pull request #10548:
URL: https://github.com/apache/kafka/pull/10548#discussion_r621063125
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredSessionStoreTest.java
##
@@ -472,11 +472,26 @@ public void
jolshan commented on pull request #10602:
URL: https://github.com/apache/kafka/pull/10602#issuecomment-829412493
Can we also add some of the newer versions to`downgrade_test.py`? We've
fallen behind on some of the versions there.
--
This is an automated message from the Apache Git
junrao commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r623253824
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogSegmentMetadataTransform.java
##
@@ -0,0
ableegoldman commented on a change in pull request #10608:
URL: https://github.com/apache/kafka/pull/10608#discussion_r623325017
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImplTest.java
##
@@ -152,28 +150,6 @@ public
[
https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335783#comment-17335783
]
A. Sophie Blee-Goldman commented on KAFKA-12629:
This test has multiple failures on
ableegoldman commented on pull request #10597:
URL: https://github.com/apache/kafka/pull/10597#issuecomment-829564963
Thanks @vitojeng -- just to clarify, I was proposing that we do throw the
StreamsNotStartedException for the `#allMetadata`, `#allMetadataForStore`, and
jsancio commented on a change in pull request #10085:
URL: https://github.com/apache/kafka/pull/10085#discussion_r623367352
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -311,8 +311,18 @@ private void updateListenersProgress(long
jsancio commented on a change in pull request #10085:
URL: https://github.com/apache/kafka/pull/10085#discussion_r623367561
##
File path:
raft/src/main/java/org/apache/kafka/raft/internals/RecordsIterator.java
##
@@ -0,0 +1,238 @@
+/*
+ * Licensed to the Apache Software
showuon commented on pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#issuecomment-829025045
@ableegoldman , I've addressed all your comments, and have some code
refactor. What I did are:
1. remove `sortedAllPartitions` to save memory
2. put all logic related to
tombentley commented on pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#issuecomment-829027535
@hachikuji that's much better, thank you. I added some logging where we
ignore on the remove path, hope that's OK.
--
This is an automated message from the Apache Git
Rajini Sivaram created KAFKA-12730:
--
Summary: A single Kerberos login failure fails all future
connections from Java 9 onwards
Key: KAFKA-12730
URL: https://issues.apache.org/jira/browse/KAFKA-12730
showuon commented on a change in pull request #10509:
URL: https://github.com/apache/kafka/pull/10509#discussion_r622780715
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -163,127 +159,181 @@ private boolean
kowshik commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r622786594
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataSerde.java
##
@@ -0,0 +1,105 @@
1 - 100 of 115 matches
Mail list logo
