dajac commented on PR #11971:
URL: https://github.com/apache/kafka/pull/11971#issuecomment-1091191284
We have found the root cause of the original issue. It was a bug in our
benchmark setup so it had nothing to do with this change in the end. We can
still keep this change as it looks better
[
https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17518660#comment-17518660
]
RivenSun commented on KAFKA-13793:
--
Kafka itself supports five sasl mechanisms, GSSAPI
dajac merged PR #11998:
URL: https://github.com/apache/kafka/pull/11998
--
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
[
https://issues.apache.org/jira/browse/KAFKA-13801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-13801.
-
Fix Version/s: 3.3.0
Reviewer: David Jacot
Assignee: Xavier Léauté
Resol
showuon commented on PR #11971:
URL: https://github.com/apache/kafka/pull/11971#issuecomment-1091344371
> We have found the root cause of the original issue. It was a bug in our
benchmark setup so it had nothing to do with this change in the end. We can
still keep this change as it looks be
ddrid commented on code in PR #12006:
URL: https://github.com/apache/kafka/pull/12006#discussion_r844881404
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -187,7 +187,7 @@ private void startSequencesAtBeginning(TopicPartition
bozhao12 closed pull request #12007: MINOR: Fix method annotation
URL: https://github.com/apache/kafka/pull/12007
--
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
bozhao12 opened a new pull request, #12009:
URL: https://github.com/apache/kafka/pull/12009
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgr
bozhao12 commented on PR #12009:
URL: https://github.com/apache/kafka/pull/12009#issuecomment-1091395431
@showuon Sorry, I deleted the remote branch by mistake, I submitted a new
Pull Request. Thanks
--
This is an automated message from the Apache Git Service.
To respond to the message,
RivenSun2 opened a new pull request, #12010:
URL: https://github.com/apache/kafka/pull/12010
Add validators for configs that lack validators
--
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 sp
RivenSun2 commented on PR #12010:
URL: https://github.com/apache/kafka/pull/12010#issuecomment-1091397361
Hi @showuon
could you help to review the PR?
Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
bozhao12 closed pull request #12009: MINOR: Fix method annotation
URL: https://github.com/apache/kafka/pull/12009
--
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
[
https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17518732#comment-17518732
]
RivenSun commented on KAFKA-13793:
--
Hi [~showuon] , please help review PR-12010.
Thanks
showuon commented on PR #12007:
URL: https://github.com/apache/kafka/pull/12007#issuecomment-1091493302
Failed tests are unrelated:
```
Build / ARM /
kafka.network.ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit()
```
--
This is an automated message f
showuon merged PR #12007:
URL: https://github.com/apache/kafka/pull/12007
--
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.
EvansJahja opened a new pull request, #12011:
URL: https://github.com/apache/kafka/pull/12011
```
Usage:
./kafka-console-consumer.sh --bootstrap-server kafka:9092 --include '.*'
--property print.topic=true
Example output:
Topic:hello.world{"msg": "abc"}
```
Pur
Luke Chen created KAFKA-13804:
-
Summary: Log broker shutdown reason at the end of log output
Key: KAFKA-13804
URL: https://issues.apache.org/jira/browse/KAFKA-13804
Project: Kafka
Issue Type: Imp
[
https://issues.apache.org/jira/browse/KAFKA-13804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-13804:
--
Description:
Currently, when the broker hit exception, or SIGINT signal received, we will
first log t
EvansJahja closed pull request #12011: MINOR: add print.topic property in
console consumer
URL: https://github.com/apache/kafka/pull/12011
--
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 specifi
EvansJahja opened a new pull request, #12012:
URL: https://github.com/apache/kafka/pull/12012
```
Usage:
./kafka-console-consumer.sh --bootstrap-server kafka:9092 --include '.*'
--property print.topic=true
Example output:
Topic:hello.world{"msg": "abc"}
```
Pur
[
https://issues.apache.org/jira/browse/KAFKA-13762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17518845#comment-17518845
]
Jordan Moore commented on KAFKA-13762:
--
[~kkameshm90] Please lower the priority as
[
https://issues.apache.org/jira/browse/KAFKA-13571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17518846#comment-17518846
]
Jordan Moore commented on KAFKA-13571:
--
It should work just fine. Please check the
[
https://issues.apache.org/jira/browse/KAFKA-13571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17518846#comment-17518846
]
Jordan Moore edited comment on KAFKA-13571 at 4/7/22 12:21 PM:
---
ddrid commented on code in PR #12006:
URL: https://github.com/apache/kafka/pull/12006#discussion_r844881404
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -187,7 +187,7 @@ private void startSequencesAtBeginning(TopicPartition
Shivakumar created KAFKA-13805:
--
Summary: Upgrade vulnerable dependencies march 2022
Key: KAFKA-13805
URL: https://issues.apache.org/jira/browse/KAFKA-13805
Project: Kafka
Issue Type: Bug
Af
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shivakumar updated KAFKA-13805:
---
Description:
|Packages|Package Version|CVSS|Fix Status|
|com.fasterxml.jackson.core_jackson-databind
[
https://issues.apache.org/jira/browse/KAFKA-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xavier Léauté updated KAFKA-6204:
-
Fix Version/s: 3.3.0
(was: 3.2.0)
> Interceptor and MetricsReporter should
[
https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-8575:
-
Fix Version/s: (was: 3.2.0)
> Investigate removing EAGER protocol & cleaning up task suspens
[
https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-8575:
-
Priority: Critical (was: Blocker)
> Investigate removing EAGER protocol & cleaning up task susp
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13805:
--
Fix Version/s: (was: 3.0.1)
(was: 3.2.0)
(was
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13805:
--
Affects Version/s: 3.0.1
3.1.1
> Upgrade vulnerable dependencies march
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13805:
--
Priority: Blocker (was: Major)
> Upgrade vulnerable dependencies march 2022
> ---
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13805:
--
Fix Version/s: 3.1.2
2.8.2
3.0.2
> Upgrade vulnerable de
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519059#comment-17519059
]
Bruno Cadonna commented on KAFKA-13805:
---
[~shivakumar] Are you referring to the fo
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519059#comment-17519059
]
Bruno Cadonna edited comment on KAFKA-13805 at 4/7/22 5:45 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13805:
--
Affects Version/s: (was: 3.1.1)
> Upgrade vulnerable dependencies march 2022
> ---
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13805:
--
Fix Version/s: (was: 3.1.2)
> Upgrade vulnerable dependencies march 2022
> ---
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519073#comment-17519073
]
Kirk True commented on KAFKA-13805:
---
According to
[https://mvnrepository.com/artifact
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519073#comment-17519073
]
Kirk True edited comment on KAFKA-13805 at 4/7/22 6:07 PM:
---
Ac
artemlivshits commented on code in PR #12006:
URL: https://github.com/apache/kafka/pull/12006#discussion_r845433136
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -187,7 +187,7 @@ private void startSequencesAtBeginning(TopicPa
kirktrue commented on code in PR #11998:
URL: https://github.com/apache/kafka/pull/11998#discussion_r845436714
##
core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala:
##
@@ -1813,14 +1812,20 @@ class TestMetricsReporter extends MetricsReporter wit
Jose Armando Garcia Sancio created KAFKA-13806:
--
Summary: Check CRC when reading snapshots
Key: KAFKA-13806
URL: https://issues.apache.org/jira/browse/KAFKA-13806
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519082#comment-17519082
]
Bruno Cadonna commented on KAFKA-13805:
---
[~kirktrue] Under "Known Affected Softwar
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519087#comment-17519087
]
Kirk True commented on KAFKA-13805:
---
[~cadonna] - Sorry for the confusion... I was men
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519087#comment-17519087
]
Kirk True edited comment on KAFKA-13805 at 4/7/22 6:37 PM:
---
[~
cadonna opened a new pull request, #12013:
URL: https://github.com/apache/kafka/pull/12013
Just a test
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (incl
xvrl commented on code in PR #11998:
URL: https://github.com/apache/kafka/pull/11998#discussion_r845459993
##
core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala:
##
@@ -1813,14 +1812,20 @@ class TestMetricsReporter extends MetricsReporter with
R
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13805:
--
Description:
https://nvd.nist.gov/vuln/detail/CVE-2020-36518
|Packages|Package Version|CVSS|F
[
https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519093#comment-17519093
]
Bruno Cadonna commented on KAFKA-13805:
---
[~kirktrue] Ah, got it! You are right! I
dajac commented on code in PR #12005:
URL: https://github.com/apache/kafka/pull/12005#discussion_r845466434
##
core/src/main/scala/kafka/server/LeaderEndPoint.scala:
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor li
dajac commented on code in PR #12005:
URL: https://github.com/apache/kafka/pull/12005#discussion_r845466834
##
core/src/main/scala/kafka/server/LeaderEndPoint.scala:
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor li
cadonna commented on PR #11681:
URL: https://github.com/apache/kafka/pull/11681#issuecomment-1092089272
@showuon @dengziming @hachikuji @dajac What is the status of this PR? This
PR would resolve a blocker for the 3.2.0 release. Would be great if we could
merge this PR as soon as possible?
dajac commented on code in PR #12005:
URL: https://github.com/apache/kafka/pull/12005#discussion_r845468553
##
core/src/main/scala/kafka/server/LeaderEndPoint.scala:
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor li
jeqo commented on PR #11999:
URL: https://github.com/apache/kafka/pull/11999#issuecomment-1092096823
cc @vvcephei
--
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 unsubs
dajac commented on code in PR #12005:
URL: https://github.com/apache/kafka/pull/12005#discussion_r845476205
##
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala:
##
@@ -213,62 +174,6 @@ class ReplicaFetcherThread(name: String,
"equal or larger than your settin
rittikaadhikari commented on code in PR #12005:
URL: https://github.com/apache/kafka/pull/12005#discussion_r845476760
##
core/src/main/scala/kafka/server/LeaderEndPoint.scala:
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * cont
dajac commented on code in PR #12005:
URL: https://github.com/apache/kafka/pull/12005#discussion_r845476205
##
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala:
##
@@ -213,62 +174,6 @@ class ReplicaFetcherThread(name: String,
"equal or larger than your settin
dajac commented on code in PR #12005:
URL: https://github.com/apache/kafka/pull/12005#discussion_r845478395
##
core/src/main/scala/kafka/server/LeaderEndPoint.scala:
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor li
[
https://issues.apache.org/jira/browse/KAFKA-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519124#comment-17519124
]
Karsten Schnitter commented on KAFKA-7491:
--
Hi, this issue has not seen much act
rittikaadhikari commented on code in PR #12005:
URL: https://github.com/apache/kafka/pull/12005#discussion_r845546314
##
core/src/main/scala/kafka/server/LeaderEndPoint.scala:
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * cont
[
https://issues.apache.org/jira/browse/KAFKA-13803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rittika Adhikari updated KAFKA-13803:
-
Description:
Currently, AbstractFetcherThread has a series of protected APIs which contr
rittikaadhikari commented on code in PR #12005:
URL: https://github.com/apache/kafka/pull/12005#discussion_r845546314
##
core/src/main/scala/kafka/server/LeaderEndPoint.scala:
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * cont
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519175#comment-17519175
]
Matthias J. Sax commented on KAFKA-12909:
-
Not that _inner_ join result are stil
ijuma opened a new pull request, #12014:
URL: https://github.com/apache/kafka/pull/12014
This regressed in ca375d8004c1 due to a typo. We need tests
for our builds. :)
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify t
[
https://issues.apache.org/jira/browse/KAFKA-9296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519194#comment-17519194
]
Jun Rao commented on KAFKA-9296:
[~vongosling] : It would be useful to provide a bit more
[
https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519199#comment-17519199
]
Matthias J. Sax commented on KAFKA-7509:
Thanks for staying on top of this. The f
mjsax commented on code in PR #11896:
URL: https://github.com/apache/kafka/pull/11896#discussion_r845465254
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java:
##
@@ -80,22 +109,54 @@ public void enableSendingOldValues() {
pr
tmbull commented on PR #8103:
URL: https://github.com/apache/kafka/pull/8103#issuecomment-1092308800
Is there any update on this?
--
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 com
Colin McCabe created KAFKA-13807:
Summary: Ensure that we can set log.flush.interval.ms with
IncrementalAlterConfigs
Key: KAFKA-13807
URL: https://issues.apache.org/jira/browse/KAFKA-13807
Project: Ka
dengziming commented on code in PR #11681:
URL: https://github.com/apache/kafka/pull/11681#discussion_r845640296
##
core/src/test/java/kafka/testkit/KafkaClusterTestKit.java:
##
@@ -373,13 +373,19 @@ public void startup() throws ExecutionException,
InterruptedException {
ddrid commented on code in PR #12006:
URL: https://github.com/apache/kafka/pull/12006#discussion_r845672887
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -187,7 +187,7 @@ private void startSequencesAtBeginning(TopicPartition
showuon commented on code in PR #12006:
URL: https://github.com/apache/kafka/pull/12006#discussion_r845677599
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -187,7 +187,7 @@ private void startSequencesAtBeginning(TopicPartitio
showuon commented on code in PR #12010:
URL: https://github.com/apache/kafka/pull/12010#discussion_r845685014
##
clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java:
##
@@ -1083,6 +1083,26 @@ public String toString() {
}
}
+public static class
EvansJahja commented on PR #12012:
URL: https://github.com/apache/kafka/pull/12012#issuecomment-1092379826
Hi @dajac, could I ask for your review on this?
--
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 t
RivenSun2 commented on code in PR #12010:
URL: https://github.com/apache/kafka/pull/12010#discussion_r845759271
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorMakerConfigTest.java:
##
@@ -49,15 +53,15 @@ public void testClusterConfigProperties() {
RivenSun2 commented on PR #12010:
URL: https://github.com/apache/kafka/pull/12010#issuecomment-1092480807
Hi @showuon
I'll tease out a KIP later that aims to add it for configs with missing
validators. The changes involved in the public interface will be pointed out in
the text.
Than
76 matches
Mail list logo
