Lincong Li created KAFKA-10823:
--
Summary: AdminOperationException has no error code
Key: KAFKA-10823
URL: https://issues.apache.org/jira/browse/KAFKA-10823
Project: Kafka
Issue Type: Bug
lmr3796 commented on pull request #9435:
URL: https://github.com/apache/kafka/pull/9435#issuecomment-740431014
@chia7712 @ijuma I just rebased to latest trunk. Please take a look
This is an automated message from the Apache
showuon commented on pull request #9672:
URL: https://github.com/apache/kafka/pull/9672#issuecomment-740423573
Hey @chia7712 , thanks for reminding. I know that actually, but actually, I
think there's some other issues in this test. Just want to find it out. Maybe
I'm wrong, but I just
chia7712 commented on pull request #9672:
URL: https://github.com/apache/kafka/pull/9672#issuecomment-740413073
FYI: #9688
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
UnityLung closed pull request #9703:
URL: https://github.com/apache/kafka/pull/9703
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
[
https://issues.apache.org/jira/browse/KAFKA-10822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-10822:
---
Summary: Force some stdout from downgrade_test.py/upgrade_test.py for
Travis (was: Force
[
https://issues.apache.org/jira/browse/KAFKA-10822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-10822:
---
Description: downgrade_test.py/upgrade_test.py does upgrade/downgrade for
each tests. the
[
https://issues.apache.org/jira/browse/KAFKA-10822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-10822:
---
Description: downgrade_test.py does upgrade/downgrade for each tests. the
upgrade/downgrade
chia7712 opened a new pull request #9712:
URL: https://github.com/apache/kafka/pull/9712
downgrade_test.py does upgrade/downgrade for each tests. the
upgrade/downgrade tasks take 10+ mins in Travis env so we ought to print
something in order to avoid timeout caused by Travis.
###
Chia-Ping Tsai created KAFKA-10822:
--
Summary: Force some stdout from downgrade_test.py for Travis
Key: KAFKA-10822
URL: https://issues.apache.org/jira/browse/KAFKA-10822
Project: Kafka
guozhangwang commented on pull request #9690:
URL: https://github.com/apache/kafka/pull/9690#issuecomment-740405554
LGTM. Left some comment on the PR for trunk.
This is an automated message from the Apache Git Service.
To
guozhangwang commented on a change in pull request #9688:
URL: https://github.com/apache/kafka/pull/9688#discussion_r538062610
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -540,18 +535,18 @@ public void
chia7712 commented on pull request #9711:
URL: https://github.com/apache/kafka/pull/9711#issuecomment-740404375
@guozhangwang Please take a look as this is related to #9196 (which updated
python from 2 to 3)
This is an
chia7712 opened a new pull request #9711:
URL: https://github.com/apache/kafka/pull/9711
That makes the behavior of ```print``` equal to pyhton2.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI
jsancio commented on a change in pull request #9553:
URL: https://github.com/apache/kafka/pull/9553#discussion_r538060397
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -1101,6 +1140,174 @@ private DescribeQuorumResponseData
[
https://issues.apache.org/jira/browse/KAFKA-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245659#comment-17245659
]
Loy Larvin Rao commented on KAFKA-7878:
---
Seeing the same issue in 2.6.0.
> Connect Task already
chia7712 commented on pull request #9435:
URL: https://github.com/apache/kafka/pull/9435#issuecomment-740351361
@lmr3796 Thanks for your updating. Could you rebase code to include recent
big commits to trigger QA again?
Jose Armando Garcia Sancio created KAFKA-10821:
--
Summary: Send cluster id information with the FetchSnapshot request
Key: KAFKA-10821
URL: https://issues.apache.org/jira/browse/KAFKA-10821
Jose Armando Garcia Sancio created KAFKA-10820:
--
Summary: Update start offset and end offset of the replicated log
Key: KAFKA-10820
URL: https://issues.apache.org/jira/browse/KAFKA-10820
Jose Armando Garcia Sancio created KAFKA-10819:
--
Summary: The freeze operation should validate the content of the
snapshot
Key: KAFKA-10819
URL: https://issues.apache.org/jira/browse/KAFKA-10819
chia7712 commented on a change in pull request #9707:
URL: https://github.com/apache/kafka/pull/9707#discussion_r537998894
##
File path:
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java
##
@@ -391,6 +391,23 @@ Sender newSender(LogContext
chia7712 commented on a change in pull request #9707:
URL: https://github.com/apache/kafka/pull/9707#discussion_r537998495
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
##
@@ -1115,6 +1115,10 @@ private void ensureValidRecordSize(int
chia7712 commented on pull request #9694:
URL: https://github.com/apache/kafka/pull/9694#issuecomment-740342002
@chris8099 Could you rebase code to include
https://github.com/apache/kafka/commit/8db3b1a09af0bad274e07161336994610d616b35?
Also, please fix the conflicting.
chia7712 commented on pull request #9705:
URL: https://github.com/apache/kafka/pull/9705#issuecomment-740340757
@APaMio Could you rebase code to include
https://github.com/apache/kafka/commit/8db3b1a09af0bad274e07161336994610d616b35?
ableegoldman commented on pull request #9671:
URL: https://github.com/apache/kafka/pull/9671#issuecomment-740339466
Kicked off 30 versions of the system test which has seemed to be flaky due
to this bug:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4302/
[
https://issues.apache.org/jira/browse/KAFKA-7819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gwen Shapira resolved KAFKA-7819.
-
Fix Version/s: 2.2.0
Resolution: Fixed
Closing since I noticed the PR was merged.
>
vamossagar12 commented on a change in pull request #9539:
URL: https://github.com/apache/kafka/pull/9539#discussion_r537995450
##
File path: clients/src/main/resources/common/message/LeaderChangeMessage.json
##
@@ -22,7 +22,11 @@
{"name": "LeaderId", "type": "int32",
ableegoldman commented on a change in pull request #9671:
URL: https://github.com/apache/kafka/pull/9671#discussion_r537990731
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -248,18 +243,26 @@ protected
jsancio commented on a change in pull request #9553:
URL: https://github.com/apache/kafka/pull/9553#discussion_r537993156
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -1037,6 +1047,14 @@ private boolean handleFetchResponse(
ableegoldman commented on a change in pull request #9671:
URL: https://github.com/apache/kafka/pull/9671#discussion_r537992012
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -235,11 +235,6 @@ protected
ableegoldman commented on a change in pull request #9671:
URL: https://github.com/apache/kafka/pull/9671#discussion_r537990731
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -248,18 +243,26 @@ protected
jsancio commented on a change in pull request #9505:
URL: https://github.com/apache/kafka/pull/9505#discussion_r537990223
##
File path: clients/src/main/resources/common/message/FetchSnapshotResponse.json
##
@@ -0,0 +1,59 @@
+// Licensed to the Apache Software Foundation (ASF)
jsancio commented on a change in pull request #9505:
URL: https://github.com/apache/kafka/pull/9505#discussion_r537990130
##
File path: clients/src/main/resources/common/message/FetchSnapshotRequest.json
##
@@ -0,0 +1,46 @@
+// Licensed to the Apache Software Foundation (ASF)
ableegoldman commented on a change in pull request #9671:
URL: https://github.com/apache/kafka/pull/9671#discussion_r537986486
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -853,7 +844,7 @@ public void
ableegoldman commented on a change in pull request #9695:
URL: https://github.com/apache/kafka/pull/9695#discussion_r537976391
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -924,22 +924,64 @@ private StreamThread createStreamThread(final
ableegoldman commented on a change in pull request #9695:
URL: https://github.com/apache/kafka/pull/9695#discussion_r537974578
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -924,22 +924,64 @@ private StreamThread createStreamThread(final
ableegoldman commented on a change in pull request #9695:
URL: https://github.com/apache/kafka/pull/9695#discussion_r537955392
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -924,22 +924,64 @@ private StreamThread createStreamThread(final
abbccdda commented on a change in pull request #9564:
URL: https://github.com/apache/kafka/pull/9564#discussion_r537958278
##
File path: core/src/main/scala/kafka/server/AlterIsrManager.scala
##
@@ -88,20 +88,34 @@ class AlterIsrManagerImpl(val controllerChannelManager:
apovzner commented on a change in pull request #9685:
URL: https://github.com/apache/kafka/pull/9685#discussion_r537955330
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -1753,9 +1761,9 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
mumrah commented on a change in pull request #9564:
URL: https://github.com/apache/kafka/pull/9564#discussion_r537948141
##
File path: core/src/main/scala/kafka/server/AlterIsrManager.scala
##
@@ -88,20 +88,34 @@ class AlterIsrManagerImpl(val controllerChannelManager:
splett2 commented on a change in pull request #9628:
URL: https://github.com/apache/kafka/pull/9628#discussion_r537945058
##
File path: core/src/main/scala/kafka/admin/ConfigCommand.scala
##
@@ -778,6 +793,10 @@ object ConfigCommand extends Config {
val brokerLogger =
splett2 commented on a change in pull request #9628:
URL: https://github.com/apache/kafka/pull/9628#discussion_r537945058
##
File path: core/src/main/scala/kafka/admin/ConfigCommand.scala
##
@@ -778,6 +793,10 @@ object ConfigCommand extends Config {
val brokerLogger =
junrao merged pull request #9710:
URL: https://github.com/apache/kafka/pull/9710
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
splett2 commented on pull request #9628:
URL: https://github.com/apache/kafka/pull/9628#issuecomment-740266395
Thanks for the feedback @dajac
I went ahead and also refactored some tests in `ConfigCommandTest` that were
a bit repetitive.
Let me know what you think
[
https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245587#comment-17245587
]
A. Sophie Blee-Goldman commented on KAFKA-10772:
Specifically, I'm looking for the log
splett2 commented on a change in pull request #9628:
URL: https://github.com/apache/kafka/pull/9628#discussion_r537937603
##
File path: core/src/test/scala/unit/kafka/admin/ConfigCommandTest.scala
##
@@ -472,6 +512,134 @@ class ConfigCommandTest extends ZooKeeperTestHarness
splett2 commented on a change in pull request #9628:
URL: https://github.com/apache/kafka/pull/9628#discussion_r537937180
##
File path: core/src/test/scala/unit/kafka/admin/ConfigCommandTest.scala
##
@@ -472,6 +512,134 @@ class ConfigCommandTest extends ZooKeeperTestHarness
[
https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245586#comment-17245586
]
A. Sophie Blee-Goldman commented on KAFKA-10772:
Hey [~lkokhreidze] and/or
ableegoldman commented on a change in pull request #9700:
URL: https://github.com/apache/kafka/pull/9700#discussion_r537917953
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
##
@@ -199,7 +200,9 @@ private void
[
https://issues.apache.org/jira/browse/KAFKA-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-10818.
-
Resolution: Fixed
> Skip conversion to `Struct` when serializing generated requests/responses
>
ijuma commented on pull request #7409:
URL: https://github.com/apache/kafka/pull/7409#issuecomment-740248672
Thanks for the review! Will post the follow up in a bit.
This is an automated message from the Apache Git Service.
ijuma merged pull request #7409:
URL: https://github.com/apache/kafka/pull/7409
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-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-10818:
Fix Version/s: 2.8.0
> Skip conversion to `Struct` when serializing generated requests/responses
Ismael Juma created KAFKA-10818:
---
Summary: Skip conversion to `Struct` when serializing generated
requests/responses
Key: KAFKA-10818
URL: https://issues.apache.org/jira/browse/KAFKA-10818
Project:
abbccdda commented on pull request #9564:
URL: https://github.com/apache/kafka/pull/9564#issuecomment-740244739
Hit unrelated stream test failure, retest
This is an automated message from the Apache Git Service.
To respond
lct45 commented on a change in pull request #9697:
URL: https://github.com/apache/kafka/pull/9697#discussion_r537899383
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -444,6 +444,27 @@ private void handleStreamsUncaughtException(final
lct45 commented on a change in pull request #9697:
URL: https://github.com/apache/kafka/pull/9697#discussion_r537899383
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -444,6 +444,27 @@ private void handleStreamsUncaughtException(final
ijuma commented on a change in pull request #7409:
URL: https://github.com/apache/kafka/pull/7409#discussion_r537868629
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java
##
@@ -95,21 +93,33 @@ public short version() {
return
hachikuji merged pull request #9512:
URL: https://github.com/apache/kafka/pull/9512
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
ijuma commented on a change in pull request #7409:
URL: https://github.com/apache/kafka/pull/7409#discussion_r537867972
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java
##
@@ -95,21 +93,33 @@ public short version() {
return
ijuma commented on a change in pull request #7409:
URL: https://github.com/apache/kafka/pull/7409#discussion_r537867021
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java
##
@@ -95,21 +93,33 @@ public short version() {
return
d8tltanc commented on pull request #9485:
URL: https://github.com/apache/kafka/pull/9485#issuecomment-740199487
Benchmark results run against trunk:
https://paste.ubuntu.com/p/zwKyQSrmDX/
This is an automated message
d8tltanc edited a comment on pull request #9485:
URL: https://github.com/apache/kafka/pull/9485#issuecomment-740036778
https://paste.ubuntu.com/p/zKYc6rk6WY/
Benchmark with AclAuthorizer::updateCache
With aclCount=50 and resourceCount=20,
20 call to updateCache
rayokota commented on pull request #9701:
URL: https://github.com/apache/kafka/pull/9701#issuecomment-740192213
Perhaps we should have a KIP and discussion for this since it changes
existing public behavior? In the meantime, we should probably revert the
original PR.
kowshik commented on pull request #9710:
URL: https://github.com/apache/kafka/pull/9710#issuecomment-740186296
cc @junrao @ijuma for review
This is an automated message from the Apache Git Service.
To respond to the message,
kowshik opened a new pull request #9710:
URL: https://github.com/apache/kafka/pull/9710
Few call sites in `Log.scala` were passing redundant default values when
making calls to `LogSegment.open(...)`. In this PR, I've cleaned these up.
**Test plan:**
Relying on existing unit and
[
https://issues.apache.org/jira/browse/KAFKA-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leah Thomas reassigned KAFKA-9126:
--
Assignee: (was: Leah Thomas)
> Extend `StreamJoined` to allow more store configs
>
[
https://issues.apache.org/jira/browse/KAFKA-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leah Thomas reassigned KAFKA-9126:
--
Assignee: Leah Thomas
> Extend `StreamJoined` to allow more store configs
>
[
https://issues.apache.org/jira/browse/KAFKA-10715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ravindranath Kakarla updated KAFKA-10715:
-
Remaining Estimate: 72h (was: 336h)
Original Estimate: 72h (was: 336h)
>
hachikuji commented on a change in pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#discussion_r537811235
##
File path:
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java
##
@@ -198,7 +198,7 @@ private static FilterResult
jolshan commented on a change in pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#discussion_r537799398
##
File path:
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java
##
@@ -386,6 +390,10 @@ public long maxOffset() {
APaMio commented on pull request #9705:
URL: https://github.com/apache/kafka/pull/9705#issuecomment-740157289
This request for change the loop index from wraps type to primitive type and
some relative modify, those indices just used to pass as an argument not as an
object, so I thought
[
https://issues.apache.org/jira/browse/KAFKA-10715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245501#comment-17245501
]
Ravindranath Kakarla commented on KAFKA-10715:
--
Can I contribute this change?
> Support
jolshan commented on a change in pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#discussion_r537799341
##
File path:
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java
##
@@ -198,7 +198,7 @@ private static FilterResult
[
https://issues.apache.org/jira/browse/KAFKA-10715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ravindra Nath Kakarla updated KAFKA-10715:
--
Comment: was deleted
(was: Can I contribute this change?)
> Support Kafka
jolshan commented on a change in pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#discussion_r537791276
##
File path:
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java
##
@@ -386,6 +390,10 @@ public long maxOffset() {
hachikuji commented on a change in pull request #9564:
URL: https://github.com/apache/kafka/pull/9564#discussion_r537789168
##
File path:
core/src/main/scala/kafka/server/BrokerToControllerChannelManagerImpl.scala
##
@@ -125,15 +129,25 @@ class
[
https://issues.apache.org/jira/browse/KAFKA-10792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10792:
--
Fix Version/s: (was: 2.7.1)
> Source tasks can block herder thread by hanging during stop
hachikuji commented on a change in pull request #9564:
URL: https://github.com/apache/kafka/pull/9564#discussion_r537788538
##
File path:
core/src/main/scala/kafka/server/BrokerToControllerChannelManagerImpl.scala
##
@@ -34,8 +34,12 @@ import scala.collection.mutable
import
hachikuji commented on a change in pull request #9564:
URL: https://github.com/apache/kafka/pull/9564#discussion_r537786674
##
File path:
core/src/main/scala/kafka/server/BrokerToControllerChannelManagerImpl.scala
##
@@ -208,7 +209,9 @@ class
hachikuji commented on a change in pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#discussion_r537776855
##
File path:
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java
##
@@ -386,6 +390,10 @@ public long maxOffset() {
[
https://issues.apache.org/jira/browse/KAFKA-10715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245470#comment-17245470
]
Ravindra Nath Kakarla commented on KAFKA-10715:
---
Can I contribute this change?
> Support
hachikuji commented on a change in pull request #9512:
URL: https://github.com/apache/kafka/pull/9512#discussion_r537757487
##
File path: raft/src/test/java/org/apache/kafka/raft/MockLog.java
##
@@ -472,4 +490,106 @@ private EpochStartOffset(int epoch, long startOffset) {
[
https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-10772:
Fix Version/s: (was: 2.7.0)
> java.lang.IllegalStateException: There are insufficient bytes
[
https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245460#comment-17245460
]
Bill Bejeck commented on KAFKA-10772:
-
Hi [~vvcephei],
Since this appears to be an outstanding
mumrah commented on pull request #9693:
URL: https://github.com/apache/kafka/pull/9693#issuecomment-740123591
@hachikuji yes indeed. I just pushed a commit which does just that (removes
PartitionStateStore)
I also pushed a change which relocates the ISR propagation logic to
[
https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10772:
-
Fix Version/s: 2.7.0
> java.lang.IllegalStateException: There are insufficient bytes available
[
https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10772:
-
Priority: Blocker (was: Major)
> java.lang.IllegalStateException: There are insufficient bytes
[
https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245456#comment-17245456
]
John Roesler commented on KAFKA-10772:
--
Hey [~bbejeck] , this might be a bit aggressive, but I
hachikuji commented on a change in pull request #9539:
URL: https://github.com/apache/kafka/pull/9539#discussion_r537742991
##
File path: clients/src/main/resources/common/message/LeaderChangeMessage.json
##
@@ -22,7 +22,11 @@
{"name": "LeaderId", "type": "int32",
hachikuji opened a new pull request #9709:
URL: https://github.com/apache/kafka/pull/9709
We should configure a reconnect backoff for controller connections to
prevent tight reconnect loops when the controller cannot be reached. I have
borrowed the same configuration we use in
hachikuji commented on a change in pull request #9564:
URL: https://github.com/apache/kafka/pull/9564#discussion_r537709868
##
File path: core/src/main/scala/kafka/server/AlterIsrManager.scala
##
@@ -88,20 +88,33 @@ class AlterIsrManagerImpl(val controllerChannelManager:
lct45 opened a new pull request #9708:
URL: https://github.com/apache/kafka/pull/9708
Adds `withLoggingEnabled` and `withLoggingDisabled` for `StreamJoined` to
give `StreamJoined` the same flexibility as `Materialized`
This
hachikuji commented on a change in pull request #9693:
URL: https://github.com/apache/kafka/pull/9693#discussion_r537704021
##
File path: core/src/main/scala/kafka/server/ZkIsrManager.scala
##
@@ -0,0 +1,51 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
Jason Gustafson created KAFKA-10817:
---
Summary: Add clusterId validation to Fetch handling
Key: KAFKA-10817
URL: https://issues.apache.org/jira/browse/KAFKA-10817
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-10811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10811:
--
Affects Version/s: (was: 2.5.1)
(was: 2.6.0)
> System exit
[
https://issues.apache.org/jira/browse/KAFKA-10811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10811:
--
Fix Version/s: (was: 2.6.1)
(was: 2.5.2)
> System exit from
[
https://issues.apache.org/jira/browse/KAFKA-10816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10816:
--
Description:
There are a few ways to accurately detect whether a Connect worker is
d8tltanc commented on pull request #9485:
URL: https://github.com/apache/kafka/pull/9485#issuecomment-740056125
Hi @rajinisivaram. Thanks for the detailed review! I’ve addressed all
comments you left. Also, after some optimization on the `resourceCache`, the
benchmark looks much better
Randall Hauch created KAFKA-10816:
-
Summary: Connect REST API should have a resource that can be used
as a readiness probe
Key: KAFKA-10816
URL: https://issues.apache.org/jira/browse/KAFKA-10816
1 - 100 of 123 matches
Mail list logo
