chia7712 commented on a change in pull request #10096:
URL: https://github.com/apache/kafka/pull/10096#discussion_r573463351
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
##
@@ -2480,4 +2508,38 @@ String getClientId() {
boolean u
chia7712 commented on a change in pull request #10096:
URL: https://github.com/apache/kafka/pull/10096#discussion_r573459714
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##
@@ -1201,6 +1201,9 @@ private void verifyMaxInFlightRequestPerConnecti
ewencp commented on pull request #10056:
URL: https://github.com/apache/kafka/pull/10056#issuecomment-776454131
I actually don't watch this much anymore, but what is the replacement?
References were added intentionally because some dependencies weren't available
in maven central. Has every
vvcephei commented on pull request #10096:
URL: https://github.com/apache/kafka/pull/10096#issuecomment-776446769
Hey @rajinisivaram and @chia7712 ,
Here is my proposed fix for
https://issues.apache.org/jira/browse/KAFKA-12268 , based on our discussion in
https://github.com/apache/k
vvcephei opened a new pull request #10096:
URL: https://github.com/apache/kafka/pull/10096
* Revert the default Consumer#poll behavior back to early return on records
only
* Add config to enable early return on metadata or records
* Set the return-on-metadata config in Streams to supp
[
https://issues.apache.org/jira/browse/KAFKA-12314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282215#comment-17282215
]
Guozhang Wang commented on KAFKA-12314:
---
cc [~vcrfxia] a PR from 3 years ago on us
yeralin commented on pull request #6592:
URL: https://github.com/apache/kafka/pull/6592#issuecomment-776422927
Any updates on this? :)
This is an automated message from the Apache Git Service.
To respond to the message, pleas
vcrfxia commented on pull request #10091:
URL: https://github.com/apache/kafka/pull/10091#issuecomment-776412900
Rather than having the `grace(...)` method update `maintainDurationMs`,
would it be better to update `maintainMs()` to return
`Math.max(maintainDurationMs, sizeMs + graceMs)` ra
chia7712 commented on a change in pull request #10080:
URL: https://github.com/apache/kafka/pull/10080#discussion_r573418590
##
File path: core/src/main/scala/kafka/server/KafkaBroker.scala
##
@@ -90,7 +92,7 @@ trait KafkaBroker extends KafkaMetricsGroup {
explicitMetricNa
chia7712 merged pull request #10035:
URL: https://github.com/apache/kafka/pull/10035
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-12314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282165#comment-17282165
]
A. Sophie Blee-Goldman commented on KAFKA-12314:
Hey Sagar, one thing I
[
https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282162#comment-17282162
]
A. Sophie Blee-Goldman commented on KAFKA-5146:
---
I agree, let's definitely
[
https://issues.apache.org/jira/browse/KAFKA-10021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282158#comment-17282158
]
Randall Hauch commented on KAFKA-10021:
---
Including in 2.6.2 due to reports of reba
[
https://issues.apache.org/jira/browse/KAFKA-10021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10021:
--
Fix Version/s: (was: 2.6.3)
2.6.2
> When reading to the end of the conf
[
https://issues.apache.org/jira/browse/KAFKA-10021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10021:
--
Fix Version/s: (was: 2.6.2)
> When reading to the end of the config log, check if fetch.ma
[
https://issues.apache.org/jira/browse/KAFKA-10021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10021:
--
Fix Version/s: 2.6.3
> When reading to the end of the config log, check if fetch.max.wait.ms i
[
https://issues.apache.org/jira/browse/KAFKA-10021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10021:
--
Fix Version/s: 2.6.2
2.7.1
2.8.0
2.5.2
cmccabe opened a new pull request #10095:
URL: https://github.com/apache/kafka/pull/10095
The broker lifecycle manager handles registering the broker and sending
periodic heartbeats, as described in KIP-631. Based on the responses it
receives from the controller, it transitions the broker
[
https://issues.apache.org/jira/browse/KAFKA-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-12319:
---
Description:
I've seen this test fail a few times locally. But recently I saw it fail on a
jolshan commented on pull request #10041:
URL: https://github.com/apache/kafka/pull/10041#issuecomment-776344485
@junrao On the previous commit JDK8 built and only
MirrorConnectorsIntegrationSSLTest.testOneWayReplicationWithAutoOffsetSync()
failed. (The only difference between this commit
cmccabe commented on a change in pull request #10093:
URL: https://github.com/apache/kafka/pull/10093#discussion_r573350073
##
File path: tests/kafkatest/services/kafka/kafka.py
##
@@ -171,35 +347,79 @@ def __init__(self, context, num_nodes, zk,
security_protocol=SecurityConfi
cmccabe commented on a change in pull request #10093:
URL: https://github.com/apache/kafka/pull/10093#discussion_r573348782
##
File path: config/raft-controller.properties
##
@@ -0,0 +1,124 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor
cmccabe commented on a change in pull request #10093:
URL: https://github.com/apache/kafka/pull/10093#discussion_r573348737
##
File path: config/raft-controller.properties
##
@@ -0,0 +1,124 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor
cmccabe commented on a change in pull request #10093:
URL: https://github.com/apache/kafka/pull/10093#discussion_r573348327
##
File path: config/raft-broker.properties
##
@@ -0,0 +1,125 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor lice
cmccabe commented on a change in pull request #10093:
URL: https://github.com/apache/kafka/pull/10093#discussion_r573348107
##
File path: config/raft-broker.properties
##
@@ -0,0 +1,125 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor lice
junrao commented on pull request #10041:
URL: https://github.com/apache/kafka/pull/10041#issuecomment-776328567
@jolshan : Thanks. Were the JDK 8 tests ok too?
This is an automated message from the Apache Git Service.
To resp
jolshan commented on pull request #10041:
URL: https://github.com/apache/kafka/pull/10041#issuecomment-776322170
Looks like one was already created.
https://issues.apache.org/jira/browse/KAFKA-12284
https://issues.apache.org/jira/browse/KAFKA-12319
---
Justine Olshan created KAFKA-12319:
--
Summary: Flaky test
ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit()
Key: KAFKA-12319
URL: https://issues.apache.org/jira/browse/KAFKA-12319
cmccabe commented on pull request #10069:
URL: https://github.com/apache/kafka/pull/10069#issuecomment-776317812
Thanks @rondagostino . I left two small comments... LGTM after those are
addressed.
This is an automated messa
cmccabe commented on a change in pull request #10069:
URL: https://github.com/apache/kafka/pull/10069#discussion_r573328630
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -185,7 +185,9 @@ object HostedPartition {
* This state only applies to broke
cmccabe commented on a change in pull request #10069:
URL: https://github.com/apache/kafka/pull/10069#discussion_r573326890
##
File path: core/src/main/scala/kafka/server/RaftReplicaManager.scala
##
@@ -0,0 +1,397 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) und
cmccabe opened a new pull request #10094:
URL: https://github.com/apache/kafka/pull/10094
The Kafka Metadata shell is a new command which allows users to
interactively examine the metadata stored in a KIP-500 cluster.
It can read the metadata from the controllers directly, by conne
jolshan commented on pull request #10041:
URL: https://github.com/apache/kafka/pull/10041#issuecomment-776313326
I had 2 JDK 11 failures previously. I also noticed JDK failures on other
PRs. I'll check JIRA for these issues
-
rondagostino opened a new pull request #10093:
URL: https://github.com/apache/kafka/pull/10093
We need to be able to run system tests with Raft-based metadata quorums --
both co-located brokers and controllers as well as remote controllers -- in
addition to the ZooKepeer-based mode we run
rohitrmd commented on pull request #9744:
URL: https://github.com/apache/kafka/pull/9744#issuecomment-776306678
@mjsax 2 1. tests failing are not related to my changes. not sure how to fix
them. 2. Are there kip updates i need to do?
---
junrao commented on pull request #10041:
URL: https://github.com/apache/kafka/pull/10041#issuecomment-776303090
@jolshan : Thanks. For those transient failures, could you file a jira if
it's not tracked already?
Are the JDK 8 failures also transient?
---
[
https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282099#comment-17282099
]
Matthias J. Sax commented on KAFKA-5146:
Any comments from [~guozhang] [~vvcephei
[
https://issues.apache.org/jira/browse/KAFKA-12314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12314:
Component/s: streams
> Leverage custom comparator for optimized range scans on RocksDB
> -
[
https://issues.apache.org/jira/browse/KAFKA-12313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12313:
Component/s: streams
> Consider deprecating the default.windowed.serde.inner.class configs
[
https://issues.apache.org/jira/browse/KAFKA-12313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12313:
Labels: needs-kip (was: )
> Consider deprecating the default.windowed.serde.inner.class c
jolshan edited a comment on pull request #10041:
URL: https://github.com/apache/kafka/pull/10041#issuecomment-776291259
`MirrorConnectorsIntegrationSSLTest.testOneWayReplicationWithAutoOffsetSync()`
seems to be flaky (is failing on other open PRs) It passed when I ran locally.
`Connect
jolshan commented on pull request #10041:
URL: https://github.com/apache/kafka/pull/10041#issuecomment-776291259
`MirrorConnectorsIntegrationSSLTest.testOneWayReplicationWithAutoOffsetSync()`
seems to be flaky (is failing on other open PRs)
`ConnectionQuotasTest.testListenerConnection
dejan2609 commented on pull request #10056:
URL: https://github.com/apache/kafka/pull/10056#issuecomment-776291112
(note: I just force-pushed once more in order to remove phrase `[Work in
progress]` out of the git commit message... **_now_** PR is ready ready for a
review... for real 😃)
dejan2609 commented on pull request #10056:
URL: https://github.com/apache/kafka/pull/10056#issuecomment-776288230
This PR is ready for a review.
FYI @ewencp and @ijuma
This is an automated message from the Apache Git Ser
[
https://issues.apache.org/jira/browse/KAFKA-12318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-12318:
--
Assignee: Justine Olshan
> system tests need to fetch Topic IDs via Admin Client inst
Ron Dagostino created KAFKA-12318:
-
Summary: system tests need to fetch Topic IDs via Admin Client
instead of via ZooKeeper
Key: KAFKA-12318
URL: https://issues.apache.org/jira/browse/KAFKA-12318
Proj
jolshan commented on pull request #10041:
URL: https://github.com/apache/kafka/pull/10041#issuecomment-776280666
Yes. I will want this on the 2.8 branch. I'll check the failed tests. I've
also had trouble with building at least one of the three JDKs, but it seems
like it is not the same on
MarcoLotz commented on a change in pull request #10042:
URL: https://github.com/apache/kafka/pull/10042#discussion_r573277614
##
File path:
streams/src/test/java/org/apache/kafka/streams/tools/StreamsResetterTest.java
##
@@ -247,6 +268,26 @@ public void
shouldDetermineInterna
cmccabe commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r573256853
##
File path:
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
##
@@ -0,0 +1,491 @@
+/*
+ * Licensed to the Apache Software
cmccabe commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r573256612
##
File path:
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
##
@@ -0,0 +1,491 @@
+/*
+ * Licensed to the Apache Software
cmccabe commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r573256321
##
File path:
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
##
@@ -0,0 +1,491 @@
+/*
+ * Licensed to the Apache Software
cmccabe commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r573254808
##
File path:
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
##
@@ -0,0 +1,491 @@
+/*
+ * Licensed to the Apache Software
rondagostino commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r573240204
##
File path:
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
##
@@ -0,0 +1,491 @@
+/*
+ * Licensed to the Apache Sof
rondagostino commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r573239810
##
File path:
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
##
@@ -0,0 +1,491 @@
+/*
+ * Licensed to the Apache Sof
jeqo commented on a change in pull request #10042:
URL: https://github.com/apache/kafka/pull/10042#discussion_r573239173
##
File path: core/src/main/scala/kafka/tools/StreamsResetter.java
##
@@ -503,7 +506,16 @@ private void resetToDatetime(final Consumer client,
final
cmccabe commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r573238990
##
File path:
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
##
@@ -0,0 +1,491 @@
+/*
+ * Licensed to the Apache Software
cmccabe commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r573235373
##
File path:
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
##
@@ -0,0 +1,491 @@
+/*
+ * Licensed to the Apache Software
cmccabe commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r573236986
##
File path:
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
##
@@ -0,0 +1,491 @@
+/*
+ * Licensed to the Apache Software
cmccabe commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r573236986
##
File path:
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
##
@@ -0,0 +1,491 @@
+/*
+ * Licensed to the Apache Software
cmccabe commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r573235373
##
File path:
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
##
@@ -0,0 +1,491 @@
+/*
+ * Licensed to the Apache Software
cmccabe commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r573235167
##
File path:
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
##
@@ -0,0 +1,491 @@
+/*
+ * Licensed to the Apache Software
cmccabe commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r573234880
##
File path:
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
##
@@ -0,0 +1,491 @@
+/*
+ * Licensed to the Apache Software
jeqo opened a new pull request #10092:
URL: https://github.com/apache/kafka/pull/10092
Similar to #10042, this PR introduces a WARN logging when no offset is found
in a topic partition.
Test strategy:
- Adding a test case for a topic without records.
### Committer Check
cmccabe commented on a change in pull request #10084:
URL: https://github.com/apache/kafka/pull/10084#discussion_r573229531
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -217,6 +217,7 @@ class KafkaApis(val requestChannel: RequestChannel,
case Ap
cmccabe commented on a change in pull request #10084:
URL: https://github.com/apache/kafka/pull/10084#discussion_r573229531
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -217,6 +217,7 @@ class KafkaApis(val requestChannel: RequestChannel,
case Ap
rondagostino commented on a change in pull request #10069:
URL: https://github.com/apache/kafka/pull/10069#discussion_r573201310
##
File path: core/src/main/scala/kafka/server/metadata/MetadataPartitions.scala
##
@@ -39,11 +41,30 @@ object MetadataPartition {
record.isr(
dajac commented on a change in pull request #9430:
URL: https://github.com/apache/kafka/pull/9430#discussion_r573201470
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -20,102 +20,131 @@ package kafka.tools
import java.util.Properties
import joptsim
MarcoLotz opened a new pull request #10091:
URL: https://github.com/apache/kafka/pull/10091
**Reproducing:**
The bug can be easily reproduced for any TimeWindow where window + grace
period > 1 day. Changing any test in TimeWindowedKStreamImplTest.java for this
condition will reproduce t
dajac commented on pull request #9430:
URL: https://github.com/apache/kafka/pull/9430#issuecomment-776211759
Launched system tests:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4362/
This is an automated
dajac commented on a change in pull request #9430:
URL: https://github.com/apache/kafka/pull/9430#discussion_r573192881
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -20,102 +20,120 @@ package kafka.tools
import java.util.Properties
import joptsim
mumrah opened a new pull request #10090:
URL: https://github.com/apache/kafka/pull/10090
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
[
https://issues.apache.org/jira/browse/KAFKA-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17281834#comment-17281834
]
Marco Lotz edited comment on KAFKA-9524 at 2/9/21, 7:30 PM:
I
[
https://issues.apache.org/jira/browse/KAFKA-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17281834#comment-17281834
]
Marco Lotz edited comment on KAFKA-9524 at 2/9/21, 7:29 PM:
I
Matthias J. Sax created KAFKA-12317:
---
Summary: Relax non-null key requirement for left KStream-KTable
join
Key: KAFKA-12317
URL: https://issues.apache.org/jira/browse/KAFKA-12317
Project: Kafka
rondagostino commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r573093783
##
File path:
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
##
@@ -0,0 +1,491 @@
+/*
+ * Licensed to the Apache Sof
bob-barrett commented on pull request #10064:
URL: https://github.com/apache/kafka/pull/10064#issuecomment-776128103
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, plea
mumrah merged pull request #10087:
URL: https://github.com/apache/kafka/pull/10087
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 t
mumrah merged pull request #10088:
URL: https://github.com/apache/kafka/pull/10088
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 t
junrao commented on a change in pull request #9944:
URL: https://github.com/apache/kafka/pull/9944#discussion_r573102028
##
File path: core/src/main/scala/kafka/server/FetchSession.scala
##
@@ -353,50 +508,68 @@ class SessionlessFetchContext(val fetchData:
util.Map[TopicPartit
gitlw opened a new pull request #10089:
URL: https://github.com/apache/kafka/pull/10089
This PR resolves the issue by clearing the state of the request batch upon
ControllerMovedException.
Also as a safety measure, it also clears the state during shutting down of
the ReplicaStateMachine
abbccdda commented on a change in pull request #10072:
URL: https://github.com/apache/kafka/pull/10072#discussion_r573065903
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
##
@@ -213,27 +214,26 @@ private void recordSe
jolshan edited a comment on pull request #9944:
URL: https://github.com/apache/kafka/pull/9944#issuecomment-776097476
>
> Also, it seems that for more partitions, the performance with this PR is
noticeably worse than trunk?
>
> ```
> FetchRequestBenchmark.testSerializeFetchReq
jolshan commented on pull request #9944:
URL: https://github.com/apache/kafka/pull/9944#issuecomment-776097476
>
> Also, it seems that for more partitions, the performance with this PR is
noticeably worse than trunk?
>
> ```
> FetchRequestBenchmark.testSerializeFetchRequestFor
rhauch merged pull request #9780:
URL: https://github.com/apache/kafka/pull/9780
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
mumrah merged pull request #9986:
URL: https://github.com/apache/kafka/pull/9986
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
jolshan commented on a change in pull request #9944:
URL: https://github.com/apache/kafka/pull/9944#discussion_r573046669
##
File path: core/src/main/scala/kafka/server/ReplicaFetcherThread.scala
##
@@ -216,10 +217,10 @@ class ReplicaFetcherThread(name: String,
try {
jolshan commented on a change in pull request #9944:
URL: https://github.com/apache/kafka/pull/9944#discussion_r573033865
##
File path: core/src/main/scala/kafka/server/FetchSession.scala
##
@@ -353,50 +508,68 @@ class SessionlessFetchContext(val fetchData:
util.Map[TopicParti
[
https://issues.apache.org/jira/browse/KAFKA-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17281834#comment-17281834
]
Marco Lotz commented on KAFKA-9524:
---
I have reproduced the bug on the Unit Tests and ca
[
https://issues.apache.org/jira/browse/KAFKA-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marco Lotz reassigned KAFKA-9524:
-
Assignee: Marco Lotz
> Default window retention does not consider grace period
> ---
mumrah commented on a change in pull request #10063:
URL: https://github.com/apache/kafka/pull/10063#discussion_r572957037
##
File path:
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java
##
@@ -79,24 +80,69 @@ public BatchAccumulator(
}
/**
-
ijuma commented on a change in pull request #10084:
URL: https://github.com/apache/kafka/pull/10084#discussion_r572957476
##
File path: clients/src/main/java/org/apache/kafka/clients/admin/Admin.java
##
@@ -1486,41 +1486,40 @@ default DescribeFeaturesResult describeFeatures() {
[
https://issues.apache.org/jira/browse/KAFKA-12312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17281820#comment-17281820
]
Tamas Kornai commented on KAFKA-12312:
--
Thanks [~showuon]Â for looking into this.
>
mumrah opened a new pull request #10088:
URL: https://github.com/apache/kafka/pull/10088
This is a backport of #9453 which changes the Jenkinsfile over to the new
new tool names used by Apache's Jenkins.
This is an automated
mumrah opened a new pull request #10087:
URL: https://github.com/apache/kafka/pull/10087
This is a backport of #9453 which changes the Jenkinsfile over to the new
new tool names used by Apache's Jenkins.
This is an automate
[
https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17281789#comment-17281789
]
Marco Lotz commented on KAFKA-5146:
---
[~mjsax]Â I recall we had a similar problem when up
Goltseva Taisiia created KAFKA-12316:
Summary: Configuration is not defined:
topic.creation.default.partitions
Key: KAFKA-12316
URL: https://issues.apache.org/jira/browse/KAFKA-12316
Project: Kafk
kamalcph commented on pull request #10035:
URL: https://github.com/apache/kafka/pull/10035#issuecomment-775838914
@chia7712
Addressed your comment. Please take another look.
This is an automated message from the Apache Gi
dengziming commented on pull request #10031:
URL: https://github.com/apache/kafka/pull/10031#issuecomment-775793384
ping @hachikuji @ijuma @chia7712 to have a look.
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-9295:
Assignee: Luke Chen
> KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPart
[
https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17281644#comment-17281644
]
Luke Chen commented on KAFKA-9295:
--
Investigating
> KTableKTableForeignKeyInnerJoinMult
1 - 100 of 105 matches
Mail list logo
