[
https://issues.apache.org/jira/browse/KAFKA-9942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Tan updated KAFKA-9942:
-
Description:
{quote}$ bin/kafka-configs.sh --bootstrap-server localhost:9092 --alter
--add-config produc
dajac opened a new pull request #8609:
URL: https://github.com/apache/kafka/pull/8609
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes
edoardocomar commented on a change in pull request #4204:
URL: https://github.com/apache/kafka/pull/4204#discussion_r419313971
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1035,11 +1035,13 @@ class ReplicaManager(val config: KafkaConfig,
val
d8tltanc opened a new pull request #8610:
URL: https://github.com/apache/kafka/pull/8610
*More detailed description of your change,
The client-side passes an empty string "" to the server controller
indicating that the quota changes apply to the default entity. However, the
server logic
showuon opened a new pull request #8611:
URL: https://github.com/apache/kafka/pull/8611
**before:**
Here, the notation words are not in different format, makes it hard to
[
https://issues.apache.org/jira/browse/KAFKA-9934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
kaushik srinivas updated KAFKA-9934:
Issue Type: Bug (was: Improvement)
> Information and doc update needed for support of AclA
[
https://issues.apache.org/jira/browse/KAFKA-9933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
kaushik srinivas updated KAFKA-9933:
Issue Type: Bug (was: Improvement)
> Need doc update on the AclAuthorizer when SASL_SSL is
[
https://issues.apache.org/jira/browse/KAFKA-9934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17098822#comment-17098822
]
kaushik srinivas commented on KAFKA-9934:
-
Hi
[~ijuma]
Need your inputs on this
[
https://issues.apache.org/jira/browse/KAFKA-9933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17098824#comment-17098824
]
kaushik srinivas commented on KAFKA-9933:
-
Hi
[~ijuma]
Need your inputs. We en
nizhikov commented on pull request #8592:
URL: https://github.com/apache/kafka/pull/8592#issuecomment-623398837
retest this
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
nizhikov edited a comment on pull request #8592:
URL: https://github.com/apache/kafka/pull/8592#issuecomment-623398837
failure unrelated
This is an automated message from the Apache Git Service.
To respond to the message, ple
nizhikov commented on pull request #8592:
URL: https://github.com/apache/kafka/pull/8592#issuecomment-623399649
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, p
nizhikov edited a comment on pull request #8592:
URL: https://github.com/apache/kafka/pull/8592#issuecomment-623398837
retest this please
This is an automated message from the Apache Git Service.
To respond to the mes
nizhikov removed a comment on pull request #8592:
URL: https://github.com/apache/kafka/pull/8592#issuecomment-623398837
retest this please
This is an automated message from the Apache Git Service.
To respond to the me
[
https://issues.apache.org/jira/browse/KAFKA-9933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17098850#comment-17098850
]
kaushik srinivas commented on KAFKA-9933:
-
Hi
[~ijuma]
We see when SASL (GSSAPI
[
https://issues.apache.org/jira/browse/KAFKA-8120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Wang updated KAFKA-8120:
Attachment: gen-mongodump.sh.txt
> Getting NegativeArraySizeException when using Kafka Connect to send data
[
https://issues.apache.org/jira/browse/KAFKA-8120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Wang updated KAFKA-8120:
Attachment: test.txt
> Getting NegativeArraySizeException when using Kafka Connect to send data to
> Kafka
wj1918 opened a new pull request #8612:
URL: https://github.com/apache/kafka/pull/8612
1. Trigger buffer expansion when buffer does not extract a line
2. Limit buffer size to Integer.MAX_VALUE
3. Using single loop inside FileStreamSourceTask.poll
4. Close the stream before throw
[
https://issues.apache.org/jira/browse/KAFKA-8120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17098935#comment-17098935
]
Jun Wang commented on KAFKA-8120:
-
Steps to reproduce and verify with kafka 2.5
1. run a
ijuma commented on pull request #8607:
URL: https://github.com/apache/kafka/pull/8607#issuecomment-623470067
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log o
[
https://issues.apache.org/jira/browse/KAFKA-8120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Wang updated KAFKA-8120:
Affects Version/s: 2.5.0
> Getting NegativeArraySizeException when using Kafka Connect to send data to
> K
lbradstreet commented on pull request #8609:
URL: https://github.com/apache/kafka/pull/8609#issuecomment-623488567
I haven't reviewed the PR, but I can confirm that I no longer see the
premature deletion behaviour that lead me to report KAFKA-9946.
bbejeck commented on pull request #8504:
URL: https://github.com/apache/kafka/pull/8504#issuecomment-623500291
>Is she? I guess it's clearly document that the name is use for repartition
topics, too, but it might still be an unexpected "side effect"? But I see the
point that it's not too e
cadonna opened a new pull request #8613:
URL: https://github.com/apache/kafka/pull/8613
This PR sets HighAvailabilityTaskAssignor as default task assignor in
streams_upgrade_test.py. The verification of the test needed to be
modified to because the HighAvailabilityTaskAssignor surfaced
cadonna commented on a change in pull request #8613:
URL: https://github.com/apache/kafka/pull/8613#discussion_r419496703
##
File path: tests/kafkatest/tests/streams/streams_upgrade_test.py
##
@@ -532,20 +532,22 @@ def do_rolling_bounce(self, processor, counter,
current_genera
cadonna commented on a change in pull request #8613:
URL: https://github.com/apache/kafka/pull/8613#discussion_r419496703
##
File path: tests/kafkatest/tests/streams/streams_upgrade_test.py
##
@@ -532,20 +532,22 @@ def do_rolling_bounce(self, processor, counter,
current_genera
cadonna commented on pull request #8613:
URL: https://github.com/apache/kafka/pull/8613#issuecomment-623520934
Call for review: @vvcephei @ableegoldman
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/KAFKA-8120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17098935#comment-17098935
]
Jun Wang edited comment on KAFKA-8120 at 5/4/20, 3:09 PM:
--
Steps
cadonna commented on pull request #8613:
URL: https://github.com/apache/kafka/pull/8613#issuecomment-623525749
System tests job:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/3928/
This is an automated me
dajac commented on pull request #8311:
URL: https://github.com/apache/kafka/pull/8311#issuecomment-623538567
@tombentley Did you consider adding a loop in at the end of the
`handleResponse` that would complete any non-completed future related to the
current `brokerId` with an exception?
[
https://issues.apache.org/jira/browse/KAFKA-9942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099083#comment-17099083
]
Cheng Tan commented on KAFKA-9942:
--
[https://github.com/apache/kafka/pull/8610] Patch he
C0urante commented on pull request #8608:
URL: https://github.com/apache/kafka/pull/8608#issuecomment-623571317
Thanks Ryanne!
@rhauch, @kkonstantine could one of you take a look at this when you have a
chance?
This i
C0urante commented on pull request #7823:
URL: https://github.com/apache/kafka/pull/7823#issuecomment-623571767
Closing as I have no plans to work on this any time in the near future.
This is an automated message from the Apa
C0urante commented on pull request #6644:
URL: https://github.com/apache/kafka/pull/6644#issuecomment-623572029
Closing as I have no plans to work on this any time in the near future.
This is an automated message from the Apa
cadonna commented on a change in pull request #8613:
URL: https://github.com/apache/kafka/pull/8613#discussion_r419496703
##
File path: tests/kafkatest/tests/streams/streams_upgrade_test.py
##
@@ -532,20 +532,22 @@ def do_rolling_bounce(self, processor, counter,
current_genera
C0urante commented on a change in pull request #8069:
URL: https://github.com/apache/kafka/pull/8069#discussion_r419580652
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/HerderConnectorContext.java
##
@@ -16,30 +16,64 @@
*/
package org.apache.k
C0urante commented on a change in pull request #8069:
URL: https://github.com/apache/kafka/pull/8069#discussion_r419583360
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java
##
@@ -191,32 +192,71 @@ public synchronized
C0urante commented on a change in pull request #8069:
URL: https://github.com/apache/kafka/pull/8069#discussion_r419585005
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java
##
@@ -191,32 +192,71 @@ public synchronized
tombentley commented on pull request #8311:
URL: https://github.com/apache/kafka/pull/8311#issuecomment-623591202
@dajac yes, fair point. And I notice now that create and delete topics
response handlers are already doing this (though the error messages in those
cases don't really make much
C0urante commented on a change in pull request #8069:
URL: https://github.com/apache/kafka/pull/8069#discussion_r419593948
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java
##
@@ -266,31 +422,51 @@ public void close() {
hachikuji commented on a change in pull request #8602:
URL: https://github.com/apache/kafka/pull/8602#discussion_r419595855
##
File path:
core/src/test/scala/integration/kafka/api/TransactionsBounceTest.scala
##
@@ -130,13 +129,10 @@ class TransactionsBounceTest extends
Kafka
chia7712 commented on a change in pull request #8605:
URL: https://github.com/apache/kafka/pull/8605#discussion_r419596851
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
##
@@ -662,12 +641,27 @@ public KafkaConsumer(Properties properti
[
https://issues.apache.org/jira/browse/KAFKA-9918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-9918.
Fix Version/s: 2.6.0
Resolution: Fixed
> SslEngineFactory is NOT closed when channel
hachikuji commented on a change in pull request #8585:
URL: https://github.com/apache/kafka/pull/8585#discussion_r419609984
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -949,8 +949,11 @@ class ReplicaManager(val config: KafkaConfig,
else
Jason Gustafson created KAFKA-9951:
--
Summary: More testing of ReplicaSelector
Key: KAFKA-9951
URL: https://issues.apache.org/jira/browse/KAFKA-9951
Project: Kafka
Issue Type: Improvement
mjsax commented on pull request #8600:
URL: https://github.com/apache/kafka/pull/8600#issuecomment-623612153
All three runs timed out.
Retest this please.
This is an automated message from the Apache Git Service.
To re
[
https://issues.apache.org/jira/browse/KAFKA-9929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099187#comment-17099187
]
Guozhang Wang commented on KAFKA-9929:
--
Hi [~jeqo], thanks for reporting this reques
[
https://issues.apache.org/jira/browse/KAFKA-9929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099187#comment-17099187
]
Guozhang Wang edited comment on KAFKA-9929 at 5/4/20, 5:59 PM:
[
https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099190#comment-17099190
]
Guozhang Wang commented on KAFKA-9859:
--
[~lkokhreidze] Do you want to send a PR to r
[
https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099196#comment-17099196
]
Levani Kokhreidze commented on KAFKA-9859:
--
Hi [~guozhang],
Was meaning to do i
[
https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Levani Kokhreidze reassigned KAFKA-9859:
Assignee: Levani Kokhreidze
> kafka-streams-application-reset tool doesn't take in
hachikuji commented on pull request #8607:
URL: https://github.com/apache/kafka/pull/8607#issuecomment-623617879
@ijuma Thanks for the patch. I think the change makes sense. Part of me is
inclined to drop the logic for immediate propagation of high watermark
entirely. Instead, we could say
hachikuji edited a comment on pull request #8607:
URL: https://github.com/apache/kafka/pull/8607#issuecomment-623617879
@ijuma Thanks for the patch. I think the change makes sense. Part of me is
inclined to drop the logic for the immediate propagation of the high watermark
entirely. Instea
ijuma commented on pull request #8607:
URL: https://github.com/apache/kafka/pull/8607#issuecomment-623620280
@hachikuji I was thinking the exact same thing. :) I thought this PR could
be the simple one we can backport and then we can discuss the larger change
separately as you suggested.
Jason Gustafson created KAFKA-9952:
--
Summary: Reconsider immediate propagation of hw when replica
selector is used
Key: KAFKA-9952
URL: https://issues.apache.org/jira/browse/KAFKA-9952
Project: Kafka
hachikuji commented on pull request #8607:
URL: https://github.com/apache/kafka/pull/8607#issuecomment-623630601
Filed this issue: https://issues.apache.org/jira/browse/KAFKA-9952.
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099287#comment-17099287
]
Nikolay Izhikov commented on KAFKA-3184:
[~guozhang]
> we need to make the check
DivLoic opened a new pull request #8614:
URL: https://github.com/apache/kafka/pull/8614
*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 testing s
vvcephei commented on a change in pull request #8613:
URL: https://github.com/apache/kafka/pull/8613#discussion_r419693644
##
File path: tests/kafkatest/tests/streams/streams_upgrade_test.py
##
@@ -532,20 +532,22 @@ def do_rolling_bounce(self, processor, counter,
current_gener
[
https://issues.apache.org/jira/browse/KAFKA-7472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099316#comment-17099316
]
Loic DIVAD commented on KAFKA-7472:
---
Hi, I would like to suggest the PR: [https://githu
vvcephei commented on pull request #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-623680367
Thanks @mjsax (and sorry I didn't see your comment before).
The ticket indicates that it was introduced in 2.5
(https://issues.apache.org/jira/browse/KAFKA-9127).
I
vvcephei edited a comment on pull request #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-623680367
Thanks @mjsax (and sorry I didn't see your comment before).
The ticket indicates that it was introduced in 2.5
(https://issues.apache.org/jira/browse/KAFKA-9127 , l
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099287#comment-17099287
]
Nikolay Izhikov edited comment on KAFKA-3184 at 5/4/20, 8:15 PM:
--
vvcephei commented on a change in pull request #8596:
URL: https://github.com/apache/kafka/pull/8596#discussion_r419705427
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##
@@ -877,7 +877,7 @@
public static final String
STREAMS_METADAT
ableegoldman commented on pull request #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-623690181
@vvcephei yeah the regression was only introduced in 2.5, so we only _need_
to backport it that far. But I actually would agree that we should backport it
to 2.4 as well: in
ableegoldman commented on a change in pull request #8596:
URL: https://github.com/apache/kafka/pull/8596#discussion_r419711999
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##
@@ -877,7 +877,7 @@
public static final String
STREAMS_MET
hachikuji commented on pull request #8609:
URL: https://github.com/apache/kafka/pull/8609#issuecomment-623696783
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
vvcephei commented on a change in pull request #8596:
URL: https://github.com/apache/kafka/pull/8596#discussion_r419718314
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##
@@ -877,7 +877,7 @@
public static final String
STREAMS_METADAT
vvcephei commented on a change in pull request #8596:
URL: https://github.com/apache/kafka/pull/8596#discussion_r419718786
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##
@@ -877,7 +877,7 @@
public static final String
STREAMS_METADAT
vvcephei commented on pull request #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-623697876
Thanks for the clarification. I'll see about backporting to 2.4...
This is an automated message from the Apache G
vvcephei commented on pull request #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-623701299
Actually @ableegoldman , the cherry-pick to 2.4 isn't straightforward. Do
you mind doing a separate PR for it?
T
lbradstreet commented on a change in pull request #8609:
URL: https://github.com/apache/kafka/pull/8609#discussion_r419725599
##
File path: core/src/main/scala/kafka/controller/ControllerChannelManager.scala
##
@@ -590,7 +569,26 @@ abstract class
AbstractControllerBrokerReques
vvcephei commented on pull request #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-623705234
Or, if it's too much trouble, we can just note on the ticket that it _could_
be backported, but isn't (yet)
This
Joost van de Wijgerd created KAFKA-9953:
---
Summary: support multiple consumerGroupCoordinators in
TransactionManager
Key: KAFKA-9953
URL: https://issues.apache.org/jira/browse/KAFKA-9953
Project:
cmccabe commented on pull request #8527:
URL: https://github.com/apache/kafka/pull/8527#issuecomment-623716775
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
[
https://issues.apache.org/jira/browse/KAFKA-7472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch reassigned KAFKA-7472:
Assignee: Loic DIVAD (was: Randall Hauch)
> Implement KIP-145 transformations
>
[
https://issues.apache.org/jira/browse/KAFKA-7472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099377#comment-17099377
]
Randall Hauch commented on KAFKA-7472:
--
Thanks, [~loicmdivad]. I'll take a look shor
ijuma commented on pull request #8607:
URL: https://github.com/apache/kafka/pull/8607#issuecomment-623757017
I added a test. @mumrah @gwenshap maybe one of you can take a quick look?
This is an automated message from the Apac
cmccabe commented on a change in pull request #8610:
URL: https://github.com/apache/kafka/pull/8610#discussion_r419793865
##
File path: core/src/main/scala/kafka/zk/KafkaZkClient.scala
##
@@ -329,11 +329,13 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient,
cmccabe commented on a change in pull request #8610:
URL: https://github.com/apache/kafka/pull/8610#discussion_r419793778
##
File path: core/src/main/scala/kafka/zk/KafkaZkClient.scala
##
@@ -329,11 +329,13 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient,
cmccabe commented on a change in pull request #8610:
URL: https://github.com/apache/kafka/pull/8610#discussion_r419794980
##
File path: core/src/main/scala/kafka/admin/ConfigCommand.scala
##
@@ -473,10 +474,11 @@ object ConfigCommand extends Config {
}
private def descr
cmccabe commented on pull request #8610:
URL: https://github.com/apache/kafka/pull/8610#issuecomment-623768582
Thanks for this, @d8tltanc . It seems like there are still some debug log
message left in?
Also, we definitely need a test for this one.
-
hachikuji commented on a change in pull request #8609:
URL: https://github.com/apache/kafka/pull/8609#discussion_r419803119
##
File path: core/src/main/scala/kafka/controller/ControllerChannelManager.scala
##
@@ -590,7 +569,26 @@ abstract class
AbstractControllerBrokerRequestB
Cheng Tan created KAFKA-9954:
Summary: Config command didn't validate the unsupported user
config change
Key: KAFKA-9954
URL: https://issues.apache.org/jira/browse/KAFKA-9954
Project: Kafka
Issu
guozhangwang commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r419795444
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -247,6 +270,20 @@ void initializeSto
d8tltanc opened a new pull request #8615:
URL: https://github.com/apache/kafka/pull/8615
*More detailed description of your change,
Throw an error when users are trying to alter user configs with AdminClient
*Summary of testing strategy (including rationale)
for the feature or b
d8tltanc commented on pull request #8610:
URL: https://github.com/apache/kafka/pull/8610#issuecomment-623785708
Thanks @cmccabe for the initial review. I'll remove all the warning logs
after the tests pass.
This is an auto
[
https://issues.apache.org/jira/browse/KAFKA-9954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Tan reassigned KAFKA-9954:
Assignee: Cheng Tan
> Config command didn't validate the unsupported user config change
>
ijuma commented on pull request #8607:
URL: https://github.com/apache/kafka/pull/8607#issuecomment-623787840
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log o
ableegoldman opened a new pull request #8616:
URL: https://github.com/apache/kafka/pull/8616
Copy of [pull/8540](https://github.com/apache/kafka/pull/8540) targeted at
2.4
This is an automated message from the Apache Git Ser
ableegoldman commented on pull request #8616:
URL: https://github.com/apache/kafka/pull/8616#issuecomment-623792498
@vvcephei
This is an automated message from the Apache Git Service.
To respond to the message, please log on
ableegoldman commented on a change in pull request #8596:
URL: https://github.com/apache/kafka/pull/8596#discussion_r419827086
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##
@@ -877,7 +877,7 @@
public static final String
STREAMS_MET
ableegoldman commented on a change in pull request #8613:
URL: https://github.com/apache/kafka/pull/8613#discussion_r419829020
##
File path: tests/kafkatest/tests/streams/streams_upgrade_test.py
##
@@ -532,20 +532,22 @@ def do_rolling_bounce(self, processor, counter,
current_g
ableegoldman commented on a change in pull request #8613:
URL: https://github.com/apache/kafka/pull/8613#discussion_r419829020
##
File path: tests/kafkatest/tests/streams/streams_upgrade_test.py
##
@@ -532,20 +532,22 @@ def do_rolling_bounce(self, processor, counter,
current_g
efeg commented on a change in pull request #8579:
URL: https://github.com/apache/kafka/pull/8579#discussion_r419833344
##
File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala
##
@@ -382,6 +382,11 @@ abstract class AbstractFetcherThread(name: String,
efeg commented on a change in pull request #8579:
URL: https://github.com/apache/kafka/pull/8579#discussion_r419833344
##
File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala
##
@@ -382,6 +382,11 @@ abstract class AbstractFetcherThread(name: String,
jeffkbkim opened a new pull request #8617:
URL: https://github.com/apache/kafka/pull/8617
*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.*
* `MockAdminClient` sho
[
https://issues.apache.org/jira/browse/KAFKA-9660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099499#comment-17099499
]
Li Wei commented on KAFKA-9660:
---
[~sujayopensource]
i am sorry for reply late. you can re
Greg Harris created KAFKA-9955:
--
Summary: Exceptions thrown from SinkTask::close shadow other
exceptions
Key: KAFKA-9955
URL: https://issues.apache.org/jira/browse/KAFKA-9955
Project: Kafka
Iss
omkreddy commented on pull request #8617:
URL: https://github.com/apache/kafka/pull/8617#issuecomment-623842653
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
1 - 100 of 121 matches
Mail list logo
