[
https://issues.apache.org/jira/browse/KAFKA-13287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-13287:
--
Assignee: Bruno Cadonna
> Upgrade RocksDB to 6.22.1.1
>
[
https://issues.apache.org/jira/browse/KAFKA-13216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-13216:
---
Assignee: Guozhang Wang
> Streams left/outer joins cause new internal changelog
mjsax closed pull request #11235:
URL: https://github.com/apache/kafka/pull/11235
--
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:
mjsax commented on pull request #11235:
URL: https://github.com/apache/kafka/pull/11235#issuecomment-916630468
Closing the PR in favor of #11252.
The performance of this PR is really bad, while #11252 shows stable
performance.
--
This is an automated message from the Apache Git
mjsax commented on a change in pull request #11252:
URL: https://github.com/apache/kafka/pull/11252#discussion_r705883780
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java
##
@@ -280,85 +279,51 @@ private void
[
https://issues.apache.org/jira/browse/KAFKA-13256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412950#comment-17412950
]
Matthias J. Sax commented on KAFKA-13256:
-
Thanks. Just wondering if this PR fixes a non-problem
ijuma commented on pull request #11017:
URL: https://github.com/apache/kafka/pull/11017#issuecomment-916526936
@chia7712 Conflicts are resolved. :)
--
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
Jason Gustafson created KAFKA-13288:
---
Summary: Transaction find-hanging command with --broker-id
excludes internal topics
Key: KAFKA-13288
URL: https://issues.apache.org/jira/browse/KAFKA-13288
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r705721987
##
File path: core/src/main/scala/kafka/log/LogCleaner.scala
##
@@ -658,23 +676,28 @@ private[log] class Cleaner(val id: Int,
}
}
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r705721022
##
File path: core/src/main/scala/kafka/log/LogCleanerManager.scala
##
@@ -163,17 +168,18 @@ private[log] class LogCleanerManager(val logDirs:
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r705721022
##
File path: core/src/main/scala/kafka/log/LogCleanerManager.scala
##
@@ -163,17 +168,18 @@ private[log] class LogCleanerManager(val logDirs:
[
https://issues.apache.org/jira/browse/KAFKA-13164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hao Li reassigned KAFKA-13164:
--
Assignee: Hao Li
> State store is attached to wrong node in the Kafka Streams topology
>
cadonna opened a new pull request #11317:
URL: https://github.com/apache/kafka/pull/11317
### 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-13287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13287:
--
Fix Version/s: 3.1.0
> Upgrade RocksDB to 6.22.1.1
> ---
>
>
Bruno Cadonna created KAFKA-13287:
-
Summary: Upgrade RocksDB to 6.22.1.1
Key: KAFKA-13287
URL: https://issues.apache.org/jira/browse/KAFKA-13287
Project: Kafka
Issue Type: Task
[
https://issues.apache.org/jira/browse/KAFKA-13286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13286:
--
Description:
Kafka Streams state store is built in hierarchical layers as metered -> cached
Guozhang Wang created KAFKA-13286:
-
Summary: Revisit Streams State Store and Serde Implementation
Key: KAFKA-13286
URL: https://issues.apache.org/jira/browse/KAFKA-13286
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
F Méthot updated KAFKA-13272:
-
Description:
Our KStream app offset stay stuck on 1 partition after outage possibly when
exactly_once
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
F Méthot updated KAFKA-13272:
-
Description:
Our KStream app offset stay stuck on 1 partition after outage possibly when
exactly_once
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
F Méthot updated KAFKA-13272:
-
Description:
Our KStream app offset stay stuck on 1 partition after outage possibly when
exactly_once
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
F Méthot updated KAFKA-13272:
-
Description:
Our KStream app offset stay stuck on 1 partition after outage possibly when
exactly_once
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
F Méthot updated KAFKA-13272:
-
Description:
Our KStream app offset stay stuck on 1 partition after outage possibly when
exactly_once
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
F Méthot updated KAFKA-13272:
-
Description:
Our KStream app offset stay stuck on 1 partition after outage possibly when
exactly_once
[
https://issues.apache.org/jira/browse/KAFKA-8334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412714#comment-17412714
]
Jun Rao commented on KAFKA-8334:
[~geek-chen]: This is a server side issue. So you will need to upgrade
junrao commented on pull request #11058:
URL: https://github.com/apache/kafka/pull/11058#issuecomment-916281257
@satishd : Could you rebase this PR? Thanks.
--
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-12988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-12988.
-
Fix Version/s: 3.1.0
Resolution: Fixed
merged the PR to trunk.
> Change RLMM
junrao merged pull request #11033:
URL: https://github.com/apache/kafka/pull/11033
--
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:
jeqo opened a new pull request #11316:
URL: https://github.com/apache/kafka/pull/11316
As part of the migration of KStream/KTable operations to the new Processor
API https://issues.apache.org/jira/browse/KAFKA-8410, this PR includes the
migration of KTable aggregate/reduce operations.
[
https://issues.apache.org/jira/browse/KAFKA-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jorge Esteban Quilcate Otoya resolved KAFKA-10542.
--
Resolution: Fixed
https://github.com/apache/kafka/pull/11099
[
https://issues.apache.org/jira/browse/KAFKA-13201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jorge Esteban Quilcate Otoya resolved KAFKA-13201.
--
Resolution: Fixed
https://github.com/apache/kafka/pull/11213
[
https://issues.apache.org/jira/browse/KAFKA-13201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jorge Esteban Quilcate Otoya reassigned KAFKA-13201:
Assignee: Jorge Esteban Quilcate Otoya
> Convert KTable
[
https://issues.apache.org/jira/browse/KAFKA-13256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison reassigned KAFKA-13256:
--
Assignee: René Kerner
> Possible NPE in ConfigDef when rendering (enriched) RST or
[
https://issues.apache.org/jira/browse/KAFKA-13256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-13256:
---
Affects Version/s: 3.0.0
> Possible NPE in ConfigDef when rendering (enriched) RST or HTML
[
https://issues.apache.org/jira/browse/KAFKA-13256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-13256.
Fix Version/s: 3.1.0
Resolution: Fixed
> Possible NPE in ConfigDef when rendering
mimaison merged pull request #11287:
URL: https://github.com/apache/kafka/pull/11287
--
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:
jeqo opened a new pull request #11315:
URL: https://github.com/apache/kafka/pull/11315
As part of the migration of KStream/KTable operations to the new Processor
API https://issues.apache.org/jira/browse/KAFKA-8410, this PR includes the
migration of KStream aggregate/reduce operations.
[
https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412670#comment-17412670
]
Maatari edited comment on KAFKA-10643 at 9/9/21, 4:18 PM:
--
So just you know, we
[
https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412670#comment-17412670
]
Maatari commented on KAFKA-10643:
-
So just you know, we tried, and it has an effect, but only to
[
https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412623#comment-17412623
]
Maatari edited comment on KAFKA-10643 at 9/9/21, 2:49 PM:
--
[~gray.john] It
[
https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412623#comment-17412623
]
Maatari edited comment on KAFKA-10643 at 9/9/21, 2:48 PM:
--
[~gray.john] It
wcarlson5 commented on pull request #11278:
URL: https://github.com/apache/kafka/pull/11278#issuecomment-916170147
@guozhangwang I think there are defiantly questions to be answered about
this and really what we want to the user to achieve. I think the
maxbufferedbytes is really being
[
https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412623#comment-17412623
]
Maatari commented on KAFKA-10643:
-
[~gray.john] It feels like disabling it altogether might make sense
dajac merged pull request #11314:
URL: https://github.com/apache/kafka/pull/11314
--
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:
Tom Bentley created KAFKA-13285:
---
Summary: Use consistent access modifier for Admin clients Result
classes
Key: KAFKA-13285
URL: https://issues.apache.org/jira/browse/KAFKA-13285
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412602#comment-17412602
]
John Gray commented on KAFKA-10643:
---
[~maatdeamon] hey your understanding appears about as good as
mimaison commented on a change in pull request #10983:
URL: https://github.com/apache/kafka/pull/10983#discussion_r705288892
##
File path: docs/ops.html
##
@@ -845,6 +845,11 @@
patrickstuedi commented on a change in pull request #10798:
URL: https://github.com/apache/kafka/pull/10798#discussion_r705268638
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBRangeIterator.java
##
@@ -32,34 +34,49 @@
private final
rk3rn3r commented on a change in pull request #11287:
URL: https://github.com/apache/kafka/pull/11287#discussion_r705252513
##
File path: clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java
##
@@ -1372,11 +1372,13 @@ public String toEnrichedRst() {
*/
rk3rn3r commented on a change in pull request #11287:
URL: https://github.com/apache/kafka/pull/11287#discussion_r705251404
##
File path: clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java
##
@@ -1372,11 +1372,13 @@ public String toEnrichedRst() {
*/
[
https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412498#comment-17412498
]
Maatari commented on KAFKA-10643:
-
[~gray.john] I do have state store to restore, it is happening. We
mimaison commented on a change in pull request #11287:
URL: https://github.com/apache/kafka/pull/11287#discussion_r705140109
##
File path: clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java
##
@@ -1372,11 +1372,13 @@ public String toEnrichedRst() {
*/
tombentley commented on a change in pull request #11301:
URL: https://github.com/apache/kafka/pull/11301#discussion_r705112124
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -3178,7 +3178,8 @@ public DescribeConsumerGroupsResult
mimaison commented on pull request #10649:
URL: https://github.com/apache/kafka/pull/10649#issuecomment-915876743
@rajinisivaram Thanks for the reviews. I hope we have answered your
comments. Do you have any more questions?
--
This is an automated message from the Apache Git Service.
To
dajac commented on pull request #11314:
URL: https://github.com/apache/kafka/pull/11314#issuecomment-915807764
@omkreddy Could you have a quick look at this one please?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
dajac opened a new pull request #11314:
URL: https://github.com/apache/kafka/pull/11314
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including
55 matches
Mail list logo
