RivenSun2 opened a new pull request, #12000:
URL: https://github.com/apache/kafka/pull/12000
Use the LEAVE_GROUP_ON_CLOSE_CONFIG configuration uniformly to avoid
multiple codes using the `internal.leave.group.on.close` string alone
--
This is an automated message from the Apache Git Servi
[
https://issues.apache.org/jira/browse/KAFKA-12774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517866#comment-17517866
]
Jørgen commented on KAFKA-12774:
[~cadonna] : Sounds good to me. We still have the issue
[
https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516472#comment-17516472
]
RivenSun edited comment on KAFKA-13793 at 4/6/22 6:26 AM:
--
I co
[
https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516472#comment-17516472
]
RivenSun edited comment on KAFKA-13793 at 4/6/22 6:26 AM:
--
I co
[
https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516472#comment-17516472
]
RivenSun edited comment on KAFKA-13793 at 4/6/22 6:26 AM:
--
I co
dongjoon-hyun commented on PR #11995:
URL: https://github.com/apache/kafka/pull/11995#issuecomment-1089831593
Thank you so much all!
--
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 c
sciclon2 commented on PR #11842:
URL: https://github.com/apache/kafka/pull/11842#issuecomment-1089818537
@junrao I committed the changes and ran the test, all good, thanks!
 referencing a c
