[
https://issues.apache.org/jira/browse/KAFKA-14254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-14254.
---
Fix Version/s: 3.4.0
Resolution: Fixed
> Format timestamps in assignor logs as dates
showuon commented on code in PR #13100:
URL: https://github.com/apache/kafka/pull/13100#discussion_r1105435108
##
clients/src/main/java/org/apache/kafka/common/protocol/types/TaggedFields.java:
##
@@ -100,6 +100,13 @@ public NavigableMap read(ByteBuffer
buffer) {
}
[
https://issues.apache.org/jira/browse/KAFKA-14597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688362#comment-17688362
]
Bruno Cadonna commented on KAFKA-14597:
---
[~talestonini] Thank you for the ticket!
showuon opened a new pull request, #13244:
URL: https://github.com/apache/kafka/pull/13244
Improve the test verification to make sure the cache size is expected before
and after each call.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
showuon commented on PR #13244:
URL: https://github.com/apache/kafka/pull/13244#issuecomment-1429346498
@satishd , call for review. Thanks.
--
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
dajac merged PR #13230:
URL: https://github.com/apache/kafka/pull/13230
--
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...@kafka.apache.or
dajac commented on PR #13230:
URL: https://github.com/apache/kafka/pull/13230#issuecomment-1429361939
Merged to trunk, 3.4 and 3.3.
--
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 co
[
https://issues.apache.org/jira/browse/KAFKA-14704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-14704.
-
Fix Version/s: 3.5.0
3.4.1
3.3.3
Reviewer: Jason G
showuon commented on code in PR #13239:
URL: https://github.com/apache/kafka/pull/13239#discussion_r1105504621
##
clients/src/main/java/org/apache/kafka/common/KafkaFuture.java:
##
@@ -127,8 +127,6 @@ public static KafkaFuture allOf(KafkaFuture...
futures) {
public abstrac
Hangleton commented on code in PR #13078:
URL: https://github.com/apache/kafka/pull/13078#discussion_r1105509459
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -264,6 +265,8 @@ class ReplicaManager(val config: KafkaConfig,
leaderPartitionsIterator.count(_.h
mimaison commented on code in PR #13239:
URL: https://github.com/apache/kafka/pull/13239#discussion_r1105515715
##
clients/src/main/java/org/apache/kafka/common/KafkaFuture.java:
##
@@ -127,8 +127,6 @@ public static KafkaFuture allOf(KafkaFuture...
futures) {
public abstra
mimaison merged PR #13239:
URL: https://github.com/apache/kafka/pull/13239
--
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...@kafka.apache
dajac opened a new pull request, #13245:
URL: https://github.com/apache/kafka/pull/13245
Cherry-picked from bd32d98bd7cbd8cff35d6786bc8b00061e0fedf7.
When a leader becomes a follower, it is likely that it has uncommitted
records in its log. When it reaches out to the leader, the leade
bachmanity1 opened a new pull request, #13246:
URL: https://github.com/apache/kafka/pull/13246
```
if (size > buffer.remaining())
throw new SchemaException("Error reading array of size " + size + ",
only " + buffer.remaining() + " bytes available");
```
Array type has the ab
bachmanity1 commented on PR #13246:
URL: https://github.com/apache/kafka/pull/13246#issuecomment-1429404900
@cmccabe @dongjinleekr could you please have 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
U
armandfargeon commented on PR #6193:
URL: https://github.com/apache/kafka/pull/6193#issuecomment-1429444823
Hello @mimaison,
It is planned to add this PR in a future version ? Thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
nizhikov opened a new pull request, #13247:
URL: https://github.com/apache/kafka/pull/13247
This PR contains changes required to move `PartitionReassignmentState` class
to java code.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
-
[
https://issues.apache.org/jira/browse/KAFKA-14595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688429#comment-17688429
]
Nikolay Izhikov commented on KAFKA-14595:
-
Hello
To reduce changes and make the
cadonna commented on code in PR #13025:
URL: https://github.com/apache/kafka/pull/13025#discussion_r1105612105
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/ReadOnlyTask.java:
##
@@ -190,7 +190,7 @@ public void clearTaskTimeout() {
@Override
p
cadonna commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1105688687
##
streams/src/test/java/org/apache/kafka/streams/tools/StreamsResetterTest.java:
##
@@ -16,7 +16,7 @@
*/
package org.apache.kafka.streams.tools;
-import kafka.too
cadonna commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1105688687
##
streams/src/test/java/org/apache/kafka/streams/tools/StreamsResetterTest.java:
##
@@ -16,7 +16,7 @@
*/
package org.apache.kafka.streams.tools;
-import kafka.too
Tamas created KAFKA-14713:
-
Summary: Kafka Streams global table startup takes too long
Key: KAFKA-14713
URL: https://issues.apache.org/jira/browse/KAFKA-14713
Project: Kafka
Issue Type: Bug
satishd commented on PR #13235:
URL: https://github.com/apache/kafka/pull/13235#issuecomment-1429693785
Thanks @showuon for your review.
> Overall LGTM! But do you think we should add a null `producerStateEntry`
test case?
Can you be more specific about the test case you are r
[
https://issues.apache.org/jira/browse/KAFKA-14595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688492#comment-17688492
]
Nikolay Izhikov commented on KAFKA-14595:
-
> I move the `PartitionReassignmentSt
Satish Duggana created KAFKA-14714:
--
Summary: Move/Rewrite RollParams, LogAppendInfo, and
LeaderHwChange to storage module.
Key: KAFKA-14714
URL: https://issues.apache.org/jira/browse/KAFKA-14714
Pro
dajac commented on code in PR #13240:
URL: https://github.com/apache/kafka/pull/13240#discussion_r1105846605
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -425,35 +425,72 @@ class KafkaApis(val requestChannel: RequestChannel,
requestHelper.sendMaybeThrottle(r
dajac commented on code in PR #13240:
URL: https://github.com/apache/kafka/pull/13240#discussion_r1105854122
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -425,35 +425,72 @@ class KafkaApis(val requestChannel: RequestChannel,
requestHelper.sendMaybeThrottle(r
dajac commented on code in PR #13240:
URL: https://github.com/apache/kafka/pull/13240#discussion_r1105855843
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -425,35 +425,72 @@ class KafkaApis(val requestChannel: RequestChannel,
requestHelper.sendMaybeThrottle(r
nizhikov commented on PR #13247:
URL: https://github.com/apache/kafka/pull/13247#issuecomment-1429798487
@mimaison
This PR is a first part of moving `ReassignPartitionsCommand` to java and
`tools` module.
Can you, please, take a look?
--
This is an automated message from the Ap
[
https://issues.apache.org/jira/browse/KAFKA-14696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-14696:
---
Fix Version/s: (was: 3.4.0)
> CVE-2023-25194: Apache Kafka: Possible RCE/Denial of servi
[
https://issues.apache.org/jira/browse/KAFKA-14696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-14696:
---
Fix Version/s: 3.4.0
> CVE-2023-25194: Apache Kafka: Possible RCE/Denial of service attack v
[
https://issues.apache.org/jira/browse/KAFKA-14696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-14696.
Resolution: Fixed
> CVE-2023-25194: Apache Kafka: Possible RCE/Denial of service attack vi
[
https://issues.apache.org/jira/browse/KAFKA-14225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison reassigned KAFKA-14225:
--
Assignee: Huilin Shi
> lazy val exemptSensor Could Cause Deadlock
> -
[
https://issues.apache.org/jira/browse/KAFKA-14236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison reassigned KAFKA-14236:
--
Assignee: Alexandre GRIFFAUT
> ListGroups request produces too much Denied logs in au
[
https://issues.apache.org/jira/browse/KAFKA-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison reassigned KAFKA-14646:
--
Assignee: Matthias J. Sax
> SubscriptionWrapper is of an incompatible version (Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison reassigned KAFKA-13632:
--
Assignee: Rens Groothuijsen
> MirrorMaker 2.0 NPE and Warning "Failure to commit reco
[
https://issues.apache.org/jira/browse/KAFKA-14564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison reassigned KAFKA-14564:
--
Assignee: Brendan Ribera
> Upgrade Netty to 4.1.86.Final to fix CVEs
> --
[
https://issues.apache.org/jira/browse/KAFKA-14570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison reassigned KAFKA-14570:
--
Assignee: iamazy
> Problem description missing closing parenthesis symbol
> -
[
https://issues.apache.org/jira/browse/KAFKA-14644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison reassigned KAFKA-14644:
--
Assignee: Jason Gustafson
> Process should stop after failure in raft IO thread
> ---
Hangleton commented on code in PR #13240:
URL: https://github.com/apache/kafka/pull/13240#discussion_r1105985661
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -425,35 +425,72 @@ class KafkaApis(val requestChannel: RequestChannel,
requestHelper.sendMaybeThrott
Hangleton commented on code in PR #13240:
URL: https://github.com/apache/kafka/pull/13240#discussion_r1105987099
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -425,35 +425,72 @@ class KafkaApis(val requestChannel: RequestChannel,
requestHelper.sendMaybeThrott
Hangleton commented on PR #13240:
URL: https://github.com/apache/kafka/pull/13240#issuecomment-1429942230
Thanks for the review, David. I am working on adding unit tests for
`OffsetCommitResponse` and the server-side handling of the request/response,
and fix the bugs you have identified.
Mickael Maison created KAFKA-14715:
--
Summary: Reduce Fetcher#parseRecord() memory copy
Key: KAFKA-14715
URL: https://issues.apache.org/jira/browse/KAFKA-14715
Project: Kafka
Issue Type: Impr
[
https://issues.apache.org/jira/browse/KAFKA-14395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-14395:
---
Fix Version/s: 3.5.0
> Add config to configure client supplier for KafkaStreams
> --
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688565#comment-17688565
]
Mickael Maison commented on KAFKA-13152:
Is KIP-770 still in progress? If so do
urbandan commented on PR #13163:
URL: https://github.com/apache/kafka/pull/13163#issuecomment-1429992202
@C0urante Existing tests (testWorkerConfigs and testClientConfigProperties)
already cover the config provider resolution (they use ${fake:secret:password}
and FakeConfigProvider), I don'
urbandan commented on PR #13163:
URL: https://github.com/apache/kafka/pull/13163#issuecomment-1429994157
Rebased the change on trunk and resolved conflicts
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-14578:
Fix Version/s: 3.5.0
> Move ConsumerPerformance to tools
> ---
philipnee commented on code in PR #13238:
URL: https://github.com/apache/kafka/pull/13238#discussion_r1106052765
##
examples/src/main/java/kafka/examples/Consumer.java:
##
@@ -63,33 +63,36 @@ public Consumer(final String topic,
this.numMessageToConsume = numMessageToCon
C0urante commented on code in PR #13178:
URL: https://github.com/apache/kafka/pull/13178#discussion_r1106023715
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java:
##
@@ -134,9 +138,9 @@ public String version() {
@Override
public
philipnee commented on code in PR #13238:
URL: https://github.com/apache/kafka/pull/13238#discussion_r1106061755
##
examples/src/main/java/kafka/examples/Consumer.java:
##
@@ -63,33 +63,36 @@ public Consumer(final String topic,
this.numMessageToConsume = numMessageToCon
Daniel Urban created KAFKA-14716:
Summary: Connect schema does not allow struct default values
Key: KAFKA-14716
URL: https://issues.apache.org/jira/browse/KAFKA-14716
Project: Kafka
Issue Typ
[
https://issues.apache.org/jira/browse/KAFKA-14716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Urban updated KAFKA-14716:
-
Description:
The ConnectSchema API should allow specifying a composite (struct) default
value f
jolshan commented on PR #13078:
URL: https://github.com/apache/kafka/pull/13078#issuecomment-1430066349
@anatasiavela do you mind rebasing again 😅
--
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
C0urante commented on PR #13163:
URL: https://github.com/apache/kafka/pull/13163#issuecomment-1430077887
@urbandan Ah yes, apologies for missing that. You're right, we don't need
any more coverage for the `MirrorMakerConfig` class.
I also agree that the manual config transformations p
urbandan commented on PR #13163:
URL: https://github.com/apache/kafka/pull/13163#issuecomment-1430082523
Thanks for the reviews @C0urante!
--
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 spec
hachikuji merged PR #13242:
URL: https://github.com/apache/kafka/pull/13242
--
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...@kafka.apach
gharris1727 commented on code in PR #13178:
URL: https://github.com/apache/kafka/pull/13178#discussion_r1106151042
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java:
##
@@ -134,9 +138,9 @@ public String version() {
@Override
publ
gharris1727 commented on code in PR #13178:
URL: https://github.com/apache/kafka/pull/13178#discussion_r1106151656
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java:
##
@@ -16,40 +16,88 @@
*/
package org.apache.kafka.connect.mirror;
-impor
jsancio merged PR #13227:
URL: https://github.com/apache/kafka/pull/13227
--
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...@kafka.apache.
[
https://issues.apache.org/jira/browse/KAFKA-14693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio resolved KAFKA-14693.
Resolution: Fixed
> KRaft Controller and ProcessExitingFaultHandle
[
https://issues.apache.org/jira/browse/KAFKA-14693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-14693:
---
Fix Version/s: 3.5.0
> KRaft Controller and ProcessExitingFaultHandl
[
https://issues.apache.org/jira/browse/KAFKA-14716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688651#comment-17688651
]
Chris Egerton commented on KAFKA-14716:
---
[~durban] is this a duplicate of KAFKA-12
C0urante commented on code in PR #13208:
URL: https://github.com/apache/kafka/pull/13208#discussion_r1106203170
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTask.java:
##
@@ -256,14 +257,25 @@ private void maybeBeginTransaction() {
Hangleton commented on code in PR #13240:
URL: https://github.com/apache/kafka/pull/13240#discussion_r1106229439
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -425,35 +425,72 @@ class KafkaApis(val requestChannel: RequestChannel,
requestHelper.sendMaybeThrott
Hangleton commented on code in PR #13240:
URL: https://github.com/apache/kafka/pull/13240#discussion_r1106229439
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -425,35 +425,72 @@ class KafkaApis(val requestChannel: RequestChannel,
requestHelper.sendMaybeThrott
C0urante commented on code in PR #13208:
URL: https://github.com/apache/kafka/pull/13208#discussion_r1106236517
##
connect/runtime/src/test/java/org/apache/kafka/connect/storage/OffsetStorageWriterTest.java:
##
@@ -135,38 +135,40 @@ public void testFlushFailureReplacesOffsets()
C0urante commented on code in PR #13208:
URL: https://github.com/apache/kafka/pull/13208#discussion_r1106250177
##
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageWriter.java:
##
@@ -98,6 +104,24 @@ private boolean flushing() {
return toFlush
guozhangwang commented on code in PR #13082:
URL: https://github.com/apache/kafka/pull/13082#discussion_r1106267030
##
docs/streams/developer-guide/config-streams.html:
##
@@ -778,10 +778,20 @@ rack.aware.assignment.tagsmax.warmup.replicas
-
[
https://issues.apache.org/jira/browse/KAFKA-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688679#comment-17688679
]
Matthias J. Sax commented on KAFKA-14713:
-
Sounds like a duplicate to https://is
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688684#comment-17688684
]
Guozhang Wang commented on KAFKA-13152:
---
Thanks [~mimaison], this is still quite r
guozhangwang commented on code in PR #13025:
URL: https://github.com/apache/kafka/pull/13025#discussion_r1102201605
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -258,21 +269,27 @@ private List getTasksAndActions() {
Chia-Ping Tsai created KAFKA-14717:
--
Summary: KafkaStreams can' get running if the rebalance happens
before StreamThread gets shutdown completely
Key: KAFKA-14717
URL: https://issues.apache.org/jira/browse/KAFKA-
guozhangwang commented on PR #13025:
URL: https://github.com/apache/kafka/pull/13025#issuecomment-1430280435
@lucasbru seems I forgot to send those pending comments from last week,
sorry... anyways there's only one comment that I had here:
https://github.com/apache/kafka/pull/13025#discussi
chia7712 opened a new pull request, #13248:
URL: https://github.com/apache/kafka/pull/13248
I noticed this issue when tracing #12590
StreamThread closes the consumer before changing state to DEAD. If the
partition rebalance happens quickly, the other StreamThreads can't change
KafkaStrea
mattwong949 commented on PR #13206:
URL: https://github.com/apache/kafka/pull/13206#issuecomment-1430302196
sorry for the delay on any open comments, I'll be able to reply to and
iterate on them by tomorrow
--
This is an automated message from the Apache Git Service.
To respond to the mes
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688701#comment-17688701
]
Mickael Maison commented on KAFKA-13152:
Ok, I've added it to the release plan.
C0urante commented on PR #13163:
URL: https://github.com/apache/kafka/pull/13163#issuecomment-1430408893
Test failures appear unrelated (the newly-introduced dedicated MM2
integration tests seem to be flaking out on Jenkins; filed KAFKA-14718 to
track). Merging...
--
This is an automated
Chris Egerton created KAFKA-14718:
-
Summary: Flaky DedicatedMirrorIntegrationTest test suite
Key: KAFKA-14718
URL: https://issues.apache.org/jira/browse/KAFKA-14718
Project: Kafka
Issue Type:
C0urante merged PR #13163:
URL: https://github.com/apache/kafka/pull/13163
--
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...@kafka.apache
[
https://issues.apache.org/jira/browse/KAFKA-14653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14653:
--
Fix Version/s: 3.5.0
> MM2 should delay resolving config provider references
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-10586.
---
Resolution: Done
> Full support for distributed mode in dedicated MirrorMaker 2.0 clusters
>
[
https://issues.apache.org/jira/browse/KAFKA-10586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-10586:
--
Fix Version/s: 3.5.0
> Full support for distributed mode in dedicated MirrorMaker 2.0 clusters
[
https://issues.apache.org/jira/browse/KAFKA-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-10857.
---
Resolution: Duplicate
> Mirror Maker 2 - replication not working when deploying multiple ins
[
https://issues.apache.org/jira/browse/KAFKA-12893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-12893.
---
Resolution: Duplicate
> MM2 fails to replicate if starting two+ nodes same time
> --
[
https://issues.apache.org/jira/browse/KAFKA-12150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-12150.
---
Resolution: Duplicate
> Consumer group refresh not working with clustered MM2 setup
> --
guozhangwang commented on code in PR #13248:
URL: https://github.com/apache/kafka/pull/13248#discussion_r1106408656
##
streams/src/test/java/org/apache/kafka/streams/integration/AdjustStreamThreadCountTest.java:
##
@@ -257,6 +258,23 @@ private Thread adjustCountHelperThread(fina
hachikuji commented on code in PR #13192:
URL: https://github.com/apache/kafka/pull/13192#discussion_r1106464011
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MetadataFetcher.java:
##
@@ -0,0 +1,805 @@
+/*
+ * Licensed to the Apache Software Foundation (AS
hachikuji commented on code in PR #13192:
URL: https://github.com/apache/kafka/pull/13192#discussion_r1106467125
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MetadataFetcher.java:
##
@@ -0,0 +1,805 @@
+/*
+ * Licensed to the Apache Software Foundation (AS
jolshan commented on PR #12957:
URL: https://github.com/apache/kafka/pull/12957#issuecomment-1430506039
Is this an issue only on 3.2?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
kirktrue commented on code in PR #13192:
URL: https://github.com/apache/kafka/pull/13192#discussion_r1106476284
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MetadataFetcher.java:
##
@@ -0,0 +1,805 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
[
https://issues.apache.org/jira/browse/KAFKA-14717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-14717:
Component/s: streams
> KafkaStreams can' get running if the rebalance happens before Strea
kirktrue commented on code in PR #13192:
URL: https://github.com/apache/kafka/pull/13192#discussion_r1106476882
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MetadataFetcher.java:
##
@@ -0,0 +1,805 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
mjsax commented on code in PR #13243:
URL: https://github.com/apache/kafka/pull/13243#discussion_r1106482112
##
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStore.java:
##
@@ -283,7 +293,12 @@ public void init(final StateStoreContext context, fi
ijuma commented on PR #13247:
URL: https://github.com/apache/kafka/pull/13247#issuecomment-1430569601
Is `server-common` the right module? What requires access to these classes
aside from `tools`?
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
ijuma commented on PR #13246:
URL: https://github.com/apache/kafka/pull/13246#issuecomment-1430570552
Checking for OOM is a security issue, so we cannot do that.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
vcrfxia commented on code in PR #13243:
URL: https://github.com/apache/kafka/pull/13243#discussion_r1106532591
##
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStore.java:
##
@@ -297,6 +312,12 @@ void restoreBatch(final Collection> records) {
bachmanity1 commented on code in PR #13246:
URL: https://github.com/apache/kafka/pull/13246#discussion_r1106542835
##
clients/src/main/java/org/apache/kafka/common/protocol/types/ArrayOf.java:
##
@@ -72,10 +74,10 @@ public Object read(ByteBuffer buffer) {
else if (size
ijuma commented on PR #13205:
URL: https://github.com/apache/kafka/pull/13205#issuecomment-1430621318
Gradle 8 has been released. Have you been able to figure out why the build
is failing?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
mjsax commented on code in PR #13243:
URL: https://github.com/apache/kafka/pull/13243#discussion_r1106567105
##
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStore.java:
##
@@ -283,7 +293,12 @@ public void init(final StateStoreContext context, fi
1 - 100 of 117 matches
Mail list logo
