[
https://issues.apache.org/jira/browse/KAFKA-13239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406115#comment-17406115
]
A. Sophie Blee-Goldman commented on KAFKA-13239:
Thanks for looping back
dengziming commented on a change in pull request #11186:
URL: https://github.com/apache/kafka/pull/11186#discussion_r697800147
##
File path: core/src/main/scala/kafka/server/ControllerApis.scala
##
@@ -488,6 +488,31 @@ class ControllerApis(val requestChannel: RequestChannel,
[
https://issues.apache.org/jira/browse/KAFKA-13230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406102#comment-17406102
]
A. Sophie Blee-Goldman commented on KAFKA-13230:
Thanks for kicking this
[
https://issues.apache.org/jira/browse/KAFKA-13236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13236:
Fix Version/s: 2.7.2
2.6.3
> TopologyTestDriver crashes with EOS-beta c
mjsax commented on pull request #11279:
URL: https://github.com/apache/kafka/pull/11279#issuecomment-907558502
Merged to `2.7` and cherry-picked to `2.6` branch.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/KAFKA-13128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-13128.
Resolution: Fixed
> Flaky Test
> StoreQueryIntegrationTest.shouldQuerySto
[
https://issues.apache.org/jira/browse/KAFKA-13128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-13128:
---
Fix Version/s: 3.1.0
> Flaky Test
> StoreQueryIntegrationTest.shouldQuerySt
ableegoldman merged pull request #11275:
URL: https://github.com/apache/kafka/pull/11275
--
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-unsu
ableegoldman commented on pull request #11262:
URL: https://github.com/apache/kafka/pull/11262#issuecomment-907557633
Merged to trunk.
Thanks @alapidas ! Congrats on your first AK submission 😛
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/KAFKA-12963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-12963.
Fix Version/s: 3.1.0
Resolution: Fixed
> Improve error message for
ableegoldman merged pull request #11262:
URL: https://github.com/apache/kafka/pull/11262
--
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-unsu
showuon commented on a change in pull request #11211:
URL: https://github.com/apache/kafka/pull/11211#discussion_r697793805
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/PersistentWindowStore.java
##
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apach
Walker Carlson created KAFKA-13246:
--
Summary:
StoreQueryIntegrationTest#shouldQueryStoresAfterAddingAndRemovingStreamThread
does not gate on stream state well
Key: KAFKA-13246
URL: https://issues.apache.org/jira
ableegoldman commented on a change in pull request #11076:
URL: https://github.com/apache/kafka/pull/11076#discussion_r697793854
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -590,7 +590,14 @@ boolean runLoop() {
wcarlson5 commented on pull request #11275:
URL: https://github.com/apache/kafka/pull/11275#issuecomment-907555453
@ableegoldman lets get this merged. I will file a follow up ticket to make
sure that this test has proper gating on the streams state
--
This is an automated message from th
mjsax merged pull request #11279:
URL: https://github.com/apache/kafka/pull/11279
--
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...
ccding commented on pull request #11270:
URL: https://github.com/apache/kafka/pull/11270#issuecomment-907550506
failed test is unrelated
```
Build / JDK 16 and Scala 2.13 /
shouldQueryStoresAfterAddingAndRemovingStreamThread –
org.apache.kafka.streams.integration.StoreQueryIntegratio
[
https://issues.apache.org/jira/browse/KAFKA-12486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406084#comment-17406084
]
A. Sophie Blee-Goldman commented on KAFKA-12486:
{quote}Also, for my und
ableegoldman commented on pull request #11211:
URL: https://github.com/apache/kafka/pull/11211#issuecomment-907543609
Ping @cadonna since he's got a good eye for this part of the code. Also
@wcarlson5 @lct45 @showuon for help with reviews
--
This is an automated message from the Apache G
ableegoldman commented on a change in pull request #11275:
URL: https://github.com/apache/kafka/pull/11275#discussion_r697778586
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StoreQueryIntegrationTest.java
##
@@ -543,22 +516,27 @@ public void
should
tusharg1993 commented on pull request #11204:
URL: https://github.com/apache/kafka/pull/11204#issuecomment-907540893
@aloknnikhil Hey, Tushar here. I am the original author for the PR. Thanks
for forward porting the change apache/kafka trunk.
Some background. This change is essentia
[
https://issues.apache.org/jira/browse/KAFKA-13188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406075#comment-17406075
]
Tushar Goyal commented on KAFKA-13188:
--
[~aloknnikhil]Â I am the original author for
rodesai commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r697743994
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java
##
@@ -2262,6 +2352,14 @@ public void testListOffsetShouldUp
rodesai commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r697740825
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java
##
@@ -178,12 +184,48 @@ public void resetProducer(
guozhangwang commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r697736171
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java
##
@@ -269,6 +300,12 @@ public fina
rodesai commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r697727733
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java
##
@@ -269,6 +300,12 @@ public final voi
[
https://issues.apache.org/jira/browse/KAFKA-13243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13243:
--
Description:
Today most of the client latency metrics are measured in millis, and some in
nan
[
https://issues.apache.org/jira/browse/KAFKA-13243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13243:
--
Description:
Today most of the client latency metrics are measured in millis, and some in
nan
junrao commented on a change in pull request #11255:
URL: https://github.com/apache/kafka/pull/11255#discussion_r697714522
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -630,7 +630,7 @@ class KafkaController(val config: KafkaConfig,
// If
Ryan Dielhenn created KAFKA-13245:
-
Summary: KIP 771: Change behavior of how controller metrics are
exposed when using KRaft.
Key: KAFKA-13245
URL: https://issues.apache.org/jira/browse/KAFKA-13245
Pr
splett2 commented on a change in pull request #11255:
URL: https://github.com/apache/kafka/pull/11255#discussion_r697707732
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -630,7 +630,7 @@ class KafkaController(val config: KafkaConfig,
// I
[
https://issues.apache.org/jira/browse/KAFKA-13236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13236:
Description:
If EOS-beta is configured, we rely on the `-StreamThread-`Â name part to creat
[
https://issues.apache.org/jira/browse/KAFKA-13236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13236:
Description:
If EOS-beta is configured, we rely on the `-StreamThread`Â name part to create
[
https://issues.apache.org/jira/browse/KAFKA-13236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13236:
Description:
If EOS-beta is configured, we rely on the `-StreamThread`Â name part to create
[
https://issues.apache.org/jira/browse/KAFKA-13236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13236:
Description:
If EOS-beta is configured, we rely on the {{-StreamThread-}}Â name part to
cr
[
https://issues.apache.org/jira/browse/KAFKA-13236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13236:
Fix Version/s: 2.8.1
> TopologyTestDriver crashes with EOS-beta config
> -
mjsax commented on pull request #11271:
URL: https://github.com/apache/kafka/pull/11271#issuecomment-907429311
Merged to `2.8`. Could not cherry-pick to `2.7` because of code refactoring
between both branches. Follow up PR for 2.7:
https://github.com/apache/kafka/pull/11279
--
This is a
mjsax opened a new pull request #11279:
URL: https://github.com/apache/kafka/pull/11279
Port of #11271 for 2.7 branch.
--
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 u
hachikuji removed a comment on pull request #11267:
URL: https://github.com/apache/kafka/pull/11267#issuecomment-907422734
@ijuma Thanks. I will post test results once the run completes.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
hachikuji commented on pull request #11267:
URL: https://github.com/apache/kafka/pull/11267#issuecomment-907422703
--
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 unsubs
mjsax merged pull request #11271:
URL: https://github.com/apache/kafka/pull/11271
--
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...
wcarlson5 commented on pull request #11278:
URL: https://github.com/apache/kafka/pull/11278#issuecomment-907410140
@ableegoldman here is my idea for `cache.max.bytes.buffering` for named
topologies. I will need to make a few changes once
https://github.com/apache/kafka/pull/11272 gets in b
wcarlson5 opened a new pull request #11278:
URL: https://github.com/apache/kafka/pull/11278
make max buffer cache settable for a name topology
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build s
mumrah commented on pull request #11266:
URL: https://github.com/apache/kafka/pull/11266#issuecomment-907396380
Cherry-picked to:
* 2.8 as 16ef2ae9e474
* 2.7 as 39a52ee91d7a
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
junrao merged pull request #0:
URL: https://github.com/apache/kafka/pull/0
--
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..
hachikuji commented on a change in pull request #11267:
URL: https://github.com/apache/kafka/pull/11267#discussion_r697627332
##
File path: tests/kafkatest/tests/core/transactions_test.py
##
@@ -108,6 +108,10 @@ def bounce_brokers(self, clean_shutdown):
tim
hachikuji merged pull request #11268:
URL: https://github.com/apache/kafka/pull/11268
--
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
guozhangwang commented on pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#issuecomment-907375597
The compilation current failed and @cadonna suggested where we should fix
it. We should see one green build before we can merge.
--
This is an automated message from the
guozhangwang commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r697605349
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/KafkaProducerMetrics.java
##
@@ -0,0 +1,106 @@
+/*
+ * Licensed to t
mjaschob-twilio opened a new pull request #11277:
URL: https://github.com/apache/kafka/pull/11277
When new topics are created through the admin interface, the Kafka
controller creates the partition assignments for these topics according to the
algorithm defined in `AdminUtils.assignReplica
cadonna commented on a change in pull request #11250:
URL: https://github.com/apache/kafka/pull/11250#discussion_r697611748
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java
##
@@ -37,7
[
https://issues.apache.org/jira/browse/KAFKA-13243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13243:
--
Description:
Today most of the client latency metrics are measured in millis, and some in
nan
Michael Jaschob created KAFKA-13244:
---
Summary: Control Which Brokers Host Partitions of Newly Created
Topics
Key: KAFKA-13244
URL: https://issues.apache.org/jira/browse/KAFKA-13244
Project: Kafka
cadonna commented on a change in pull request #11250:
URL: https://github.com/apache/kafka/pull/11250#discussion_r697609982
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java
##
@@ -249,7
Guozhang Wang created KAFKA-13243:
-
Summary: Differentiate metric latency measured in millis and nanos
Key: KAFKA-13243
URL: https://issues.apache.org/jira/browse/KAFKA-13243
Project: Kafka
I
[
https://issues.apache.org/jira/browse/KAFKA-13079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-13079.
-
Fix Version/s: 3.1.0
Reviewer: David Jacot
Resolution: Fixed
> Forgotten Topics
dajac merged pull request #11104:
URL: https://github.com/apache/kafka/pull/11104
--
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...
satishd commented on pull request #11060:
URL: https://github.com/apache/kafka/pull/11060#issuecomment-907318976
Thanks @junrao for the comments. Addressed them with the latest commit.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
dajac commented on pull request #11104:
URL: https://github.com/apache/kafka/pull/11104#issuecomment-907313567
The build for `JDK 11 and Scala 2.13` hangs on
`kafka.server.ServerShutdownTest.testCleanShutdownWithZkUnavailable`. It seems
that the test is stuck. All the other tests have pass
jsancio commented on a change in pull request #11186:
URL: https://github.com/apache/kafka/pull/11186#discussion_r697549554
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -804,7 +817,7 @@ void handleBrokerUnfenced(int brok
viktorsomogyi opened a new pull request #11276:
URL: https://github.com/apache/kafka/pull/11276
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade
hachikuji commented on pull request #11267:
URL: https://github.com/apache/kafka/pull/11267#issuecomment-907301359
I ran the transaction tests again with `--repeat 5`. There were no failures:
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2021-08-26--00
dengziming commented on a change in pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#discussion_r697535233
##
File path: core/src/main/scala/kafka/admin/TopicCommand.scala
##
@@ -568,6 +619,10 @@ object TopicCommand extends Logging {
throw new Illegal
dengziming commented on a change in pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#discussion_r697531725
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsResult.java
##
@@ -32,28 +34,86 @@
*/
@InterfaceStability.Evolving
wcarlson5 commented on a change in pull request #11272:
URL: https://github.com/apache/kafka/pull/11272#discussion_r697495900
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
##
@@ -67,7 +68,7 @@
stateDirectory,
mumrah merged pull request #11266:
URL: https://github.com/apache/kafka/pull/11266
--
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..
wcarlson5 commented on pull request #11275:
URL: https://github.com/apache/kafka/pull/11275#issuecomment-907270874
@lct45 @ableegoldman Can I get a quick look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
wcarlson5 opened a new pull request #11275:
URL: https://github.com/apache/kafka/pull/11275
add a new case for the flaky tests to take care of threads starting up
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test cov
[
https://issues.apache.org/jira/browse/KAFKA-13128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-13128:
--
Assignee: Walker Carlson
> Flaky Test
> StoreQueryIntegrationTest.shouldQueryStoresA
dengziming opened a new pull request #11274:
URL: https://github.com/apache/kafka/pull/11274
*More detailed description of your change*
Handle UpdateFeatureRequest in KRaft mode
*Summary of testing strategy (including rationale)*
TODO
--
This is an automated message from
[
https://issues.apache.org/jira/browse/KAFKA-13242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengziming updated KAFKA-13242:
---
Fix Version/s: 3.0.1
> KRaft Controller doesn't handle UpdateFeaturesRequest
> -
dengziming created KAFKA-13242:
--
Summary: KRaft Controller doesn't handle UpdateFeaturesRequest
Key: KAFKA-13242
URL: https://issues.apache.org/jira/browse/KAFKA-13242
Project: Kafka
Issue Type:
cadonna commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r697393359
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java
##
@@ -2262,6 +2352,14 @@ public void testListOffsetShouldUp
rajinisivaram commented on a change in pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#discussion_r697217671
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsResult.java
##
@@ -32,28 +34,86 @@
*/
@InterfaceStability.Evolvin
[
https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405744#comment-17405744
]
Justin Jack commented on KAFKA-7641:
DO you know [selling on
Amazon|https://www.thec
AndrewDi created KAFKA-13241:
Summary: Name resolution should be disabled during SASL
authentication
Key: KAFKA-13241
URL: https://issues.apache.org/jira/browse/KAFKA-13241
Project: Kafka
Issue
Viktor Somogyi-Vass created KAFKA-13240:
---
Summary: HTTP TRACE should be disabled in Connect
Key: KAFKA-13240
URL: https://issues.apache.org/jira/browse/KAFKA-13240
Project: Kafka
Issue
dajac merged pull request #11265:
URL: https://github.com/apache/kafka/pull/11265
--
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...
[
https://issues.apache.org/jira/browse/KAFKA-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405687#comment-17405687
]
Carsten Lohmann commented on KAFKA-12256:
-
I would vote for raising the priority
TomerWizman commented on a change in pull request #11250:
URL: https://github.com/apache/kafka/pull/11250#discussion_r697228345
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java
##
@@ -2
TomerWizman commented on a change in pull request #11250:
URL: https://github.com/apache/kafka/pull/11250#discussion_r697227894
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java
##
@@ -178,15 +178,15 @@ void openDB(final Map configs
TomerWizman commented on a change in pull request #11250:
URL: https://github.com/apache/kafka/pull/11250#discussion_r697227114
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java
##
@@ -6
dajac opened a new pull request #11273:
URL: https://github.com/apache/kafka/pull/11273
This PR adds the `ActiveBrokerCount` and the `FencedBrokerCount` metrics to
the ZK controller. Note that `FencedBrokerCount` is always set to zero in the
ZK controller.
`testControllerMetrics` ha
83 matches
Mail list logo
