[
https://issues.apache.org/jira/browse/KAFKA-8154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292717#comment-17292717
]
Ori Popowski commented on KAFKA-8154:
-
[~gordonmessmer] I don't see any Alena or a pa
[
https://issues.apache.org/jira/browse/KAFKA-9752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292724#comment-17292724
]
Peter Sinoros-Szabo commented on KAFKA-9752:
Do you think [~hachikuji] that t
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://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients
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
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
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 automat
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
Issu
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
[
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
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"/>
+ files="(KafkaStreams|KS
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_r584621434
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -463,9 +464,8 @@ private void replaceStreamThread(final Throwable thr
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,
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,
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 automat
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 TransactionStateManager(br
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) {
[
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 environment2
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) {
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 Se
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.
--
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.
[
https://issues.apache.org/jira/browse/KAFKA-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292852#comment-17292852
]
Tom Bentley commented on KAFKA-8946:
I think this is a bug in org.apache.kafka.connec
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-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 bat
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 t
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.
---
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.
--
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 upgrade
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 respond
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 th
[
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
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 com
[
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 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
CVE-2020-27218](https://github.com/apache/kafka/pull/1017
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 tes
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
[
https://issues.apache.org/jira/browse/KAFKA-12393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292946#comment-17292946
]
ASF GitHub Bot commented on KAFKA-12393:
miguno opened a new pull request #334:
[
https://issues.apache.org/jira/browse/KAFKA-12393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292947#comment-17292947
]
Michael G. Noll commented on KAFKA-12393:
-
PR up at https://github.com/apache/ka
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
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 t
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 t
[
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 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: 3.0.0
> Source connectors should report error when trying to produce records to
[
https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292993#comment-17292993
]
Randall Hauch commented on KAFKA-10340:
---
[~xakassi] wrote:
{quote}
And also I can
[
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&focusedCommentId=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
]
Randall Hauch updated KAFKA-10340:
--
Fix Version/s: (was: 2.7.1)
> Source connectors should report error when trying to produce
[
https://issues.apache.org/jira/browse/KAFKA-12253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292997#comment-17292997
]
Jose Armando Garcia Sancio commented on KAFKA-12253:
Hi [~rohitdesha
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 produceRequestGetErrorResp
[
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 to
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 respon
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.
--
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 add
[
https://issues.apache.org/jira/browse/KAFKA-12393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17293011#comment-17293011
]
ASF GitHub Bot commented on KAFKA-12393:
miguno commented on pull request #334:
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 (KAFKA-10340)[https://issues.apache.org/jira/brow
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 ru
[
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 configs
[
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
>
[
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: KAFKA-
[
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-10582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17293034#comment-17293034
]
Leonid Ilyevsky commented on KAFKA-10582:
-
Actually, it does work without cleani
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 th
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
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 re
[
https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17293057#comment-17293057
]
Matthias J. Sax commented on KAFKA-12377:
-
Failed again with same error message.
[
https://issues.apache.org/jira/browse/KAFKA-12253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17293060#comment-17293060
]
Rohit Deshpande commented on KAFKA-12253:
-
Thank you. Will go through those test
[
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
> Rep
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 shouldBeReb
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 createS
[
https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17293091#comment-17293091
]
Matthias J. Sax commented on KAFKA-10383:
-
[~marcolotz] Are you all set in the m
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 respond
[
https://issues.apache.org/jira/browse/KAFKA-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17293107#comment-17293107
]
Matthias J. Sax commented on KAFKA-12283:
-
[https://github.com/apache/kafka/pull
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 th
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 the
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 Git
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 add
guozhangwang merged pull request #10231:
URL: https://github.com/apache/kafka/pull/10231
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
rondagostino commented on pull request #10225:
URL: https://github.com/apache/kafka/pull/10225#issuecomment-788225857
https://issues.apache.org/jira/browse/KAFKA-12381
This is an automated message from the Apache Git Service.
rondagostino commented on pull request #10225:
URL: https://github.com/apache/kafka/pull/10225#issuecomment-788226851
This PR "fixes" the issue by changing the system test to check for the new
error. We can close this PR in favor of another one if @abbccdda decides the
behavior change is
Jason Gustafson created KAFKA-12394:
---
Summary: Consider topic id existence and authorization errors
Key: KAFKA-12394
URL: https://issues.apache.org/jira/browse/KAFKA-12394
Project: Kafka
Is
hachikuji commented on a change in pull request #10223:
URL: https://github.com/apache/kafka/pull/10223#discussion_r585014029
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1884,20 +1884,24 @@ class KafkaApis(val requestChannel: RequestChannel,
val
guozhangwang merged pull request #10205:
URL: https://github.com/apache/kafka/pull/10205
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
guozhangwang commented on pull request #10205:
URL: https://github.com/apache/kafka/pull/10205#issuecomment-788238202
Cherry-picked to 2.8 and 2.7, cc RM @vvcephei
This is an automated message from the Apache Git Service.
To
hachikuji commented on a change in pull request #10223:
URL: https://github.com/apache/kafka/pull/10223#discussion_r585017852
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1874,7 +1874,7 @@ class KafkaApis(val requestChannel: RequestChannel,
if
hachikuji commented on pull request #10223:
URL: https://github.com/apache/kafka/pull/10223#issuecomment-788239224
@jolshan @chia7712 I don't think `KafkaApis` has been rewritten yet. My
suggestion is probably get this checked in as is so that we can definitely get
it into 2.8. Then we sho
hachikuji edited a comment on pull request #10223:
URL: https://github.com/apache/kafka/pull/10223#issuecomment-788239224
@jolshan @chia7712 I don't think `KafkaApis` has been rewritten yet. My
suggestion is probably get this checked in as is so that we can definitely get
it into 2.8. Then
gharris1727 commented on a change in pull request #8259:
URL: https://github.com/apache/kafka/pull/8259#discussion_r585020737
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/SynchronizationTest.java
##
@@ -0,0 +1,468 @@
+/*
+ * Licensed t
[
https://issues.apache.org/jira/browse/KAFKA-12394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17293155#comment-17293155
]
Ismael Juma commented on KAFKA-12394:
-
{quote}There is an argument to be made for TO
gharris1727 commented on pull request #8259:
URL: https://github.com/apache/kafka/pull/8259#issuecomment-788250316
Now that the bug is fixed, some comments are explicitly incorrect. For
example:
```
// 1. Lock the PluginClassLoader (via PluginClassLoader::loadClass)
hachikuji commented on a change in pull request #10223:
URL: https://github.com/apache/kafka/pull/10223#discussion_r585027051
##
File path: core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
##
@@ -3479,6 +3481,161 @@ class KafkaApisTest {
assertEquals(List(mkTopicD
[
https://issues.apache.org/jira/browse/KAFKA-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-12381:
Component/s: core
> Incompatible change in verifiable_producer.log in 2.8
> --
[
https://issues.apache.org/jira/browse/KAFKA-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-12381:
Labels: kip-500 (was: )
> Incompatible change in verifiable_producer.log in 2.8
> ---
[
https://issues.apache.org/jira/browse/KAFKA-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17293161#comment-17293161
]
Boyang Chen commented on KAFKA-12381:
-
[~cmccabe] Could you provide more specific de
jolshan commented on pull request #10223:
URL: https://github.com/apache/kafka/pull/10223#issuecomment-788251941
@hachikuji Ah sorry. I was misreading the file name. Makes sense.
This is an automated message from the Apache G
[
https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17293166#comment-17293166
]
Marco Lotz commented on KAFKA-10383:
[~mjsax] the KIP is available
[here|https://cw
Jason Gustafson created KAFKA-12395:
---
Summary: Drop topic mapKey in DeleteTopics response
Key: KAFKA-12395
URL: https://issues.apache.org/jira/browse/KAFKA-12395
Project: Kafka
Issue Type:
hachikuji commented on a change in pull request #10223:
URL: https://github.com/apache/kafka/pull/10223#discussion_r585036724
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1884,20 +1884,24 @@ class KafkaApis(val requestChannel: RequestChannel,
val
vanhoale opened a new pull request #10239:
URL: https://github.com/apache/kafka/pull/10239
[JIRA](https://issues.apache.org/jira/browse/KAFKA-12372)
Our team is having an issue of handling multiple timestamp fields in a kafka
message, so for now if we use the converter then we have t
MarcoLotz commented on pull request #10042:
URL: https://github.com/apache/kafka/pull/10042#issuecomment-788295749
@mjsax can you please have a quick look on the updated tests?
This is an automated message from the Apache Git
1 - 100 of 177 matches
Mail list logo
