showuon opened a new pull request #10002:
URL: https://github.com/apache/kafka/pull/10002
Reading the security doc recently, and one thing annoys me: the long indent
in front of each command, ex:
.
-
xiao-penglei commented on pull request #9872:
URL: https://github.com/apache/kafka/pull/9872#issuecomment-769718703
> @xiao-penglei : Thanks. Is the PR ready to be committed then?
> @junrao
> @mumrah, since you helped set up the jenkins pipeline recently, could you
advise on the next
xiao-penglei edited a comment on pull request #9872:
URL: https://github.com/apache/kafka/pull/9872#issuecomment-769718703
> @xiao-penglei : Thanks. Is the PR ready to be committed then?
>
> @mumrah, since you helped set up the jenkins pipeline recently, could you
advise on the next
xiao-penglei edited a comment on pull request #9872:
URL: https://github.com/apache/kafka/pull/9872#issuecomment-769718703
> @xiao-penglei : Thanks. Is the PR ready to be committed then?
>
> @mumrah, since you helped set up the jenkins pipeline recently, could you
advise on the next
xiao-penglei commented on pull request #9872:
URL: https://github.com/apache/kafka/pull/9872#issuecomment-769729173
> What's the underlying ARM CI capacity? How long does it take to run? I
don't think we want to make the PR process slower. As I suggested before, let's
start by running `uni
xiao-penglei commented on a change in pull request #9992:
URL: https://github.com/apache/kafka/pull/9992#discussion_r566736408
##
File path: Jenkinsfile
##
@@ -158,6 +158,23 @@ pipeline {
echo 'Skipping Kafka Streams archetype test for Java 15'
}
dengziming commented on pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#issuecomment-769771773
@rajinisivaram I triggered the QA again but still has some failures, it
seems the failure is unrelated to this pr since other PRs also have these
failures.
--
cadonna commented on a change in pull request #9984:
URL: https://github.com/apache/kafka/pull/9984#discussion_r566722041
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -983,19 +989,75 @@ private StreamThread createAndAddStreamThread(final
rajinisivaram commented on pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#issuecomment-769798261
There are quite a few failures in the last PR build. Failures don't look
related to this PR, rerunning the build.
--
rajinisivaram commented on pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#issuecomment-769809654
@dengziming Sorry missed your note. Will wait for the current build to
complete in case it was a timing issue due to slow machines. Agree that the
issues don't look related
rondagostino opened a new pull request #10003:
URL: https://github.com/apache/kafka/pull/10003
Brokers receive metadata from the Raft metadata quorum very differently than
they do from ZooKeeper today, and this has implications for ReplicaManager. In
particular, when a broker reads the me
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17274511#comment-17274511
]
Nazar Volynets commented on KAFKA-8803:
---
Hi [~ableegoldman],
JFI, as was promised.
Chris Egerton created KAFKA-12252:
-
Summary: Distributed herder tick thread loops rapidly when worker
loses leadership
Key: KAFKA-12252
URL: https://issues.apache.org/jira/browse/KAFKA-12252
Project:
ijuma commented on a change in pull request #10003:
URL: https://github.com/apache/kafka/pull/10003#discussion_r566901097
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -316,7 +324,7 @@ class ReplicaManager(val config: KafkaConfig,
private def mayb
[
https://issues.apache.org/jira/browse/KAFKA-10873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reopened KAFKA-10873:
---
Assignee: (was: Luke Chen)
> Inaccurate "Ignoring stop request for unowned connector"
[
https://issues.apache.org/jira/browse/KAFKA-10873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17274520#comment-17274520
]
Chris Egerton commented on KAFKA-10873:
---
[~showuon] this is definitely a problem a
[
https://issues.apache.org/jira/browse/KAFKA-10873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17274520#comment-17274520
]
Chris Egerton edited comment on KAFKA-10873 at 1/29/21, 3:31 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-6876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-6876.
--
Resolution: Duplicate
> Sender exceptions ignored by WorkerSourceTask producer Callback causing
vvcephei commented on pull request #9420:
URL: https://github.com/apache/kafka/pull/9420#issuecomment-769881493
Only one flaky test failure:
```
Build / JDK 11 /
org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testOneWayReplicationWithAutoOffsetSync()
vvcephei merged pull request #9420:
URL: https://github.com/apache/kafka/pull/9420
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
vvcephei commented on pull request #9420:
URL: https://github.com/apache/kafka/pull/9420#issuecomment-769882506
Merged!
Many thanks, @dongjinleekr !
This is an automated message from the Apache Git Service.
To respond
wcarlson5 commented on a change in pull request #9984:
URL: https://github.com/apache/kafka/pull/9984#discussion_r566921429
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -983,19 +989,75 @@ private StreamThread createAndAddStreamThread(fina
[
https://issues.apache.org/jira/browse/KAFKA-12247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-12247:
--
Labels: (was: streams)
> Make removeStreamThread work better with static membership
> --
[
https://issues.apache.org/jira/browse/KAFKA-12247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-12247:
--
Component/s: streams
> Make removeStreamThread work better with static membership
> --
rajinisivaram commented on pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#issuecomment-769894936
@dengziming The new PR build completed and we are still seeing
NullPointerException in the JDK 8 build for the new test.
---
rajinisivaram edited a comment on pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#issuecomment-769894936
@dengziming The new PR build completed and we are still seeing
NullPointerException in the JDK 8 build for the new test. The results are here:
https://ci-builds.apach
cadonna commented on a change in pull request #9984:
URL: https://github.com/apache/kafka/pull/9984#discussion_r566935095
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -1046,13 +1045,20 @@ private StreamThread createAndAddStreamThread(fina
cadonna commented on a change in pull request #9984:
URL: https://github.com/apache/kafka/pull/9984#discussion_r566936574
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -25,7 +25,7 @@
import org.apache.kafka.clients.consumer.KafkaConsumer;
cadonna commented on a change in pull request #9984:
URL: https://github.com/apache/kafka/pull/9984#discussion_r566937333
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -25,7 +25,7 @@
import org.apache.kafka.clients.consumer.KafkaConsumer;
wcarlson5 commented on a change in pull request #9984:
URL: https://github.com/apache/kafka/pull/9984#discussion_r566940153
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -25,7 +25,7 @@
import org.apache.kafka.clients.consumer.KafkaConsume
dengziming commented on pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#issuecomment-769911317
@rajinisivaram Thank you, I think the problem comes from
`EasyMock.expect(authorizer.authorize(anyObject[RequestContext],
EasyMock.eq(expectedActions.asJava)))`.
below is wh
nicolasguyomar opened a new pull request #10004:
URL: https://github.com/apache/kafka/pull/10004
Hi team,
Minor improvement to log the received memberId upon joining a group at INFO
level on the memberside (consumer, worker) so that we can easily track broker
logs with the member lo
lct45 commented on a change in pull request #9253:
URL: https://github.com/apache/kafka/pull/9253#discussion_r566957204
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala
##
@@ -41,8 +43,19 @@ object Serdes {
implicit def Integer:
lct45 commented on a change in pull request #9253:
URL: https://github.com/apache/kafka/pull/9253#discussion_r566957547
##
File path:
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/SerdesUnitTest.scala
##
@@ -0,0 +1,35 @@
+/**
+ * Licensed to the Apache So
dengziming edited a comment on pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#issuecomment-769911317
@rajinisivaram Thank you, I think the problem comes from
`EasyMock.expect(authorizer.authorize(anyObject[RequestContext],
EasyMock.eq(expectedActions.asJava)))`.
belo
mjsax merged pull request #9969:
URL: https://github.com/apache/kafka/pull/9969
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
hachikuji commented on a change in pull request #9994:
URL: https://github.com/apache/kafka/pull/9994#discussion_r566987833
##
File path: clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java
##
@@ -98,7 +98,9 @@
UPDATE_FEATURES(ApiMessageType.UPDATE_FEATURES
vvcephei commented on a change in pull request #9253:
URL: https://github.com/apache/kafka/pull/9253#discussion_r567010831
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala
##
@@ -41,8 +43,19 @@ object Serdes {
implicit def Integ
junrao commented on a change in pull request #9901:
URL: https://github.com/apache/kafka/pull/9901#discussion_r567004415
##
File path:
metadata/src/main/java/org/apache/kafka/timeline/SnapshotRegistry.java
##
@@ -0,0 +1,251 @@
+/*
+ * Licensed to the Apache Software Foundation
lct45 commented on a change in pull request #9253:
URL: https://github.com/apache/kafka/pull/9253#discussion_r567013228
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala
##
@@ -41,8 +43,19 @@ object Serdes {
implicit def Integer:
ableegoldman commented on a change in pull request #9978:
URL: https://github.com/apache/kafka/pull/9978#discussion_r567013928
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -133,6 +152,72 @@ private void configurePer
cmccabe commented on a change in pull request #9901:
URL: https://github.com/apache/kafka/pull/9901#discussion_r567014310
##
File path:
metadata/src/main/java/org/apache/kafka/timeline/SnapshotRegistry.java
##
@@ -0,0 +1,251 @@
+/*
+ * Licensed to the Apache Software Foundatio
cmccabe commented on a change in pull request #9901:
URL: https://github.com/apache/kafka/pull/9901#discussion_r567014747
##
File path:
metadata/src/main/java/org/apache/kafka/timeline/SnapshotRegistry.java
##
@@ -0,0 +1,251 @@
+/*
+ * Licensed to the Apache Software Foundatio
wcarlson5 commented on a change in pull request #9978:
URL: https://github.com/apache/kafka/pull/9978#discussion_r567019601
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -133,6 +152,72 @@ private void configurePermis
dhruvilshah3 commented on pull request #7480:
URL: https://github.com/apache/kafka/pull/7480#issuecomment-769980062
@ryannedolan are you planning on working on this? I noticed that MM2 has no
system tests at the moment.
This
ning2008wisc commented on pull request #9287:
URL: https://github.com/apache/kafka/pull/9287#issuecomment-769983845
@mimaison @ryannedolan As titled, I think the change proposed in this PR may
be preferred when tackling https://issues.apache.org/jira/browse/KAFKA-10339
(EOS) since lots of
junrao commented on a change in pull request #9901:
URL: https://github.com/apache/kafka/pull/9901#discussion_r567020932
##
File path:
metadata/src/main/java/org/apache/kafka/timeline/SnapshotRegistry.java
##
@@ -0,0 +1,251 @@
+/*
+ * Licensed to the Apache Software Foundation
cmccabe commented on a change in pull request #9901:
URL: https://github.com/apache/kafka/pull/9901#discussion_r567027495
##
File path:
metadata/src/main/java/org/apache/kafka/timeline/timeline/SnapshottableHashTable.java
##
@@ -0,0 +1,410 @@
+/*
+ * Licensed to the Apache Sof
cmccabe commented on a change in pull request #9901:
URL: https://github.com/apache/kafka/pull/9901#discussion_r567028392
##
File path: metadata/src/main/java/org/apache/kafka/timeline/TimelineHashMap.java
##
@@ -0,0 +1,414 @@
+/*
+ * Licensed to the Apache Software Foundation
cmccabe commented on a change in pull request #9901:
URL: https://github.com/apache/kafka/pull/9901#discussion_r567032323
##
File path:
metadata/src/main/java/org/apache/kafka/timeline/SnapshotRegistry.java
##
@@ -0,0 +1,249 @@
+/*
+ * Licensed to the Apache Software Foundatio
cmccabe commented on a change in pull request #9901:
URL: https://github.com/apache/kafka/pull/9901#discussion_r567034077
##
File path:
metadata/src/main/java/org/apache/kafka/timeline/SnapshotRegistry.java
##
@@ -0,0 +1,251 @@
+/*
+ * Licensed to the Apache Software Foundatio
rondagostino opened a new pull request #10005:
URL: https://github.com/apache/kafka/pull/10005
`Partition` objects are able to retrieve topic configs when creating their
log, and currently they do so via ZooKeeper. ZooKeeper is not available when
using the Raft-based metadata log, so we n
rajinisivaram commented on pull request #9684:
URL: https://github.com/apache/kafka/pull/9684#issuecomment-770006566
The failing test FetcherTest.testEarlierOffsetResetArrivesLate is a known
flaky test (https://issues.apache.org/jira/browse/KAFKA-12245). Merging to
trunk.
---
hachikuji merged pull request #:
URL: https://github.com/apache/kafka/pull/
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
rajinisivaram merged pull request #9684:
URL: https://github.com/apache/kafka/pull/9684
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
rajinisivaram commented on pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#issuecomment-770011022
@dengziming Even the last PR build for this one seemed to have issues. I
merged https://github.com/apache/kafka/pull/9684 first since that build looked
good. But now this on
wcarlson5 commented on a change in pull request #9984:
URL: https://github.com/apache/kafka/pull/9984#discussion_r566940153
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -25,7 +25,7 @@
import org.apache.kafka.clients.consumer.KafkaConsume
[
https://issues.apache.org/jira/browse/KAFKA-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17275292#comment-17275292
]
A. Sophie Blee-Goldman commented on KAFKA-8930:
---
Hey [~miguno] I changed th
[
https://issues.apache.org/jira/browse/KAFKA-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-8930:
--
Fix Version/s: (was: 2.6.0)
2.6.2
> MM2 documentation
>
Jose Armando Garcia Sancio created KAFKA-12253:
--
Summary: Add tests that cover all of all of the cases for
ReplicatedLog::validateOffsetAndEpoch
Key: KAFKA-12253
URL: https://issues.apache.org/jira/br
[
https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-10793:
---
Fix Version/s: 2.6.2
> Race condition in FindCoordinatorFuture permanently s
ableegoldman commented on pull request #9671:
URL: https://github.com/apache/kafka/pull/9671#issuecomment-770017240
Cherrypicked to 2.6 as well
This is an automated message from the Apache Git Service.
To respond to the messa
mumrah commented on a change in pull request #10003:
URL: https://github.com/apache/kafka/pull/10003#discussion_r567064852
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -257,6 +265,25 @@ class ReplicaManager(val config: KafkaConfig,
}
}
+
mumrah commented on a change in pull request #10003:
URL: https://github.com/apache/kafka/pull/10003#discussion_r567065946
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -197,7 +204,8 @@ class ReplicaManager(val config: KafkaConfig,
Dhruvil Shah created KAFKA-12254:
Summary: MirrorMaker 2.0 creates destination topic with default
configs
Key: KAFKA-12254
URL: https://issues.apache.org/jira/browse/KAFKA-12254
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-12254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dhruvil Shah updated KAFKA-12254:
-
Description:
`MirrorSourceConnector` implements the logic for replicating data,
configurations,
Jose Armando Garcia Sancio created KAFKA-12255:
--
Summary: Investigate allowing for Fetch request that are not
validated
Key: KAFKA-12255
URL: https://issues.apache.org/jira/browse/KAFKA-12255
mumrah commented on a change in pull request #10003:
URL: https://github.com/apache/kafka/pull/10003#discussion_r567070588
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -257,6 +265,25 @@ class ReplicaManager(val config: KafkaConfig,
}
}
+
hachikuji commented on a change in pull request #9986:
URL: https://github.com/apache/kafka/pull/9986#discussion_r567073840
##
File path: core/src/test/java/kafka/test/annotation/ClusterProperty.java
##
@@ -0,0 +1,32 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
ableegoldman commented on pull request #9984:
URL: https://github.com/apache/kafka/pull/9984#issuecomment-770035212
All tests passed 🥳 Merging to trunk
This is an automated message from the Apache Git Service.
To respond to
ableegoldman merged pull request #9984:
URL: https://github.com/apache/kafka/pull/9984
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
hachikuji commented on a change in pull request #9986:
URL: https://github.com/apache/kafka/pull/9986#discussion_r567073840
##
File path: core/src/test/java/kafka/test/annotation/ClusterProperty.java
##
@@ -0,0 +1,32 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
hachikuji commented on a change in pull request #9986:
URL: https://github.com/apache/kafka/pull/9986#discussion_r567078580
##
File path: core/src/test/java/kafka/test/junit/ClusterForEach.java
##
@@ -0,0 +1,219 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
[
https://issues.apache.org/jira/browse/KAFKA-10866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10866.
-
Resolution: Fixed
> Add fetched metadata to ConsumerRecords
> --
[
https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10091.
-
Resolution: Fixed
> Improve task idling
> ---
>
> Key: K
[
https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10091:
Fix Version/s: 2.8.0
> Improve task idling
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/KAFKA-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10867.
-
Resolution: Fixed
> Implement improved semantics using the ConsumerRecords meta
> --
[
https://issues.apache.org/jira/browse/KAFKA-12247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-12247.
--
> Make removeStreamThread work better with static membership
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-10500.
--
> Add API to Start and Stop Stream Threads
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-10015:
--
Assignee: Walker Carlson (was: Bruno Cadonna)
> React Smartly to Unexpected Errors o
[
https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson resolved KAFKA-10015.
Resolution: Fixed
> React Smartly to Unexpected Errors on Stream Threads
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-10015.
--
> React Smartly to Unexpected Errors on Stream Threads
> -
[
https://issues.apache.org/jira/browse/KAFKA-12247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12247:
Description:
Ensure that calling removeStreamThread make the thread leave the group right
hachikuji commented on a change in pull request #9996:
URL: https://github.com/apache/kafka/pull/9996#discussion_r567106239
##
File path: clients/src/main/java/org/apache/kafka/clients/admin/Admin.java
##
@@ -1449,6 +1449,39 @@ default DescribeFeaturesResult describeFeatures()
hachikuji commented on pull request #9996:
URL: https://github.com/apache/kafka/pull/9996#issuecomment-770067513
Not also the test failure
`RequestConvertToJsonTest.testAllResponseTypesHandled`.
This is an automated message
bob-barrett commented on a change in pull request #9902:
URL: https://github.com/apache/kafka/pull/9902#discussion_r567112712
##
File path: clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java
##
@@ -907,6 +924,140 @@ public void testCorrelationId() {
[
https://issues.apache.org/jira/browse/KAFKA-10764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan resolved KAFKA-10764.
Resolution: Fixed
> Add support for returning topic IDs on create, supplying topic IDs for
[
https://issues.apache.org/jira/browse/KAFKA-10551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-10551:
--
Assignee: Justine Olshan (was: dengziming)
> Support topic IDs in Produce request
>
[
https://issues.apache.org/jira/browse/KAFKA-10551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-10551:
--
Assignee: (was: Justine Olshan)
> Support topic IDs in Produce request
>
[
https://issues.apache.org/jira/browse/KAFKA-10551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17275381#comment-17275381
]
Justine Olshan commented on KAFKA-10551:
Oh no. I was looking at this and I acci
hachikuji commented on a change in pull request #9777:
URL: https://github.com/apache/kafka/pull/9777#discussion_r567113645
##
File path: core/src/test/scala/unit/kafka/utils/TestUtils.scala
##
@@ -885,6 +891,24 @@ object TestUtils extends Logging {
), "Timed out waiting f
hachikuji commented on a change in pull request #9777:
URL: https://github.com/apache/kafka/pull/9777#discussion_r567117397
##
File path: core/src/test/scala/unit/kafka/utils/TestUtils.scala
##
@@ -349,10 +349,13 @@ object TestUtils extends Logging {
!hasSessionExpiratio
bob-barrett commented on a change in pull request #9902:
URL: https://github.com/apache/kafka/pull/9902#discussion_r567117421
##
File path: clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
##
@@ -239,24 +241,63 @@ public NetworkClient(Selectable selector,
hachikuji commented on pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#issuecomment-770075156
The failures look like known flakes. Will merge to trunk.
This is an automated message from the Apache Git Servi
hachikuji merged pull request #9816:
URL: https://github.com/apache/kafka/pull/9816
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-10761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-10761.
-
Resolution: Fixed
> In Raft support nonzero start offset and SnapshotId for the Fetch re
bob-barrett commented on a change in pull request #9902:
URL: https://github.com/apache/kafka/pull/9902#discussion_r567120007
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -183,6 +186,10 @@ public void disconnected(String id, l
1 - 100 of 134 matches
Mail list logo
