[
https://issues.apache.org/jira/browse/KAFKA-10090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127648#comment-17127648
]
Chia-Ping Tsai commented on KAFKA-10090:
[~rwruck] Let me take over this :)
> M
[
https://issues.apache.org/jira/browse/KAFKA-10090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-10090:
--
Assignee: Chia-Ping Tsai
> Misleading warnings: The configuration was supplied but is
chia7712 opened a new pull request #8826:
URL: https://github.com/apache/kafka/pull/8826
https://issues.apache.org/jira/browse/KAFKA-10090
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build statu
[
https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127673#comment-17127673
]
Joel Wee commented on KAFKA-6435:
-
Hi [~bchen225242] and [~mjsax], is this issue still wo
rhauch commented on pull request #8270:
URL: https://github.com/apache/kafka/pull/8270#issuecomment-640234740
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
rhauch commented on pull request #8270:
URL: https://github.com/apache/kafka/pull/8270#issuecomment-640234683
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127684#comment-17127684
]
Boyang Chen commented on KAFKA-6435:
[~JoelWee] Thanks for your interest! Feel free t
Itamar Benjamin created KAFKA-10114:
---
Summary: Kafka producer stuck after broker crash
Key: KAFKA-10114
URL: https://issues.apache.org/jira/browse/KAFKA-10114
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-10114:
Priority: Critical (was: Major)
> Kafka producer stuck after broker crash
> -
[
https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127715#comment-17127715
]
Guozhang Wang commented on KAFKA-6435:
--
What about just adding a `--internal-topics`
guozhangwang commented on pull request #8815:
URL: https://github.com/apache/kafka/pull/8815#issuecomment-640248563
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
[
https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127720#comment-17127720
]
Guozhang Wang commented on KAFKA-10091:
---
Thanks John. I think you're concerning ab
hachikuji commented on a change in pull request #8822:
URL: https://github.com/apache/kafka/pull/8822#discussion_r436386913
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
##
@@ -852,14 +835,28 @@ public void onFailure(RuntimeExcept
hachikuji commented on a change in pull request #8822:
URL: https://github.com/apache/kafka/pull/8822#discussion_r436387154
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
##
@@ -480,6 +480,17 @@ public synchronized boolea
hachikuji commented on a change in pull request #8822:
URL: https://github.com/apache/kafka/pull/8822#discussion_r436387869
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
##
@@ -1050,4 +1062,43 @@ public String toString()
[
https://issues.apache.org/jira/browse/KAFKA-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127730#comment-17127730
]
Jason Gustafson commented on KAFKA-10114:
-
[~ibinyami] Thanks for the report. Ca
hachikuji commented on a change in pull request #8802:
URL: https://github.com/apache/kafka/pull/8802#discussion_r436389230
##
File path: clients/src/main/resources/common/message/FetchRequest.json
##
@@ -49,7 +49,7 @@
"fields": [
{ "name": "ReplicaId", "type": "int32",
[
https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127733#comment-17127733
]
John Roesler commented on KAFKA-10091:
--
Thanks Guozhang. That would certainly be ea
hachikuji commented on a change in pull request #8822:
URL: https://github.com/apache/kafka/pull/8822#discussion_r436390686
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
##
@@ -1325,23 +1323,15 @@ private CompletedFetch
initializ
hachikuji commented on a change in pull request #8822:
URL: https://github.com/apache/kafka/pull/8822#discussion_r436391255
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java
##
@@ -3856,12 +3857,16 @@ private void
testOffsetValid
kkonstantine commented on pull request #8805:
URL: https://github.com/apache/kafka/pull/8805#issuecomment-640268366
Latest build:
jdk8 and jdk11 green
jdk14 one unrelated failure at:
`kafka.api.PlaintextAdminIntegrationTest.testAlterReplicaLogDirs`
--
kkonstantine merged pull request #8270:
URL: https://github.com/apache/kafka/pull/8270
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
[
https://issues.apache.org/jira/browse/KAFKA-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127741#comment-17127741
]
Paul Whalen commented on KAFKA-8177:
Sorry, I missed this comment. That sounds like
[
https://issues.apache.org/jira/browse/KAFKA-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Whalen resolved KAFKA-8177.
Resolution: Resolved
> Allow for separate connect instances to have sink connectors with the same
kkonstantine opened a new pull request #8827:
URL: https://github.com/apache/kafka/pull/8827
tbd
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including
[
https://issues.apache.org/jira/browse/KAFKA-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-9216:
--
Fix Version/s: 2.5.1
2.4.2
2.6.0
[
https://issues.apache.org/jira/browse/KAFKA-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-9216.
---
Resolution: Fixed
> Enforce connect internal topic configuration at startup
>
[
https://issues.apache.org/jira/browse/KAFKA-7833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-7833:
--
Assignee: Rob Meng
> StreamsBuilder should throw an exception if addGlobalStore and ad
[
https://issues.apache.org/jira/browse/KAFKA-7833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127754#comment-17127754
]
Matthias J. Sax commented on KAFKA-7833:
Thanks for the PR. Will take a look.
Al
hachikuji commented on a change in pull request #8795:
URL: https://github.com/apache/kafka/pull/8795#discussion_r436401217
##
File path: core/src/test/scala/unit/kafka/log/LogCleanerManagerTest.scala
##
@@ -571,12 +571,12 @@ class LogCleanerManagerTest extends Logging {
c
cmccabe commented on a change in pull request #8640:
URL: https://github.com/apache/kafka/pull/8640#discussion_r436401514
##
File path:
clients/src/test/java/org/apache/kafka/common/message/MessageTest.java
##
@@ -962,4 +962,23 @@ private void verifyWriteSucceeds(short version
cmccabe commented on a change in pull request #8640:
URL: https://github.com/apache/kafka/pull/8640#discussion_r436401747
##
File path:
generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java
##
@@ -2033,15 +2033,21 @@ private void generateClassEquals(String
[
https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Wee reassigned KAFKA-6435:
---
Assignee: Joel Wee
> Application Reset Tool might delete incorrect internal topics
> ---
ijuma commented on a change in pull request #8640:
URL: https://github.com/apache/kafka/pull/8640#discussion_r436401914
##
File path:
clients/src/test/java/org/apache/kafka/common/message/MessageTest.java
##
@@ -962,4 +962,23 @@ private void verifyWriteSucceeds(short version,
ijuma commented on a change in pull request #8640:
URL: https://github.com/apache/kafka/pull/8640#discussion_r436401965
##
File path:
generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java
##
@@ -2033,15 +2033,21 @@ private void generateClassEquals(String c
mjsax commented on pull request #8825:
URL: https://github.com/apache/kafka/pull/8825#issuecomment-640280224
Thanks for the PR. I looked into the code and the check to verify if names
are overlapping is actually in `InternalTopologyBuilder` -- thus, the fix
should there.
In `Interna
hachikuji commented on a change in pull request #8783:
URL: https://github.com/apache/kafka/pull/8783#discussion_r436402304
##
File path: core/src/main/scala/kafka/log/LogCleaner.scala
##
@@ -112,9 +112,19 @@ class LogCleaner(initialConfig: CleanerConfig,
private[log] val
hachikuji closed pull request #8770:
URL: https://github.com/apache/kafka/pull/8770
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
hachikuji commented on pull request #8770:
URL: https://github.com/apache/kafka/pull/8770#issuecomment-640280937
I'm going to go ahead and close this. If we have missed something, please
reopen and let us know.
This is an au
hachikuji commented on a change in pull request #8741:
URL: https://github.com/apache/kafka/pull/8741#discussion_r436402832
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -519,7 +519,7 @@ public void onFailure(Run
[
https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127766#comment-17127766
]
Matthias J. Sax commented on KAFKA-10091:
-
I agree with John, blocking "forever"
hachikuji closed pull request #8741:
URL: https://github.com/apache/kafka/pull/8741
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
hachikuji commented on pull request #8741:
URL: https://github.com/apache/kafka/pull/8741#issuecomment-640281800
Thanks for the patch. I'm going to close this since the code was changed
separately. I don't think there's a strong reason to port the change back to
2.0, but let us know if the
hachikuji commented on a change in pull request #8685:
URL: https://github.com/apache/kafka/pull/8685#discussion_r436403355
##
File path: clients/src/main/java/org/apache/kafka/common/network/Selector.java
##
@@ -363,23 +363,14 @@ public void wakeup() {
@Override
publ
[
https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127772#comment-17127772
]
Matthias J. Sax commented on KAFKA-6435:
I don't have a strong preference. Disall
[
https://issues.apache.org/jira/browse/KAFKA-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127773#comment-17127773
]
Itamar Benjamin commented on KAFKA-10114:
-
Hi [~hachikuji], Thanks for looking i
hachikuji commented on a change in pull request #8664:
URL: https://github.com/apache/kafka/pull/8664#discussion_r436403864
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/SenderMetricsRegistry.java
##
@@ -84,7 +84,7 @@ public SenderMetricsRegis
[
https://issues.apache.org/jira/browse/KAFKA-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch reopened KAFKA-9216:
--
The previous PR only checked the number of partitions, so I'm going to reopen
this to add another
hachikuji commented on a change in pull request #8660:
URL: https://github.com/apache/kafka/pull/8660#discussion_r436405018
##
File path: build.gradle
##
@@ -1065,6 +1065,7 @@ project(':clients') {
include "**/org/apache/kafka/common/security/auth/*"
include "**/org/a
hachikuji commented on a change in pull request #8660:
URL: https://github.com/apache/kafka/pull/8660#discussion_r436405018
##
File path: build.gradle
##
@@ -1065,6 +1065,7 @@ project(':clients') {
include "**/org/apache/kafka/common/security/auth/*"
include "**/org/a
hachikuji commented on a change in pull request #8552:
URL: https://github.com/apache/kafka/pull/8552#discussion_r436405820
##
File path: core/src/main/scala/kafka/controller/ReplicaStateMachine.scala
##
@@ -423,9 +414,10 @@ class ZkReplicaStateMachine(config: KafkaConfig,
rhauch opened a new pull request #8828:
URL: https://github.com/apache/kafka/pull/8828
Supplements #8270
This change adds a check to the KafkaConfigBackingStore,
KafkaOffsetBackingStore, and KafkaStatusBackingStore to use the admin client to
verify that the internal topics are comp
hachikuji commented on a change in pull request #8579:
URL: https://github.com/apache/kafka/pull/8579#discussion_r436406760
##
File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala
##
@@ -382,6 +382,11 @@ abstract class AbstractFetcherThread(name: String,
hachikuji commented on a change in pull request #8579:
URL: https://github.com/apache/kafka/pull/8579#discussion_r436406760
##
File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala
##
@@ -382,6 +382,11 @@ abstract class AbstractFetcherThread(name: String,
[
https://issues.apache.org/jira/browse/KAFKA-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127789#comment-17127789
]
Randall Hauch commented on KAFKA-9216:
--
[~kkonstantine], thanks for reviewing and me
rhauch commented on pull request #8069:
URL: https://github.com/apache/kafka/pull/8069#issuecomment-640287934
Green builds, except for JDK 11 which failed to run due to unrelated build
issues.
This is an automated message fr
hachikuji commented on pull request #8404:
URL: https://github.com/apache/kafka/pull/8404#issuecomment-640288084
Thanks, I think this makes sense. I also get a bit annoyed with the constant
import shuffling. I'd like to hear some feedback from others though before we
consider merging this.
hachikuji commented on a change in pull request #8579:
URL: https://github.com/apache/kafka/pull/8579#discussion_r436406760
##
File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala
##
@@ -382,6 +382,11 @@ abstract class AbstractFetcherThread(name: String,
hachikuji commented on pull request #59:
URL: https://github.com/apache/kafka/pull/59#issuecomment-640289214
Closing this since it is addressed by MM2. Please reopen if you believe it
is still valuable.
This is an automated
hachikuji closed pull request #59:
URL: https://github.com/apache/kafka/pull/59
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
hachikuji closed pull request #69:
URL: https://github.com/apache/kafka/pull/69
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
hachikuji commented on pull request #69:
URL: https://github.com/apache/kafka/pull/69#issuecomment-640289625
Adding new partitioning logic will require a KIP. The process is documented
here:
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals.
I am going to close
Aakash Shah created KAFKA-10115:
---
Summary: Incorporate errors.tolerance with the Errant Record
Reporter
Key: KAFKA-10115
URL: https://issues.apache.org/jira/browse/KAFKA-10115
Project: Kafka
I
hachikuji commented on pull request #254:
URL: https://github.com/apache/kafka/pull/254#issuecomment-640290639
Thanks for the patch. I'm going to close this for now since it requires a
KIP, but please consider reopening if you (or anyone else) has time to submit a
proposal. (The change doe
hachikuji closed pull request #254:
URL: https://github.com/apache/kafka/pull/254
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-2341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-2341:
---
Labels: needs-kip (was: )
> Need Standard Deviation Metrics in MetricsBench
> --
hachikuji commented on pull request #80:
URL: https://github.com/apache/kafka/pull/80#issuecomment-640290926
I'm going to close this due to inactivity. Note that this change will
require a KIP since it affects the public metrics API:
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+
hachikuji closed pull request #80:
URL: https://github.com/apache/kafka/pull/80
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
Ismael Juma created KAFKA-10116:
---
Summary: GraalVM native-image prototype
Key: KAFKA-10116
URL: https://issues.apache.org/jira/browse/KAFKA-10116
Project: Kafka
Issue Type: Improvement
aakashnshah opened a new pull request #8829:
URL: https://github.com/apache/kafka/pull/8829
Currently, the errant record reporter doesn't take into account the value of
`errors.tolerance.` Added a check if the reporter is within the tolerance
limits; if not, then a `ConnectException` is th
[
https://issues.apache.org/jira/browse/KAFKA-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127789#comment-17127789
]
Randall Hauch edited comment on KAFKA-9216 at 6/7/20, 10:58 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-9468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-9468:
-
Fix Version/s: 2.5.1
2.4.2
2.6.0
2.3.2
>
[
https://issues.apache.org/jira/browse/KAFKA-9468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127796#comment-17127796
]
Randall Hauch commented on KAFKA-9468:
--
This issue should be fixed by KAFKA-9216, si
[
https://issues.apache.org/jira/browse/KAFKA-9468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-9468.
--
Assignee: Randall Hauch
Resolution: Fixed
> config.storage.topic partition count issue is
robin5540 commented on pull request #8825:
URL: https://github.com/apache/kafka/pull/8825#issuecomment-640293871
@mjsax Makes sense. I'll push out the change tonight 👍
This is an automated message from the Apache Git Service
rhauch commented on a change in pull request #8829:
URL: https://github.com/apache/kafka/pull/8829#discussion_r436411235
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java
##
@@ -87,6 +87,12 @@ public RetryWithTo
ijuma opened a new pull request #8830:
URL: https://github.com/apache/kafka/pull/8830
I can generate a native image with the added task, but it exists soon
after start-up.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Ver
rhauch commented on a change in pull request #8829:
URL: https://github.com/apache/kafka/pull/8829#discussion_r436411235
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java
##
@@ -87,6 +87,12 @@ public RetryWithTo
rhauch commented on a change in pull request #8829:
URL: https://github.com/apache/kafka/pull/8829#discussion_r436411235
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java
##
@@ -87,6 +87,12 @@ public RetryWithTo
rhauch commented on a change in pull request #8829:
URL: https://github.com/apache/kafka/pull/8829#discussion_r436411235
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java
##
@@ -87,6 +87,12 @@ public RetryWithTo
ijuma commented on pull request #8404:
URL: https://github.com/apache/kafka/pull/8404#issuecomment-640295614
I think this would be good. A couple of things:
1. This will generate a massive diff.
2. It would be good to have ways to format correctly automatically. It will
be really
ijuma commented on pull request #8684:
URL: https://github.com/apache/kafka/pull/8684#issuecomment-640295811
@hachikuji feel free to merge, my main concern was the `intern` calls that
have been removed. We should update the commit message to remove the bit about
interning before merging.
Rhett.Wang created KAFKA-10117:
--
Summary: TimingWheel addOverflowWheel
Key: KAFKA-10117
URL: https://issues.apache.org/jira/browse/KAFKA-10117
Project: Kafka
Issue Type: Wish
Componen
[
https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127807#comment-17127807
]
Sumant commented on KAFKA-10062:
Hi [~wbottrell], I am also a newbie to this project and
[
https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127811#comment-17127811
]
William Bottrell commented on KAFKA-10062:
--
[~sumantrana] yeah, I plan on worki
kkonstantine commented on a change in pull request #8828:
URL: https://github.com/apache/kafka/pull/8828#discussion_r436421647
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java
##
@@ -375,6 +383,152 @@ public boolean createTopic(NewTopic
hachikuji merged pull request #8684:
URL: https://github.com/apache/kafka/pull/8684
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
[
https://issues.apache.org/jira/browse/KAFKA-10012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-10012.
-
Fix Version/s: 2.6.0
Resolution: Fixed
> Reducing memory overhead associated with
sh-abhi commented on pull request #6229:
URL: https://github.com/apache/kafka/pull/6229#issuecomment-640318293
@bbejeck I'm having some difficulty doing a rebase successfully after trying
some different approaches based on some references I found online. Any
suggestions, or should I just o
jiameixie opened a new pull request #8831:
URL: https://github.com/apache/kafka/pull/8831
Add support to configure allow.auto.create.topics.enable on producer client.
This patch is based on https://github.com/apache/kafka/pull/7075, with rebase
to current HEAD and add new test cases
prehistoric-penguin commented on pull request #6403:
URL: https://github.com/apache/kafka/pull/6403#issuecomment-640324519
> Not sure if this PR was ever merged. If yes, which release I need to
download to get the fix?
> If not, please reconsider. We really need to support Windows for so
chia7712 commented on a change in pull request #8660:
URL: https://github.com/apache/kafka/pull/8660#discussion_r436429969
##
File path: build.gradle
##
@@ -1065,6 +1065,7 @@ project(':clients') {
include "**/org/apache/kafka/common/security/auth/*"
include "**/org/ap
chia7712 commented on pull request #8660:
URL: https://github.com/apache/kafka/pull/8660#issuecomment-640324949
> One other question I had is whether we should consider making doc failures
also fail the build?
+1000
It seems to me the fixes to doc errors is too verbose as doc
[
https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-10062:
---
Assignee: William Bottrell
> Add a method to retrieve the current timestamp as know
[
https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127836#comment-17127836
]
Matthias J. Sax commented on KAFKA-10062:
-
[~wbottrell] I added you to the list
Luke Chen created KAFKA-10118:
-
Summary: Improve stickiness verification for
AbstractStickyAssignorTest
Key: KAFKA-10118
URL: https://issues.apache.org/jira/browse/KAFKA-10118
Project: Kafka
Iss
[
https://issues.apache.org/jira/browse/KAFKA-10118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-10118:
--
Description:
In KAFKA-9987 , we implemented an optimized sticky partition assignor algorithm
(i.e. {{
[
https://issues.apache.org/jira/browse/KAFKA-10118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-10118:
--
Description:
In KAFKA-9987 , we implemented an optimized sticky partition assignor algorithm
(i.e. {{
aakashnshah commented on a change in pull request #8829:
URL: https://github.com/apache/kafka/pull/8829#discussion_r436437989
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java
##
@@ -87,6 +87,12 @@ public RetryW
showuon commented on pull request #8788:
URL: https://github.com/apache/kafka/pull/8788#issuecomment-640337271
Thanks for the comment, @ableegoldman . Yes, I agree we should improve the
stickiness verification, but I haven't got a better idea for that so far. I've
created a ticket to track
1 - 100 of 117 matches
Mail list logo
