chia7712 commented on pull request #10558:
URL: https://github.com/apache/kafka/pull/10558#issuecomment-824590923
@wenbingshen thanks for the updated code. I will merge it after QA pass.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
chia7712 commented on a change in pull request #9627:
URL: https://github.com/apache/kafka/pull/9627#discussion_r618116850
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java
##
@@ -203,8 +203,8 @@ public void request
wenbingshen commented on a change in pull request #10558:
URL: https://github.com/apache/kafka/pull/10558#discussion_r618114376
##
File path: core/src/test/scala/unit/kafka/admin/LeaderElectionCommandTest.scala
##
@@ -273,6 +273,48 @@ final class LeaderElectionCommandTest exten
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Travis Bischel updated KAFKA-12701:
---
Description:
Authorized result checking relies on topic name to not be null, which, when
us
Rohan Desai created KAFKA-12707:
---
Summary: KafkaProducer should have a clearer error message on
sasl.mechanism misconfiguration
Key: KAFKA-12707
URL: https://issues.apache.org/jira/browse/KAFKA-12707
Pr
chia7712 commented on a change in pull request #10582:
URL: https://github.com/apache/kafka/pull/10582#discussion_r618112622
##
File path: tests/docker/Dockerfile
##
@@ -60,7 +60,7 @@ RUN mkdir -p "/opt/kafka-2.2.2" && chmod a+rw
/opt/kafka-2.2.2 && curl -s "$KAFK
RUN mkdir -
wenbingshen commented on a change in pull request #10586:
URL: https://github.com/apache/kafka/pull/10586#discussion_r618111371
##
File path: core/src/main/scala/kafka/server/BrokerServer.scala
##
@@ -272,7 +273,7 @@ class BrokerServer(
val networkListeners = new Listene
tombentley commented on a change in pull request #10530:
URL: https://github.com/apache/kafka/pull/10530#discussion_r618109470
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java
##
@@ -357,21 +358,53 @@ public URI advertisedUrl()
showuon commented on pull request #9627:
URL: https://github.com/apache/kafka/pull/9627#issuecomment-824571219
@chia7712 , sorry, it's been a long time, and looks like the original author
and reviewer is busy, could you help check this PR? Quite straightforward to
update some logging logic
chia7712 commented on a change in pull request #10586:
URL: https://github.com/apache/kafka/pull/10586#discussion_r618107415
##
File path: core/src/main/scala/kafka/server/BrokerServer.scala
##
@@ -272,7 +273,7 @@ class BrokerServer(
val networkListeners = new ListenerCo
highluck commented on pull request #9640:
URL: https://github.com/apache/kafka/pull/9640#issuecomment-824559138
@guozhangwang
The code has been modified.
If the phrase is strange, please tell me Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the m
guozhangwang commented on a change in pull request #9640:
URL: https://github.com/apache/kafka/pull/9640#discussion_r618085808
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java
##
@@ -110,7 +110,10 @@ public void assig
kkonstantine merged pull request #10580:
URL: https://github.com/apache/kafka/pull/10580
--
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.
For queries about this service, p
kkonstantine commented on pull request #10580:
URL: https://github.com/apache/kafka/pull/10580#issuecomment-824542872
Failures were not relevant.
--
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
melan closed pull request #840:
URL: https://github.com/apache/kafka/pull/840
--
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.
For queries about this service, please conta
wenbingshen commented on pull request #10586:
URL: https://github.com/apache/kafka/pull/10586#issuecomment-824529067
Dear @chia7712 , I request apply this pr to the 2.8 branch.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
wenbingshen opened a new pull request #10586:
URL: https://github.com/apache/kafka/pull/10586
Link to [KAFKA-12702](https://issues.apache.org/jira/browse/KAFKA-12702) ,
[10575](https://github.com/apache/kafka/pull/10575)
### Committer Checklist (excluded from commit message)
- [ ]
chia7712 opened a new pull request #10585:
URL: https://github.com/apache/kafka/pull/10585
The command used by our private CI is `./gradlew cleanTest xxx:test`. It
does not re-run test when we use `unitTest` and `integrationTest` to replace
`test`. The root cause is that we don't offer tes
chia7712 merged pull request #10574:
URL: https://github.com/apache/kafka/pull/10574
--
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.
For queries about this service, pleas
wenbingshen commented on pull request #10575:
URL: https://github.com/apache/kafka/pull/10575#issuecomment-824508678
> @wenbingshen As `Utils.isBlank(ep.host)` does not exist in 2.8, could you
file another PR for 2.8 branch?
Of course, I will do it now, thank you for your guidance. :
chia7712 commented on pull request #10575:
URL: https://github.com/apache/kafka/pull/10575#issuecomment-824507357
@wenbingshen As `Utils.isBlank(ep.host)` does not exist in 2.8, could you
file another PR for 2.8 branch?
--
This is an automated message from the Apache Git Service.
To resp
[
https://issues.apache.org/jira/browse/KAFKA-12621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jibitesh Prasad closed KAFKA-12621.
---
> Kafka setup with Zookeeper- specifying an alternate znode creates the
> configuration at the
[
https://issues.apache.org/jira/browse/KAFKA-12621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jibitesh Prasad resolved KAFKA-12621.
-
Resolution: Fixed
Incorrect configuration on my part
> Kafka setup with Zookeeper- spec
[
https://issues.apache.org/jira/browse/KAFKA-12621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327073#comment-17327073
]
Jibitesh Prasad commented on KAFKA-12621:
-
Thanks! I completely missed that.
>
chia7712 merged pull request #10575:
URL: https://github.com/apache/kafka/pull/10575
--
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.
For queries about this service, pleas
[
https://issues.apache.org/jira/browse/KAFKA-12705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12705:
Component/s: unit tests
> Task idling is not sufficiently tested
> ---
jolshan edited a comment on pull request #10576:
URL: https://github.com/apache/kafka/pull/10576#issuecomment-824501282
@dengziming. I just saw this, so I didn't realize you were working on this
too. I should have paid better attention. I opened
https://github.com/apache/kafka/pull/10584
jolshan commented on pull request #10576:
URL: https://github.com/apache/kafka/pull/10576#issuecomment-824501282
@dengziming. I should have paid attention. I just saw this. I opened
https://github.com/apache/kafka/pull/10584
--
This is an automated message from the Apache Git Service.
To
jolshan opened a new pull request #10584:
URL: https://github.com/apache/kafka/pull/10584
We prevent handling MetadataRequests where the topic name is null (to
prevent NPE) as well as prevent requests that set topic IDs since this
functionality has not yet been implemented. When we do impl
mjsax merged pull request #10565:
URL: https://github.com/apache/kafka/pull/10565
--
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.
For queries about this service, please c
jolshan commented on pull request #10583:
URL: https://github.com/apache/kafka/pull/10583#issuecomment-824496045
Closed, will retarget to trunk.
--
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
jolshan closed pull request #10583:
URL: https://github.com/apache/kafka/pull/10583
--
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.
For queries about this service, please
hachikuji commented on a change in pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#discussion_r618025026
##
File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
##
@@ -905,19 +908,32 @@ class GroupCoordinator(val brokerId: Int,
*
hachikuji commented on a change in pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#discussion_r618021571
##
File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
##
@@ -905,19 +907,33 @@ class GroupCoordinator(val brokerId: Int,
*
hachikuji commented on a change in pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#discussion_r618021571
##
File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
##
@@ -905,19 +907,33 @@ class GroupCoordinator(val brokerId: Int,
*
hachikuji commented on pull request #10483:
URL: https://github.com/apache/kafka/pull/10483#issuecomment-824473278
@chia7712 Thanks for the comments. I finally had a chance to address them.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
hachikuji commented on a change in pull request #10483:
URL: https://github.com/apache/kafka/pull/10483#discussion_r618008786
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/TransactionState.java
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache Software Fo
jolshan opened a new pull request #10583:
URL: https://github.com/apache/kafka/pull/10583
This is the change for 2.8 that should be used in 2.8.1. We prevent handling
MetadataRequests where the topic name is null (to prevent NPE) as well as
prevent requests that set topic IDs since this fu
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326652#comment-17326652
]
Justine Olshan edited comment on KAFKA-12701 at 4/22/21, 12:09 AM:
---
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326909#comment-17326909
]
Justine Olshan edited comment on KAFKA-12701 at 4/22/21, 12:09 AM:
---
ableegoldman commented on a change in pull request #10542:
URL: https://github.com/apache/kafka/pull/10542#discussion_r617962722
##
File path:
streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java
##
@@ -177,9 +177,8 @@ public static
[
https://issues.apache.org/jira/browse/KAFKA-9772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327015#comment-17327015
]
Jason Gustafson commented on KAFKA-9772:
My mistake. This case is a little differ
[
https://issues.apache.org/jira/browse/KAFKA-12699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327007#comment-17327007
]
A. Sophie Blee-Goldman commented on KAFKA-12699:
Marking it down for 3.0
[
https://issues.apache.org/jira/browse/KAFKA-12699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-12699:
---
Fix Version/s: 3.0.0
> Streams no longer overrides the java default uncaught
[
https://issues.apache.org/jira/browse/KAFKA-12699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327006#comment-17327006
]
A. Sophie Blee-Goldman commented on KAFKA-12699:
> we should have the ex
[
https://issues.apache.org/jira/browse/KAFKA-9772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson reassigned KAFKA-9772:
--
Assignee: Jason Gustafson
> Transactional offset commit fails with IllegalStateExcepti
[
https://issues.apache.org/jira/browse/KAFKA-9772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326994#comment-17326994
]
Jason Gustafson commented on KAFKA-9772:
I noticed this recently in our logs. I b
A. Sophie Blee-Goldman created KAFKA-12706:
--
Summary: Consider adding reason and source of error in
APPLICATION_SHUTDOWN
Key: KAFKA-12706
URL: https://issues.apache.org/jira/browse/KAFKA-12706
mjsax commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617936154
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
kafkaS
mjsax commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617936154
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
kafkaS
mjsax commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617935620
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
kafkaS
Walker Carlson created KAFKA-12705:
--
Summary: Task idling is not sufficiently tested
Key: KAFKA-12705
URL: https://issues.apache.org/jira/browse/KAFKA-12705
Project: Kafka
Issue Type: Improv
junrao commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r617904827
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/AbstractApiMessageAndVersionSerde.java
##
@@ -0,0 +1
junrao commented on a change in pull request #10564:
URL: https://github.com/apache/kafka/pull/10564#discussion_r617858509
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -172,47 +174,54 @@ String diff(PartitionControlInfo
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326909#comment-17326909
]
Justine Olshan commented on KAFKA-12701:
[~dengziming] I can work on the 2.8 ver
wcarlson5 commented on a change in pull request #10565:
URL: https://github.com/apache/kafka/pull/10565#discussion_r617857575
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -667,8 +668,15 @@ public boolean isProcessable(f
ableegoldman closed pull request #10581:
URL: https://github.com/apache/kafka/pull/10581
--
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.
For queries about this service, p
ableegoldman commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617845243
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
mjsax commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617844560
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
kafkaS
mjsax commented on pull request #10548:
URL: https://github.com/apache/kafka/pull/10548#issuecomment-824325232
> All of them already had the checks.
Sweet. I did not double check the code before.
Seems, `put(final Windowed sessionKey,...)` and `remove(final Windowed
sessionKe
ableegoldman commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617842172
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
mjsax commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617839610
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
kafkaS
mjsax commented on a change in pull request #10573:
URL: https://github.com/apache/kafka/pull/10573#discussion_r617826977
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
##
@@ -642,9 +647,13 @@ public void beginTransaction() throws
Pro
ableegoldman commented on pull request #10582:
URL: https://github.com/apache/kafka/pull/10582#issuecomment-824320067
Cherrypicked back to 2.8 and 2.7
--
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
ableegoldman commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617836508
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
ableegoldman commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617836508
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
[
https://issues.apache.org/jira/browse/KAFKA-5761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326876#comment-17326876
]
Kirill Rodionov edited comment on KAFKA-5761 at 4/21/21, 7:54 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-5761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326876#comment-17326876
]
Kirill Rodionov commented on KAFKA-5761:
If we're talking pooled/reused buffers (
ableegoldman merged pull request #10582:
URL: https://github.com/apache/kafka/pull/10582
--
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.
For queries about this service, p
ableegoldman opened a new pull request #10582:
URL: https://github.com/apache/kafka/pull/10582
--
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.
For queries about this
ableegoldman opened a new pull request #10581:
URL: https://github.com/apache/kafka/pull/10581
Seems this was missed to add during the original 2.6.0 release
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
kpatelatwork commented on pull request #10580:
URL: https://github.com/apache/kafka/pull/10580#issuecomment-824306271
done
--
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.
[
https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326860#comment-17326860
]
Matthias J. Sax commented on KAFKA-10493:
-
Thinking about this ticket once more,
C0urante commented on pull request #10580:
URL: https://github.com/apache/kafka/pull/10580#issuecomment-824300835
Sure, I mean this:
```java
private ConcurrentMap tempConnectors = new
ConcurrentHashMap<>();
```
--
This is an automated message from the Apache Git Service.
To
kpatelatwork commented on pull request #10580:
URL: https://github.com/apache/kafka/pull/10580#issuecomment-824299926
> We may want to upgrade `tempConnectors` from a regular `Map` to a
`ConcurrentMap` as well, LGTM otherwise though.
it's already a ConcurrentHashMap :).
`priva
[
https://issues.apache.org/jira/browse/KAFKA-12696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326845#comment-17326845
]
Matthias J. Sax commented on KAFKA-12696:
-
{quote}Ok. Just to confirm, the confl
C0urante edited a comment on pull request #10566:
URL: https://github.com/apache/kafka/pull/10566#issuecomment-824292010
Hmm... I'm wondering if this might break existing setups. Since the
`SchemaBuilder` class does implement the `Schema` interface, it's currently
possible to do something
C0urante edited a comment on pull request #10566:
URL: https://github.com/apache/kafka/pull/10566#issuecomment-824292010
Hmm... I'm wondering if this might break existing setups. Since the
`SchemaBuilder` class does implement the `Schema` interface, it's currently
possible to do something
C0urante commented on pull request #10566:
URL: https://github.com/apache/kafka/pull/10566#issuecomment-824292010
Hmm... I'm wondering if this might break existing setups. Since the
`SchemaBuilder` class does implement the `Schema` interface, it's currently
possible to do something like th
ableegoldman commented on a change in pull request #10565:
URL: https://github.com/apache/kafka/pull/10565#discussion_r617805969
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -667,8 +668,15 @@ public boolean isProcessabl
Naros commented on pull request #10566:
URL: https://github.com/apache/kafka/pull/10566#issuecomment-824277958
@C0urante @rhauch , could either of you review this to see if its acceptable?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
ableegoldman merged pull request #10570:
URL: https://github.com/apache/kafka/pull/10570
--
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.
For queries about this service, p
cmccabe commented on a change in pull request #10564:
URL: https://github.com/apache/kafka/pull/10564#discussion_r617785244
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -1119,6 +1053,62 @@ void validateManualPartitionAss
junrao commented on a change in pull request #10564:
URL: https://github.com/apache/kafka/pull/10564#discussion_r617773890
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -321,22 +339,17 @@ public void replay(PartitionRecor
C0urante commented on pull request #10580:
URL: https://github.com/apache/kafka/pull/10580#issuecomment-824267968
We may want to upgrade `tempConnectors` from a regular `Map` to a
`ConcurrentMap` as well, LGTM otherwise though.
--
This is an automated message from the Apache Git Service.
kpatelatwork opened a new pull request #10580:
URL: https://github.com/apache/kafka/pull/10580
*Concurrent requests to validate endpoint for the same connector type calls
AbstractHerder::getConnector to get the cached connector instances and if the
connector hasn't been cached yet then th
junrao commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r617765100
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataContextSerdes.java
##
@@ -0,0 +1,12
junrao commented on pull request #10576:
URL: https://github.com/apache/kafka/pull/10576#issuecomment-824228739
@dengziming : We probably can't remove a field from an existing protocol
without changing the version. Otherwise, the client will be confused on the
exact protocol for a particul
[
https://issues.apache.org/jira/browse/KAFKA-9560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kalpesh Patel updated KAFKA-9560:
-
Description:
Requests to the {{PUT /connector-plugins/\{connectorType}/config/validate}}
endpoin
[
https://issues.apache.org/jira/browse/KAFKA-12704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kalpesh Patel updated KAFKA-12704:
--
Description:
As discovered in KAFKA-9560, concurrent requests to the {{PUT
/connector-plugins
[
https://issues.apache.org/jira/browse/KAFKA-12704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kalpesh Patel updated KAFKA-12704:
--
Description:
Concurrent requests to the {{PUT
/connector-plugins/\{connectorType}/config/vali
[
https://issues.apache.org/jira/browse/KAFKA-12704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kalpesh Patel reassigned KAFKA-12704:
-
Assignee: Kalpesh Patel
> Concurrent calls to AbstractHerder::getConnector can potentia
Kalpesh Patel created KAFKA-12704:
-
Summary: Concurrent calls to AbstractHerder::getConnector can
potentially create two connector instances
Key: KAFKA-12704
URL: https://issues.apache.org/jira/browse/KAFKA-12704
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326652#comment-17326652
]
Justine Olshan edited comment on KAFKA-12701 at 4/21/21, 3:58 PM:
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326628#comment-17326628
]
Justine Olshan edited comment on KAFKA-12701 at 4/21/21, 3:49 PM:
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326628#comment-17326628
]
Justine Olshan edited comment on KAFKA-12701 at 4/21/21, 3:49 PM:
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326652#comment-17326652
]
Justine Olshan commented on KAFKA-12701:
[~dengziming] Just to clarify, we did n
[
https://issues.apache.org/jira/browse/KAFKA-12696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326641#comment-17326641
]
Ismael Juma commented on KAFKA-12696:
-
The "avoid getters and setters" note applies
[
https://issues.apache.org/jira/browse/KAFKA-12696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326635#comment-17326635
]
Mikhail Panchenko commented on KAFKA-12696:
---
Ok. Just to confirm, the confluen
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326633#comment-17326633
]
Ismael Juma commented on KAFKA-12701:
-
I suggest fixing it in 3.0.0 and 2.8.1.
> NP
1 - 100 of 146 matches
Mail list logo