mjsax closed pull request #10391: MINOR: disable flaky system test
URL: https://github.com/apache/kafka/pull/10391
--
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 unsubscrib
[
https://issues.apache.org/jira/browse/KAFKA-13130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13130:
--
Fix Version/s: (was: 3.2.0)
> Deprecate long based range queries in SessionStore
> ---
[
https://issues.apache.org/jira/browse/KAFKA-13130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517724#comment-17517724
]
Bruno Cadonna commented on KAFKA-13130:
---
Removing from the 3.2.0 release since fea
[
https://issues.apache.org/jira/browse/KAFKA-12781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517723#comment-17517723
]
Bruno Cadonna commented on KAFKA-12781:
---
Removing from the 3.2.0 release since fea
[
https://issues.apache.org/jira/browse/KAFKA-12781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-12781:
--
Fix Version/s: (was: 3.2.0)
> Improve the endOffsets accuracy in TaskMetadata
> -
artemlivshits commented on code in PR #11991:
URL: https://github.com/apache/kafka/pull/11991#discussion_r843285049
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -184,16 +184,22 @@ private void startSequencesAtBeginning(Topic
jeqo commented on PR #10390:
URL: https://github.com/apache/kafka/pull/10390#issuecomment-1089370471
Thanks @dotjdk !
Do you mean
https://github.com/apache/kafka/blob/8f8f914efc2dfb2a6638553038dcb17393d7de96/streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java#L92
spec
jeqo opened a new pull request, #11999:
URL: https://github.com/apache/kafka/pull/11999
*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 testing st
junrao commented on code in PR #11842:
URL: https://github.com/apache/kafka/pull/11842#discussion_r843226602
##
core/src/test/scala/unit/kafka/tools/DumpLogSegmentsTest.scala:
##
@@ -310,6 +334,38 @@ class DumpLogSegmentsTest {
None
}
+ // Returns the total bytes of t
junrao commented on code in PR #11842:
URL: https://github.com/apache/kafka/pull/11842#discussion_r843225969
##
core/src/test/scala/unit/kafka/tools/DumpLogSegmentsTest.scala:
##
@@ -310,6 +334,38 @@ class DumpLogSegmentsTest {
None
}
+ // Returns the total bytes of t
jlprat commented on PR #11432:
URL: https://github.com/apache/kafka/pull/11432#issuecomment-1089271503
I'll resolve the conflicts tomorrow and ping people for reviews
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
jlprat commented on PR #11350:
URL: https://github.com/apache/kafka/pull/11350#issuecomment-1089268807
@jvican some intermediate work is here:
https://github.com/apache/kafka/pull/11432
I'd need to resolve s couple if conflicts as the PR got no traction for a
while. But I'm happy to
jvican commented on PR #11350:
URL: https://github.com/apache/kafka/pull/11350#issuecomment-1089258871
Any plans to prioritize the Scala 3 migration? Would be nice to see this
happening.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
mimaison merged PR #11974:
URL: https://github.com/apache/kafka/pull/11974
--
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...@kafka.apache
[
https://issues.apache.org/jira/browse/KAFKA-13801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xavier Léauté updated KAFKA-13801:
--
Component/s: metrics
> Kafka server does not respect MetricsReporter interface contract for
>
xvrl opened a new pull request, #11998:
URL: https://github.com/apache/kafka/pull/11998
MetricsReporter.contextChange contract states the method should always
be called first before MetricsReporter.init is called. This is done
correctly for reporters enabled by default (e.g. JmxReporter
Xavier Léauté created KAFKA-13801:
-
Summary: Kafka server does not respect MetricsReporter interface
contract for dynamically configured reporters
Key: KAFKA-13801
URL: https://issues.apache.org/jira/browse/KAFKA-
xvrl opened a new pull request, #11997:
URL: https://github.com/apache/kafka/pull/11997
As part of KIP-376 we had ConsumerInterceptor implement AutoCloseable
but forgot to do the same for ProducerInterceptor. This fixes the
inconsistency and also fixes KAFKA-6204 at the same time.
--
[
https://issues.apache.org/jira/browse/KAFKA-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517651#comment-17517651
]
Xavier Léauté commented on KAFKA-6204:
--
this was mostly fixed by KIP-376
https://cw
lihaosky commented on code in PR #11896:
URL: https://github.com/apache/kafka/pull/11896#discussion_r843123337
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java:
##
@@ -232,11 +247,19 @@
);
[
https://issues.apache.org/jira/browse/KAFKA-13800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hao Li reassigned KAFKA-13800:
--
Assignee: Hao Li
> Remove force cast of TimeWindowKStreamImpl in tests of
> https://github.com/apach
[
https://issues.apache.org/jira/browse/KAFKA-13797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-13797:
---
Description:
It's not a common case, but we experienced the following problem in one of our
cluster
Hao Li created KAFKA-13800:
--
Summary: Remove force cast of TimeWindowKStreamImpl in tests of
https://github.com/apache/kafka/pull/11896
Key: KAFKA-13800
URL: https://issues.apache.org/jira/browse/KAFKA-13800
[
https://issues.apache.org/jira/browse/KAFKA-13794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-13794:
Fix Version/s: 3.2.0
> Producer batch lost silently in TransactionManager
> --
hachikuji commented on PR #11995:
URL: https://github.com/apache/kafka/pull/11995#issuecomment-1089065258
@tombentley This is merged to 3.1 along with #11991. Thanks for managing the
release by the way!
--
This is an automated message from the Apache Git Service.
To respond to the message
[
https://issues.apache.org/jira/browse/KAFKA-13782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-13782.
-
Resolution: Fixed
> Producer may fail to add the correct partition to transaction
>
ijuma commented on PR #11965:
URL: https://github.com/apache/kafka/pull/11965#issuecomment-1089061398
Is it worth backporting this to release branches?
--
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 g
[
https://issues.apache.org/jira/browse/KAFKA-13794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-13794.
-
Fix Version/s: 3.1.1
3.0.2
Resolution: Fixed
> Producer batch
hachikuji merged PR #11991:
URL: https://github.com/apache/kafka/pull/11991
--
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...@kafka.apach
[
https://issues.apache.org/jira/browse/KAFKA-13778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-13778:
Affects Version/s: 2.6.0
(was: 3.2.0)
> Fetch from follower should neve
[
https://issues.apache.org/jira/browse/KAFKA-13778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-13778.
-
Fix Version/s: 3.3.0
Reviewer: David Jacot
Resolution: Fixed
> Fetch from follow
dajac merged PR #11965:
URL: https://github.com/apache/kafka/pull/11965
--
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...@kafka.apache.or
hachikuji merged PR #11995:
URL: https://github.com/apache/kafka/pull/11995
--
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...@kafka.apach
ijuma commented on PR #11995:
URL: https://github.com/apache/kafka/pull/11995#issuecomment-1088982164
In addition to this, we will also include
https://github.com/apache/kafka/pull/11991. @hachikuji should be able to merge
both this morning, I believe.
--
This is an automated message fro
dongjoon-hyun commented on PR #11995:
URL: https://github.com/apache/kafka/pull/11995#issuecomment-1088909166
Hi, @ijuma . According to your dev mailing list email, is this the last
blocker issue before Apache Kafka 3.1.1 RC?
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/KAFKA-12699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-12699:
--
Fix Version/s: (was: 3.2.0)
> Streams no longer overrides the java default uncaught except
[
https://issues.apache.org/jira/browse/KAFKA-12699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517525#comment-17517525
]
Bruno Cadonna commented on KAFKA-12699:
---
Removing from the 3.2.0 release since cod
[
https://issues.apache.org/jira/browse/KAFKA-12774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517524#comment-17517524
]
Bruno Cadonna commented on KAFKA-12774:
---
Removing from the 3.2.0 release since cod
[
https://issues.apache.org/jira/browse/KAFKA-12774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-12774:
--
Fix Version/s: (was: 3.2.0)
> kafka-streams 2.8: logging in uncaught-exceptionhandler does
[
https://issues.apache.org/jira/browse/KAFKA-12774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517523#comment-17517523
]
Bruno Cadonna commented on KAFKA-12774:
---
[~wcarlson5] [~ableegoldman] [~jorgenring
C0urante commented on PR #11974:
URL: https://github.com/apache/kafka/pull/11974#issuecomment-105947
Thanks @mimaison. I hope you don't mind but I've pushed one more change that
simplifies how the configured set of connectors and tasks is simulated (this
came in handy when designing tes
C0urante commented on code in PR #11974:
URL: https://github.com/apache/kafka/pull/11974#discussion_r842931708
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignorTest.java:
##
@@ -76,23 +83,21 @@
@Parameters
pu
mimaison commented on PR #11748:
URL: https://github.com/apache/kafka/pull/11748#issuecomment-1088831443
@tombentley @showuon Can you take a 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 above to go to
mimaison commented on code in PR #11748:
URL: https://github.com/apache/kafka/pull/11748#discussion_r842896247
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java:
##
@@ -169,6 +172,7 @@ public String version() {
return listConsumer
viktorsomogyi commented on code in PR #11748:
URL: https://github.com/apache/kafka/pull/11748#discussion_r842854543
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java:
##
@@ -169,6 +172,7 @@ public String version() {
return listCon
ijuma commented on PR #11991:
URL: https://github.com/apache/kafka/pull/11991#issuecomment-1088659695
Thanks, looks like it's been there since 2.4.0 then.
--
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 t
[
https://issues.apache.org/jira/browse/KAFKA-13799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517382#comment-17517382
]
RivenSun edited comment on KAFKA-13799 at 4/5/22 12:37 PM:
---
Hi
[
https://issues.apache.org/jira/browse/KAFKA-13799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517382#comment-17517382
]
RivenSun commented on KAFKA-13799:
--
Hi [~showuon] [~dengziming] and [~guozhang]
I thin
RivenSun created KAFKA-13799:
Summary: Improve documentation for Kafka zero-copy
Key: KAFKA-13799
URL: https://issues.apache.org/jira/browse/KAFKA-13799
Project: Kafka
Issue Type: Improvement
sciclon2 commented on PR #11842:
URL: https://github.com/apache/kafka/pull/11842#issuecomment-1088562983
@junrao the tests that I added are working locally so I guess the errors are
not relate to my tests
--
This is an automated message from the Apache Git Service.
To respond to the messa
mimaison commented on code in PR #11974:
URL: https://github.com/apache/kafka/pull/11974#discussion_r842632626
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignorTest.java:
##
@@ -769,16 +609,16 @@ public void testLostAssi
sciclon2 commented on code in PR #11842:
URL: https://github.com/apache/kafka/pull/11842#discussion_r842615733
##
core/src/main/scala/kafka/tools/DumpLogSegments.scala:
##
@@ -430,6 +431,11 @@ object DumpLogSegments {
.describedAs("size")
.ofType(classOf[java.lang.
sciclon2 commented on code in PR #11842:
URL: https://github.com/apache/kafka/pull/11842#discussion_r842615490
##
core/src/test/scala/unit/kafka/tools/DumpLogSegmentsTest.scala:
##
@@ -310,6 +334,38 @@ class DumpLogSegmentsTest {
None
}
+ // Returns the total bytes of
sciclon2 commented on code in PR #11842:
URL: https://github.com/apache/kafka/pull/11842#discussion_r842614837
##
core/src/test/scala/unit/kafka/tools/DumpLogSegmentsTest.scala:
##
@@ -310,6 +334,38 @@ class DumpLogSegmentsTest {
None
}
+ // Returns the total bytes of
mimaison commented on code in PR #11974:
URL: https://github.com/apache/kafka/pull/11974#discussion_r842589656
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignorTest.java:
##
@@ -76,23 +83,21 @@
@Parameters
pu
mimaison commented on code in PR #11974:
URL: https://github.com/apache/kafka/pull/11974#discussion_r842589656
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignorTest.java:
##
@@ -76,23 +83,21 @@
@Parameters
pu
ddrid commented on PR #11991:
URL: https://github.com/apache/kafka/pull/11991#issuecomment-1088446711
I think it was introduced in #6883, but I'm not sure if it affects all the
versions since then. What do you think? @hachikuji
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/KAFKA-13791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen resolved KAFKA-13791.
---
Fix Version/s: 3.3.0
Resolution: Fixed
> Fix FetchResponse#`fetchData` and `forgottenTopics`:
showuon merged PR #11981:
URL: https://github.com/apache/kafka/pull/11981
--
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...@kafka.apache.
showuon commented on PR #11981:
URL: https://github.com/apache/kafka/pull/11981#issuecomment-1088355283
Failed tests are unrelated.
```
Build / JDK 11 and Scala 2.13 /
kafka.api.ClientIdQuotaTest.testProducerConsumerOverrideUnthrottled()
Build / JDK 17 and Scala 2.13 /
kafk
76 matches
Mail list logo
