[
https://issues.apache.org/jira/browse/KAFKA-16063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801687#comment-17801687
]
Arpit Goyal commented on KAFKA-16063:
-
[~divijvaidya] [~showuon] PR for review.
iit2009060 opened a new pull request, #15104:
URL: https://github.com/apache/kafka/pull/15104
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of
clolov commented on code in PR #14929:
URL: https://github.com/apache/kafka/pull/14929#discussion_r1439203605
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java:
##
@@ -946,7 +966,6 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-16050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801087#comment-17801087
]
Xin edited comment on KAFKA-16050 at 1/2/24 6:45 AM:
-
Finally I found the reason
[
https://issues.apache.org/jira/browse/KAFKA-16063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801668#comment-17801668
]
Arpit Goyal commented on KAFKA-16063:
-
[~divijvaidya] It seems to be a well known leak over the
[
https://issues.apache.org/jira/browse/KAFKA-16073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801667#comment-17801667
]
hzh0425 commented on KAFKA-16073:
-
[~satish.duggana] Yes, it's exactly what you described. I actually
[
https://issues.apache.org/jira/browse/KAFKA-16073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801663#comment-17801663
]
Satish Duggana commented on KAFKA-16073:
Thanks [~hzh0425@apache] for filing JIRA with a
ijuma commented on code in PR #14034:
URL: https://github.com/apache/kafka/pull/14034#discussion_r1439152043
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -1441,9 +1442,9 @@ class UnifiedLog(@volatile var logStartOffset: Long,
* (if there is
ijuma commented on code in PR #14034:
URL: https://github.com/apache/kafka/pull/14034#discussion_r1439091103
##
core/src/test/scala/unit/kafka/log/LocalLogTest.scala:
##
@@ -362,8 +364,8 @@ class LocalLogTest {
}
assertEquals(5, log.segments.numberOfSegments)
OmniaGM opened a new pull request, #15103:
URL: https://github.com/apache/kafka/pull/15103
still - WIP
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation
mjsax commented on PR #15102:
URL: https://github.com/apache/kafka/pull/15102#issuecomment-1873512205
We still don't have an RC for 3.7, so it would be great to close this minor
gap to provide a better user experience. \cc @stanislavkozlovski for visibility
--
This is an automated
mjsax opened a new pull request, #15102:
URL: https://github.com/apache/kafka/pull/15102
We did no complete KIP-714 with regard to collecting producer clients
instance IDs in Kafka Streams if EOSv1 is enabled. Instead of throwing an
UnsupportedOperationException, we should return an empty
[
https://issues.apache.org/jira/browse/KAFKA-16055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16055:
Component/s: streams
> Thread unsafe use of HashMap stored in
wernerdv opened a new pull request, #15101:
URL: https://github.com/apache/kafka/pull/15101
Added LeakTestingExtension based on TestUtils#verifyNoUnexpectedThreads for
verify that there are no lingering threads left over. Extension execute after
every test.
### Committer Checklist
[
https://issues.apache.org/jira/browse/KAFKA-16072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dmitry Werner reassigned KAFKA-16072:
-
Assignee: Dmitry Werner
> Create Junit 5 extension to detect thread leak
>
[
https://issues.apache.org/jira/browse/KAFKA-16063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801577#comment-17801577
]
Divij Vaidya commented on KAFKA-16063:
--
Nice find and yes, disabling shutdown hook sounds like a
[
https://issues.apache.org/jira/browse/KAFKA-16063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801568#comment-17801568
]
Arpit Goyal commented on KAFKA-16063:
-
[~divijvaidya] I am able to reproduce the issue locally and
[
https://issues.apache.org/jira/browse/KAFKA-16063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arpit Goyal updated KAFKA-16063:
Attachment: Screenshot 2024-01-01 at 10.51.03 PM.png
> Fix leaked ApplicationShutdownHooks in
[
https://issues.apache.org/jira/browse/KAFKA-16063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arpit Goyal updated KAFKA-16063:
Attachment: Screenshot 2024-01-01 at 10.51.03 PM-1.png
> Fix leaked ApplicationShutdownHooks in
JimmyWang6 commented on PR #14327:
URL: https://github.com/apache/kafka/pull/14327#issuecomment-1873362395
@
> @JimmyWang6 , I think for this part
>
> > What if a new topic gets created which matches the regex subscription of
some member.
>
> we need to use the metadata
[
https://issues.apache.org/jira/browse/KAFKA-16073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hzh0425 updated KAFKA-16073:
Description:
The identified bug in Apache Kafka's tiered storage feature involves a delayed
update of
[
https://issues.apache.org/jira/browse/KAFKA-16073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hzh0425 updated KAFKA-16073:
Summary: Kafka Tiered Storage Bug: Consumer Fetch Error Due to Delayed
localLogStartOffset Update During
[
https://issues.apache.org/jira/browse/KAFKA-16073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hzh0425 updated KAFKA-16073:
Summary: Tiered Storage Bug: Kafka Tiered Storage Bug: Consumer Fetch Error
Due to Delayed
hzh0425 created KAFKA-16073:
---
Summary: Tiered Storage Bug: Incorrect Handling of Offset Ranges
During Segment Deletion
Key: KAFKA-16073
URL: https://issues.apache.org/jira/browse/KAFKA-16073
Project: Kafka
divijvaidya merged PR #14764:
URL: https://github.com/apache/kafka/pull/14764
--
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:
divijvaidya commented on PR #14764:
URL: https://github.com/apache/kafka/pull/14764#issuecomment-1873267580
Unrelated test failures, all tests modified in this PR are successful.
```
[Build / JDK 8 and Scala 2.12 /
26 matches
Mail list logo
