[
https://issues.apache.org/jira/browse/KAFKA-13669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493053#comment-17493053
]
Giovanni Marigi commented on KAFKA-13669:
-
Seen this with replicator and my cust
[
https://issues.apache.org/jira/browse/KAFKA-13390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493059#comment-17493059
]
Slawomir Messner commented on KAFKA-13390:
--
When will this fix be released? It
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r807660376
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,289
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r807663879
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,289
mosesonline commented on pull request #11426:
URL: https://github.com/apache/kafka/pull/11426#issuecomment-1041238766
When will this PR will be released in the 3.0.1/X releases?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
mimaison commented on pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#issuecomment-1041242867
It looks like this also affects system tests:
https://github.com/apache/kafka/pull/11769
--
This is an automated message from the Apache Git Service.
To respond to the messa
showuon commented on pull request #11426:
URL: https://github.com/apache/kafka/pull/11426#issuecomment-1041249965
@mosesonline , here's the release plan for v3.0.1. FYI
https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+3.0.1
--
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/KAFKA-13390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493082#comment-17493082
]
Luke Chen commented on KAFKA-13390:
---
[~mosesonline] , v3.1.0 was released containing t
[
https://issues.apache.org/jira/browse/KAFKA-13510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13510:
--
Fix Version/s: 3.2.0
> KIP-769: Connect APIs to list all connector plugins and retrieve their
[
https://issues.apache.org/jira/browse/KAFKA-13511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13511:
--
Fix Version/s: 3.2.0
> Add support for different unix precisions in TimestampConverter SMT
> -
[
https://issues.apache.org/jira/browse/KAFKA-13666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493110#comment-17493110
]
Bruno Cadonna commented on KAFKA-13666:
---
I see you point. Dropping support for Win
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r807738730
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,289
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r807738730
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,289
cadonna commented on a change in pull request #11752:
URL: https://github.com/apache/kafka/pull/11752#discussion_r807751843
##
File path:
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java
##
@@ -1094,29 +1095,37 @@ private void throwIfBuiltInSto
lkokhreidze commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r807810480
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java
##
@@ -0,0 +1,289
lkokhreidze commented on pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#issuecomment-1041380775
Hi @showuon, @cadonna
Thanks for the valuable feedback. I've addressed your comments and pushed
the changes. I also resolved conversations feel free to unresolve the
ruanwenjun commented on pull request #11763:
URL: https://github.com/apache/kafka/pull/11763#issuecomment-1041398013
@hachikuji Thanks for your review. I have removed the unused import. Now, it
should pass the `checkstyle` task.
By the way, how can I control the import order of kafka
mimaison commented on pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#issuecomment-1041402113
With this change, if a user explicitly sets `acks` to 0 or 1, we're throwing
an error. Currently in order to change `acks`, users also have to set
`enable.idempotence=false`.
mimaison merged pull request #11764:
URL: https://github.com/apache/kafka/pull/11764
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr
cadonna commented on a change in pull request #11760:
URL: https://github.com/apache/kafka/pull/11760#discussion_r807858181
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovement.java
##
@@ -102,17 +109,26 @@ static int assignA
mimaison commented on a change in pull request #11756:
URL: https://github.com/apache/kafka/pull/11756#discussion_r807883399
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java
##
@@ -137,11 +137,6 @@
private int gener
showuon commented on pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#issuecomment-1041473036
@mimaison , do you mean:
So, do you mean, we have some different cases:
1. if user **doesn't** set enable.idempotence explicitly: the idempotent
producer is **only enabled
showuon edited a comment on pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#issuecomment-1041473036
@mimaison , do you mean:
So, do you mean, we have some different cases:
1. if user **doesn't** set enable.idempotence explicitly: the idempotent
producer is **only
showuon edited a comment on pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#issuecomment-1041473036
@mimaison , do you mean:
So, do you mean, we have some different cases:
1. if user **doesn't** set enable.idempotence explicitly: the idempotent
producer is **only
C0urante commented on a change in pull request #11758:
URL: https://github.com/apache/kafka/pull/11758#discussion_r807517678
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java
##
@@ -150,9 +150,11 @@
public static final Strin
C0urante opened a new pull request #11770:
URL: https://github.com/apache/kafka/pull/11770
[Jira](https://issues.apache.org/jira/browse/KAFKA-13669)
Enough users have provided feedback about this message being
scary/spammy/misleading that we should take their thoughts into account an
mimaison commented on pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#issuecomment-1041540013
I too think it makes sense to apply the same logic to `retries` and
`max.in.flight.requests.per.connection`. When disabling idempotency due to a
conflicting config, we should
Abhijit created KAFKA-13671:
---
Summary: Power (ppc64le) support for kafka
Key: KAFKA-13671
URL: https://issues.apache.org/jira/browse/KAFKA-13671
Project: Kafka
Issue Type: Improvement
Com
[
https://issues.apache.org/jira/browse/KAFKA-13671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhijit updated KAFKA-13671:
Description:
Support for Power architecture (ppc64le) for apache kafka.
What is IBM Power architecture?
I
mjsax merged pull request #11759:
URL: https://github.com/apache/kafka/pull/11759
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...
jwiederholdconfluent commented on a change in pull request #11758:
URL: https://github.com/apache/kafka/pull/11758#discussion_r808247925
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java
##
@@ -150,9 +150,11 @@
public static
free2create commented on a change in pull request #11752:
URL: https://github.com/apache/kafka/pull/11752#discussion_r808258300
##
File path:
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java
##
@@ -1094,29 +1095,37 @@ private void throwIfBuiltI
Hangleton opened a new pull request #11771:
URL: https://github.com/apache/kafka/pull/11771
Removed unused import in RemoteIndexCacheTest. Verified with `./gradlew
build` and `./gradlew :core:compileTestScala`.
### Committer Checklist (excluded from commit message)
- [N/A] Verify
Hangleton closed pull request #11771:
URL: https://github.com/apache/kafka/pull/11771
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubsc
[
https://issues.apache.org/jira/browse/KAFKA-13666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493382#comment-17493382
]
Rob Leland commented on KAFKA-13666:
I am Just learning Kafka and other things Apach
tombentley commented on a change in pull request #11575:
URL: https://github.com/apache/kafka/pull/11575#discussion_r808304776
##
File path:
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java
##
@@ -65,14 +66,22 @@
public static f
hachikuji commented on pull request #11763:
URL: https://github.com/apache/kafka/pull/11763#issuecomment-1041960369
@ruanwenjun To be honest, I don't think we have official guidelines on
import ordering. The only style enforcement I'm aware of is avoiding `*`
imports in the Java code. If y
hachikuji merged pull request #11763:
URL: https://github.com/apache/kafka/pull/11763
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubsc
mimaison merged pull request #11756:
URL: https://github.com/apache/kafka/pull/11756
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr
Bruno Cadonna created KAFKA-13672:
-
Summary: Flaky test
kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize()
Key: KAFKA-13672
URL: https://issues.apache.org/jira/browse/KAFKA-13672
Pro
[
https://issues.apache.org/jira/browse/KAFKA-6823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493457#comment-17493457
]
Bruno Cadonna commented on KAFKA-6823:
--
I opened the following ticket for the new fa
cadonna commented on pull request #11751:
URL: https://github.com/apache/kafka/pull/11751#issuecomment-1042083707
Test failures are unrelated:
```
Build / JDK 17 and Scala 2.13 /
kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize()
Build / JDK 11 and Scala 2.13 /
k
cadonna merged pull request #11751:
URL: https://github.com/apache/kafka/pull/11751
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr.
twobeeb commented on a change in pull request #11575:
URL: https://github.com/apache/kafka/pull/11575#discussion_r808393677
##
File path:
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java
##
@@ -65,14 +66,22 @@
public static fina
tim-patterson commented on a change in pull request #11760:
URL: https://github.com/apache/kafka/pull/11760#discussion_r808418617
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovement.java
##
@@ -102,17 +109,26 @@ static int a
ableegoldman commented on a change in pull request #11705:
URL: https://github.com/apache/kafka/pull/11705#discussion_r808518197
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java
##
@@ -81,14 +81,19 @@ public StreamsBuilder() {
internalSt
[
https://issues.apache.org/jira/browse/KAFKA-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bangarraju Vadapalli reassigned KAFKA-7499:
---
Assignee: Bangarraju Vadapalli
> Extend ProductionExceptionHandler to cover
showuon commented on pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#issuecomment-1042484001
@ijuma @hachikuji @vvcephei @kirktrue , any thoughts about this suggestion?
This way, we don't need https://github.com/apache/kafka/pull/11767
https://github.com/apache/kafka/p
hachikuji merged pull request #11770:
URL: https://github.com/apache/kafka/pull/11770
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubsc
[
https://issues.apache.org/jira/browse/KAFKA-13669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-13669.
-
Fix Version/s: 3.2.0
Resolution: Fixed
> Log messages for source tasks with no of
C0urante commented on pull request #11770:
URL: https://github.com/apache/kafka/pull/11770#issuecomment-1042488844
Thanks Jason, appreciate it.
--
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
hachikuji commented on pull request #11767:
URL: https://github.com/apache/kafka/pull/11767#issuecomment-1042497943
> Yes, I don't know the getters serve any purpose, either. But I'm still
worried that there's someone relying on it.
I'd like to hear what @hachikuji 's thought since he d
hachikuji edited a comment on pull request #11767:
URL: https://github.com/apache/kafka/pull/11767#issuecomment-1042497943
> Yes, I don't know the getters serve any purpose, either. But I'm still
worried that there's someone relying on it.
I'd like to hear what @hachikuji 's thought sin
[
https://issues.apache.org/jira/browse/KAFKA-13668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493601#comment-17493601
]
Luke Chen commented on KAFKA-13668:
---
Nice suggestion! We should improve it!
> Failed
hachikuji commented on a change in pull request #11681:
URL: https://github.com/apache/kafka/pull/11681#discussion_r808619827
##
File path: core/src/test/scala/unit/kafka/admin/LeaderElectionCommandTest.scala
##
@@ -55,9 +54,18 @@ final class LeaderElectionCommandTest(cluster:
showuon commented on a change in pull request #11753:
URL: https://github.com/apache/kafka/pull/11753#discussion_r808620042
##
File path: checkstyle/suppressions.xml
##
@@ -1,9 +1,24 @@
-
+
Review comment:
Is this necessary to add this line?
--
This is an automated
showuon commented on a change in pull request #11681:
URL: https://github.com/apache/kafka/pull/11681#discussion_r808620691
##
File path: core/src/test/scala/unit/kafka/admin/LeaderElectionCommandTest.scala
##
@@ -55,9 +54,18 @@ final class LeaderElectionCommandTest(cluster:
C
hachikuji commented on a change in pull request #11681:
URL: https://github.com/apache/kafka/pull/11681#discussion_r808622838
##
File path: core/src/test/scala/unit/kafka/admin/LeaderElectionCommandTest.scala
##
@@ -55,9 +54,18 @@ final class LeaderElectionCommandTest(cluster:
hachikuji commented on a change in pull request #11681:
URL: https://github.com/apache/kafka/pull/11681#discussion_r808622838
##
File path: core/src/test/scala/unit/kafka/admin/LeaderElectionCommandTest.scala
##
@@ -55,9 +54,18 @@ final class LeaderElectionCommandTest(cluster:
showuon commented on a change in pull request #11681:
URL: https://github.com/apache/kafka/pull/11681#discussion_r808623633
##
File path: core/src/test/scala/unit/kafka/admin/LeaderElectionCommandTest.scala
##
@@ -55,9 +54,18 @@ final class LeaderElectionCommandTest(cluster:
C
hachikuji commented on pull request #11681:
URL: https://github.com/apache/kafka/pull/11681#issuecomment-1042520005
> it doesn't work to put the admin client creating after
cluster.waitForReadyBrokers(), because the waitForReadyBrokers only wait for
all brokers registered and unfenced (re
showuon commented on pull request #11681:
URL: https://github.com/apache/kafka/pull/11681#issuecomment-1042521794
@hachikuji , let me check it and let you know.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
showuon commented on pull request #11433:
URL: https://github.com/apache/kafka/pull/11433#issuecomment-1042525944
@vamossagar12 , thanks for the PR. I'll take a look in next week.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
C0urante opened a new pull request #11772:
URL: https://github.com/apache/kafka/pull/11772
Adds the new metrics described in
[KIP-618](https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Exactly-Once+Support+for+Source+Connectors#KIP618:ExactlyOnceSupportforSourceConnectors-Newmetr
C0urante opened a new pull request #11773:
URL: https://github.com/apache/kafka/pull/11773
Adds the new exactly-once-related source connector APIs described in
[KIP-618].
Note that these APIs are not used by the framework in this PR, just defined.
They will be used in downstream PRs
C0urante opened a new pull request #11774:
URL: https://github.com/apache/kafka/pull/11774
Adds some reusable utility methods for:
- Overriding (and logging a warning) user-supplied properties if they do not
contain an expected value
- Generating an array of the names (or, to be p
C0urante opened a new pull request #11775:
URL: https://github.com/apache/kafka/pull/11775
Adds the new connector- and worker-level properties described in
[KIP-618](https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Exactly-Once+Support+for+Source+Connectors#KIP618:ExactlyOnceSup
vvcephei commented on pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#issuecomment-1042545763
I have to admit that I find all these breakages that are cropping up to be a
bit disturbing. I like the idea to default to stronger guarantees, but if the
cost is that a lot o
showuon commented on pull request #10682:
URL: https://github.com/apache/kafka/pull/10682#issuecomment-1042548348
@eas5 , thanks for the patch! Since it's been a while, could you rebase to
trunk and check the jenkins test results again. Thanks.
--
This is an automated message from the Ap
C0urante opened a new pull request #11776:
URL: https://github.com/apache/kafka/pull/11776
Implements the preflight validation logic described in
[KIP-618](https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Exactly-Once+Support+for+Source+Connectors#KIP618:ExactlyOnceSupportforSou
C0urante opened a new pull request #11777:
URL: https://github.com/apache/kafka/pull/11777
Implements the new admin client API described in
[KIP-618](https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Exactly-Once+Support+for+Source+Connectors#KIP618:ExactlyOnceSupportforSourceCon
C0urante opened a new pull request #11778:
URL: https://github.com/apache/kafka/pull/11778
Implements the behavior described in
[KIP-618](https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Exactly-Once+Support+for+Source+Connectors#KIP618:ExactlyOnceSupportforSourceConnectors-Lead
C0urante opened a new pull request #11779:
URL: https://github.com/apache/kafka/pull/11779
Implements the zombie fencing logic described in
[KIP-618](https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Exactly-Once+Support+for+Source+Connectors#KIP618:ExactlyOnceSupportforSourceCon
C0urante opened a new pull request #11780:
URL: https://github.com/apache/kafka/pull/11780
Implements a source task wrapper (`ExactlyOnceWorkerSourceTask`) that
follows the behavior described in
[KIP-618](https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Exactly-Once+Support+for
C0urante opened a new pull request #11781:
URL: https://github.com/apache/kafka/pull/11781
Implements support for per-connector offsets topics as described in
[KIP-618](https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Exactly-Once+Support+for+Source+Connectors#KIP618:ExactlyOnce
C0urante commented on a change in pull request #11780:
URL: https://github.com/apache/kafka/pull/11780#discussion_r808667916
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStore.java
##
@@ -0,0 +1,72 @@
+/*
+ * Licensed to th
C0urante opened a new pull request #11782:
URL: https://github.com/apache/kafka/pull/11782
Implements embedded end-to-end integration tests for
[KIP-618](https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Exactly-Once+Support+for+Source+Connectors),
and brings together previously
C0urante opened a new pull request #11783:
URL: https://github.com/apache/kafka/pull/11783
Implements system tests for
[KIP-618](https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Exactly-Once+Support+for+Source+Connectors).
Relies on changes from:
- https://github.com/a
C0urante closed pull request #10907:
URL: https://github.com/apache/kafka/pull/10907
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr
C0urante commented on pull request #10907:
URL: https://github.com/apache/kafka/pull/10907#issuecomment-1042573696
@mimaison @rhauch I've broken things down into smaller PRs.
These can all be reviewed immediately:
- https://github.com/apache/kafka/pull/11777 (cc @hachikuji in case
ijuma commented on pull request #11769:
URL: https://github.com/apache/kafka/pull/11769#issuecomment-1042574221
I think you would want to disable idempotence instead. Retries were
intentionally disabled here.
--
This is an automated message from the Apache Git Service.
To respond to the
C0urante edited a comment on pull request #10907:
URL: https://github.com/apache/kafka/pull/10907#issuecomment-1042573696
@mimaison @rhauch I've broken things down into smaller PRs.
These can all be reviewed immediately:
- https://github.com/apache/kafka/pull/11777 (cc @hachikuji i
ruanwenjun commented on a change in pull request #11753:
URL: https://github.com/apache/kafka/pull/11753#discussion_r808702569
##
File path: checkstyle/suppressions.xml
##
@@ -1,9 +1,24 @@
-
+
Review comment:
Thanks for your review.
To be honestly, I am not sure if
showuon commented on a change in pull request #11705:
URL: https://github.com/apache/kafka/pull/11705#discussion_r808708709
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java
##
@@ -81,14 +81,19 @@ public StreamsBuilder() {
internalStreams
showuon commented on a change in pull request #11753:
URL: https://github.com/apache/kafka/pull/11753#discussion_r808713500
##
File path: checkstyle/suppressions.xml
##
@@ -1,9 +1,24 @@
-
+
Review comment:
OK, from the XML spec [1], it said:
_XML documents SHOULD
showuon commented on pull request #11753:
URL: https://github.com/apache/kafka/pull/11753#issuecomment-1042619446
failed tests are unrelated:
```
[Build / JDK 11 and Scala 2.13 /
kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize()](https://ci-builds.apache.org/job/Kaf
showuon merged pull request #11753:
URL: https://github.com/apache/kafka/pull/11753
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr.
Luke Chen created KAFKA-13673:
-
Summary: disable idempotent producer when
acks/retries/max.in.flight config conflicts
Key: KAFKA-13673
URL: https://issues.apache.org/jira/browse/KAFKA-13673
Project: Kafka
showuon commented on pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#issuecomment-1042640027
[KAFKA-13673](https://issues.apache.org/jira/browse/KAFKA-13673) is created
for this proposal.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/KAFKA-13673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-13673:
-
Assignee: Luke Chen
> disable idempotent producer when acks/retries/max.in.flight config confli
RivenSun2 commented on pull request #11768:
URL: https://github.com/apache/kafka/pull/11768#issuecomment-1042652006
@showuon
Yeah i agree with you
I just want to keep the code style in the AccessControlEntryFilter#matches
method consistent~
Like the following lines of code:
the
91 matches
Mail list logo
