guozhangwang commented on pull request #10231:
URL: https://github.com/apache/kafka/pull/10231#issuecomment-788209240
> It would be good to include a bit more context in the PR description
regarding the motivation. I assume it's noisy and doesn't add useful
information.
SG, will
bbejeck commented on pull request #10150:
URL: https://github.com/apache/kafka/pull/10150#issuecomment-788208213
including @lct45 and @wcarlson5 in the review request as well
This is an automated message from the Apache
mjsax commented on pull request #10229:
URL: https://github.com/apache/kafka/pull/10229#issuecomment-788192044
Thanks @dengziming! Merged to `trunk`.
This is an automated message from the Apache Git Service.
To respond to
mjsax merged pull request #10229:
URL: https://github.com/apache/kafka/pull/10229
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-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293107#comment-17293107
]
Matthias J. Sax commented on KAFKA-12283:
-
bbejeck commented on pull request #10150:
URL: https://github.com/apache/kafka/pull/10150#issuecomment-788178028
ping @mjsax @cadonna @vvcephei for reviews
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293091#comment-17293091
]
Matthias J. Sax commented on KAFKA-10383:
-
[~marcolotz] Are you all set in the mean time?
>
abbccdda commented on a change in pull request #10156:
URL: https://github.com/apache/kafka/pull/10156#discussion_r584950105
##
File path:
clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java
##
@@ -211,15 +390,15 @@ private SSLEngine
abbccdda commented on a change in pull request #10156:
URL: https://github.com/apache/kafka/pull/10156#discussion_r584949583
##
File path:
clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java
##
@@ -106,10 +138,7 @@ public boolean
[
https://issues.apache.org/jira/browse/KAFKA-12253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293060#comment-17293060
]
Rohit Deshpande commented on KAFKA-12253:
-
Thank you. Will go through those test classes and
[
https://issues.apache.org/jira/browse/KAFKA-12253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rohit Deshpande reassigned KAFKA-12253:
---
Assignee: Rohit Deshpande
> Add tests that cover all of all of the cases for
>
[
https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293057#comment-17293057
]
Matthias J. Sax commented on KAFKA-12377:
-
Failed again with same error message.
> Flaky Test
junrao commented on a change in pull request #10216:
URL: https://github.com/apache/kafka/pull/10216#discussion_r584915517
##
File path: core/src/test/scala/unit/kafka/log/LogTest.scala
##
@@ -1515,6 +1515,27 @@ class LogTest {
"expect a single producer state snapshot
tombentley commented on a change in pull request #10227:
URL: https://github.com/apache/kafka/pull/10227#discussion_r584906630
##
File path: KIP-500.md
##
@@ -0,0 +1,131 @@
+KIP-500 Early Access Release
+
+
+# Introduction
+It is now possible to run
dajac merged pull request #10236:
URL: https://github.com/apache/kafka/pull/10236
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-10582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293034#comment-17293034
]
Leonid Ilyevsky commented on KAFKA-10582:
-
Actually, it does work without cleaning up that
[
https://issues.apache.org/jira/browse/KAFKA-12254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dhruvil Shah updated KAFKA-12254:
-
Affects Version/s: 2.4.0
2.5.0
2.4.1
[
https://issues.apache.org/jira/browse/KAFKA-8929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dhruvil Shah updated KAFKA-8929:
Priority: Major (was: Minor)
> MM2 system tests
>
>
> Key:
[
https://issues.apache.org/jira/browse/KAFKA-12254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dhruvil Shah updated KAFKA-12254:
-
Priority: Blocker (was: Major)
> MirrorMaker 2.0 creates destination topic with default
[
https://issues.apache.org/jira/browse/KAFKA-12254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dhruvil Shah updated KAFKA-12254:
-
Affects Version/s: 2.8.0
> MirrorMaker 2.0 creates destination topic with default configs
>
rondagostino commented on a change in pull request #10227:
URL: https://github.com/apache/kafka/pull/10227#discussion_r584875012
##
File path: KIP-500.md
##
@@ -0,0 +1,131 @@
+KIP-500 Early Access Release
+
+
+# Introduction
+It is now possible to
rhauch opened a new pull request #10238:
URL: https://github.com/apache/kafka/pull/10238
**_NOTE: This is targeted to the `2.8` branch (currently frozen), but
includes the same commit cherry-picked from `trunk` and originating in #10016
for
[
https://issues.apache.org/jira/browse/KAFKA-12393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293011#comment-17293011
]
ASF GitHub Bot commented on KAFKA-12393:
miguno commented on pull request #334:
URL:
rondagostino opened a new pull request #10237:
URL: https://github.com/apache/kafka/pull/10237
The system test in `delegation_token_test.py` broke due to
https://github.com/apache/kafka/pull/10199/.
That patch changed the logic of `SecurityConfig.enabled_sasl_mechanisms()`
to only
ijuma commented on pull request #10231:
URL: https://github.com/apache/kafka/pull/10231#issuecomment-788086223
It would be good to include a bit more context in the PR description
regarding the motivation. I assume it's noisy and doesn't add useful
information.
ijuma commented on pull request #10203:
URL: https://github.com/apache/kafka/pull/10203#issuecomment-788083914
@chia7712 Are you ok after the latest changes?
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10340:
--
Fix Version/s: 2.7.1
> Source connectors should report error when trying to produce records
ijuma commented on a change in pull request #9758:
URL: https://github.com/apache/kafka/pull/9758#discussion_r584812552
##
File path:
clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java
##
@@ -791,15 +791,18 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-12253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292997#comment-17292997
]
Jose Armando Garcia Sancio commented on KAFKA-12253:
Hi [~rohitdeshaws]
Please go
[
https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10340:
--
Fix Version/s: (was: 2.7.1)
> Source connectors should report error when trying to
[
https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292993#comment-17292993
]
Randall Hauch edited comment on KAFKA-10340 at 3/1/21, 4:16 PM:
[
https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-10340:
--
Affects Version/s: 2.8.0
2.5.1
2.7.0
[
https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292993#comment-17292993
]
Randall Hauch commented on KAFKA-10340:
---
[~xakassi] wrote:
{quote}
And also I cannot understand,
[
https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10340:
--
Fix Version/s: 2.7.1
> Source connectors should report error when trying to produce records
[
https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10340:
--
Fix Version/s: 3.0.0
> Source connectors should report error when trying to produce records
rhauch merged pull request #10016:
URL: https://github.com/apache/kafka/pull/10016
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
wcarlson5 commented on a change in pull request #10215:
URL: https://github.com/apache/kafka/pull/10215#discussion_r584812254
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -463,9 +464,8 @@ private void replaceStreamThread(final Throwable
C0urante commented on a change in pull request #9541:
URL: https://github.com/apache/kafka/pull/9541#discussion_r584810742
##
File path:
connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java
##
@@ -266,10 +261,19 @@ public static void validateValue(String
[
https://issues.apache.org/jira/browse/KAFKA-12393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292947#comment-17292947
]
Michael G. Noll commented on KAFKA-12393:
-
PR up at
[
https://issues.apache.org/jira/browse/KAFKA-12393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292946#comment-17292946
]
ASF GitHub Bot commented on KAFKA-12393:
miguno opened a new pull request #334:
URL:
Michael G. Noll created KAFKA-12393:
---
Summary: Document multi-tenancy considerations
Key: KAFKA-12393
URL: https://issues.apache.org/jira/browse/KAFKA-12393
Project: Kafka
Issue Type: Bug
dajac opened a new pull request #10236:
URL: https://github.com/apache/kafka/pull/10236
Follow-up of
https://github.com/apache/kafka/pull/9958#discussion_r582662669.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify
dongjinleekr commented on pull request #10235:
URL: https://github.com/apache/kafka/pull/10235#issuecomment-787990779
@omkreddy This commit should be cherry-picked onto 2.8, 2.7 and 2.6 branch
like [KAFKA-12324: Upgrade jetty to fix
[
https://issues.apache.org/jira/browse/KAFKA-12389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongjin Lee reassigned KAFKA-12389:
---
Assignee: Dongjin Lee
> Upgrade of netty-codec due to CVE-2021-21290
>
dongjinleekr opened a new pull request #10235:
URL: https://github.com/apache/kafka/pull/10235
This security vulnerability is related to netty itself and fixed in
4.1.59.Final. So, upgrade the netty version from 4.1.51.Final to 4.1.59.Final.
### Committer Checklist (excluded from
[
https://issues.apache.org/jira/browse/KAFKA-12329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-12329.
-
Fix Version/s: 3.0.0
Resolution: Fixed
> kafka-reassign-partitions command should give a
dajac merged pull request #10141:
URL: https://github.com/apache/kafka/pull/10141
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
dajac commented on pull request #10141:
URL: https://github.com/apache/kafka/pull/10141#issuecomment-787968243
Failed test is not related. Merging to trunk.
This is an automated message from the Apache Git Service.
To
dajac opened a new pull request #10234:
URL: https://github.com/apache/kafka/pull/10234
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including
kamalcph edited a comment on pull request #10202:
URL: https://github.com/apache/kafka/pull/10202#issuecomment-787919773
Filed [KAFKA-12392](https://issues.apache.org/jira/browse/KAFKA-12392)
ticket and opened [KIP-717](https://cwiki.apache.org/confluence/x/DB1RCg) for
discussion.
kamalcph commented on pull request #10202:
URL: https://github.com/apache/kafka/pull/10202#issuecomment-787919773
Filed [KAFKA-12392](https://issues.apache.org/jira/browse/KAFKA-12392)
ticket and opened [KIP-717](https://cwiki.apache.org/confluence/x/DB1RCg) for
this.
viktorsomogyi opened a new pull request #10233:
URL: https://github.com/apache/kafka/pull/10233
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of
[
https://issues.apache.org/jira/browse/KAFKA-12392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash updated KAFKA-12392:
-
Affects Version/s: (was: 3.0.0)
2.7.0
> Deprecate
Kamal Chandraprakash created KAFKA-12392:
Summary: Deprecate batch-size config from console producer
Key: KAFKA-12392
URL: https://issues.apache.org/jira/browse/KAFKA-12392
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292852#comment-17292852
]
Tom Bentley commented on KAFKA-8946:
I think this is a bug in
kamalcph edited a comment on pull request #10202:
URL: https://github.com/apache/kafka/pull/10202#issuecomment-787891934
> Is there a JIRA/KIP where this deprecation was discussed?
No, I don't find any and it wasn't discussed. The config is unused so I
propose to deprecate it.
kamalcph commented on pull request #10202:
URL: https://github.com/apache/kafka/pull/10202#issuecomment-787891934
> Is there a JIRA/KIP where this deprecation was discussed?
No, I don't find any. The batch size config is unused.
tombentley commented on pull request #10202:
URL: https://github.com/apache/kafka/pull/10202#issuecomment-787888644
Is there a JIRA/KIP where this deprecation was discussed?
This is an automated message from the Apache Git
tombentley commented on a change in pull request #10193:
URL: https://github.com/apache/kafka/pull/10193#discussion_r584648224
##
File path:
clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java
##
@@ -320,7 +320,7 @@ public Long validate(Object item) {
[
https://issues.apache.org/jira/browse/KAFKA-10886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenbing Shen updated KAFKA-10886:
-
Attachment: (was: image-2021-03-01-14-29-55-418.png)
> Kafka crashed in windows
tombentley commented on a change in pull request #10193:
URL: https://github.com/apache/kafka/pull/10193#discussion_r584646665
##
File path:
clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java
##
@@ -320,7 +320,7 @@ public Long validate(Object item) {
tombentley commented on a change in pull request #10206:
URL: https://github.com/apache/kafka/pull/10206#discussion_r584641483
##
File path:
core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala
##
@@ -223,6 +224,46 @@ class
dajac commented on pull request #10141:
URL: https://github.com/apache/kafka/pull/10141#issuecomment-787870948
@chia7712 Thanks. I just pushed a commit to address your comment. Could you
take another look?
This is an
chia7712 commented on a change in pull request #10184:
URL: https://github.com/apache/kafka/pull/10184#discussion_r584628216
##
File path: core/src/main/scala/kafka/server/ControllerApis.scala
##
@@ -280,25 +281,34 @@ class ControllerApis(val requestChannel: RequestChannel,
chia7712 commented on a change in pull request #10184:
URL: https://github.com/apache/kafka/pull/10184#discussion_r584139776
##
File path: core/src/main/scala/kafka/server/ControllerApis.scala
##
@@ -154,6 +163,162 @@ class ControllerApis(val requestChannel: RequestChannel,
cadonna commented on a change in pull request #10215:
URL: https://github.com/apache/kafka/pull/10215#discussion_r584621434
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -463,9 +464,8 @@ private void replaceStreamThread(final Throwable
chia7712 commented on a change in pull request #10141:
URL: https://github.com/apache/kafka/pull/10141#discussion_r584616679
##
File path: core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala
##
@@ -812,6 +812,26 @@ object ReassignPartitionsCommand extends Logging {
cadonna commented on a change in pull request #10215:
URL: https://github.com/apache/kafka/pull/10215#discussion_r584613463
##
File path: checkstyle/suppressions.xml
##
@@ -161,7 +161,7 @@
files="StreamThread.java"/>
+
[
https://issues.apache.org/jira/browse/KAFKA-12391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luca Burgazzoli updated KAFKA-12391:
Description:
When writing Source Connectors for Kafka, it may be required to perform some
Luca Burgazzoli created KAFKA-12391:
---
Summary: Add an option to store arbitrary metadata to a
SourceRecord
Key: KAFKA-12391
URL: https://issues.apache.org/jira/browse/KAFKA-12391
Project: Kafka
Dominique Mongelli created KAFKA-12389:
--
Summary: Upgrade of netty-codec due to CVE-2021-21290
Key: KAFKA-12389
URL: https://issues.apache.org/jira/browse/KAFKA-12389
Project: Kafka
dajac commented on pull request #10141:
URL: https://github.com/apache/kafka/pull/10141#issuecomment-787818715
@chia7712 I just pushed an update. Please take a look and let me know what
you think about it.
This is an
Andrey created KAFKA-12390:
--
Summary: error when storing group assignment during SyncGroup
Key: KAFKA-12390
URL: https://issues.apache.org/jira/browse/KAFKA-12390
Project: Kafka
Issue Type: Bug
rajinisivaram merged pull request #10217:
URL: https://github.com/apache/kafka/pull/10217
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
dajac commented on pull request #10141:
URL: https://github.com/apache/kafka/pull/10141#issuecomment-787783411
> @dajac Nice improvement. Some minor comments are left. Please take a look.
>
> 1.
[
https://issues.apache.org/jira/browse/KAFKA-9752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292724#comment-17292724
]
Peter Sinoros-Szabo commented on KAFKA-9752:
Do you think [~hachikuji] that the problem we
[
https://issues.apache.org/jira/browse/KAFKA-8154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292717#comment-17292717
]
Ori Popowski commented on KAFKA-8154:
-
[~gordonmessmer] I don't see any Alena or a patch in your
101 - 177 of 177 matches
Mail list logo
