[
https://issues.apache.org/jira/browse/KAFKA-13812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jacky resolved KAFKA-13812.
---
Resolution: Not A Bug
> Kraft TopicsDelta finishSnapshot maybe loss data
> -
bozhao12 opened a new pull request, #12022:
URL: https://github.com/apache/kafka/pull/12022
…s onControllerResignation
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify doc
showuon commented on code in PR #12015:
URL: https://github.com/apache/kafka/pull/12015#discussion_r846566765
##
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala:
##
@@ -868,7 +872,7 @@ object DynamicListenerConfig {
)
}
-class DynamicClientQuotaCallback(brokerId
showuon commented on PR #12006:
URL: https://github.com/apache/kafka/pull/12006#issuecomment-1093624469
Cherry-pick back to 3.2, 3.1, 3.0 as
https://github.com/apache/kafka/pull/11991 did.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
showuon merged PR #12006:
URL: https://github.com/apache/kafka/pull/12006
--
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-13812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jacky updated KAFKA-13812:
--
Summary: Kraft TopicsDelta finishSnapshot maybe loss data (was: Kraft
TopicsDelta deletedTopicIds maybe loss
jacky created KAFKA-13812:
-
Summary: Kraft TopicsDelta deletedTopicIds maybe loss data
Key: KAFKA-13812
URL: https://issues.apache.org/jira/browse/KAFKA-13812
Project: Kafka
Issue Type: Bug
showuon commented on PR #12006:
URL: https://github.com/apache/kafka/pull/12006#issuecomment-1093618609
Failed tests are unrelated
```
Build / ARM /
kafka.network.ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit()
```
--
This is an automated message fr
showuon commented on PR #10367:
URL: https://github.com/apache/kafka/pull/10367#issuecomment-1093617556
Great! I'll take a look next week. Also cc @kkonstantine . Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
jsancio opened a new pull request, #12021:
URL: https://github.com/apache/kafka/pull/12021
When migrating from Easymock to Mockito, the mockito implemetnation
didn't have the same semantic as the Easymock implementation.
Without this fix the mocking of LogSegment.size() always retur
cadonna commented on PR #12017:
URL: https://github.com/apache/kafka/pull/12017#issuecomment-1093490164
> @cadonna This is probably a 3.2 blocker.
Thank you for letting me know and cherry-picking to 3.2.
--
This is an automated message from the Apache Git Service.
To respond to the
cadonna commented on PR #12018:
URL: https://github.com/apache/kafka/pull/12018#issuecomment-1093487516
@dajac @lihaosky This failed test might be related to the PR since it
involves probing rebalances.
```
Build / JDK 17 and Scala 2.13 /
org.apache.kafka.streams.integration.HighA
cadonna commented on PR #12014:
URL: https://github.com/apache/kafka/pull/12014#issuecomment-1093483360
Thank you @ijuma !
--
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.
T
mjsax commented on PR #12020:
URL: https://github.com/apache/kafka/pull/12020#issuecomment-1093473885
Build failed. Looks concerning?
--
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
mjsax commented on code in PR #12020:
URL: https://github.com/apache/kafka/pull/12020#discussion_r846536809
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java:
##
@@ -86,10 +87,23 @@
import static
org.apache.kafka.streams.proces
mjsax commented on code in PR #12020:
URL: https://github.com/apache/kafka/pull/12020#discussion_r846536809
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java:
##
@@ -86,10 +87,23 @@
import static
org.apache.kafka.streams.proces
[
https://issues.apache.org/jira/browse/KAFKA-13651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson reassigned KAFKA-13651:
---
Assignee: Jason Gustafson
> StandardAuthorizer should implement all the required lo
C0urante commented on PR #11914:
URL: https://github.com/apache/kafka/pull/11914#issuecomment-1093388773
@mimaison do you have time for this quick change?
--
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
C0urante commented on PR #11894:
URL: https://github.com/apache/kafka/pull/11894#issuecomment-1093388485
@tombentley do you have time to take a look at this one?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
C0urante commented on PR #11890:
URL: https://github.com/apache/kafka/pull/11890#issuecomment-1093386858
@showuon do you have time for this quick change?
--
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
C0urante commented on PR #11838:
URL: https://github.com/apache/kafka/pull/11838#issuecomment-1093383801
BTW, probably want to update the ticket number in the title to 13702.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
C0urante commented on PR #11838:
URL: https://github.com/apache/kafka/pull/11838#issuecomment-1093383402
There's also https://github.com/apache/kafka/pull/11844, which addresses the
same issue and takes a slightly different approach that preserves the exact
status that the client received f
[
https://issues.apache.org/jira/browse/KAFKA-13156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519808#comment-17519808
]
Chris Egerton commented on KAFKA-13156:
---
It looks like we emit tombstones into the
ijuma merged PR #12017:
URL: https://github.com/apache/kafka/pull/12017
--
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
Leah Thomas created KAFKA-13811:
---
Summary: Investigate sliding windows performance
Key: KAFKA-13811
URL: https://issues.apache.org/jira/browse/KAFKA-13811
Project: Kafka
Issue Type: Task
[
https://issues.apache.org/jira/browse/KAFKA-13764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519733#comment-17519733
]
Chris Egerton edited comment on KAFKA-13764 at 4/8/22 7:29 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519748#comment-17519748
]
Chris Egerton commented on KAFKA-7509:
--
Thanks [~mjsax]. It seems like the root caus
vvcephei commented on code in PR #12020:
URL: https://github.com/apache/kafka/pull/12020#discussion_r846375420
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/DynamicPrefixLogger.java:
##
@@ -0,0 +1,353 @@
+/*
+ * Licensed to the Apache Software Foundation (
vvcephei opened a new pull request, #12020:
URL: https://github.com/apache/kafka/pull/12020
Reading assignor logs is really confusing in large part because they are
spread across different layers of abstraction (the ConsumerCoordinator
and the ConsumerPartitionAssignor, which in Stream
aloknnikhil commented on PR #12017:
URL: https://github.com/apache/kafka/pull/12017#issuecomment-1093154427
Looks like we had a successful run for JDK 11 / Scala 2.13 except for one
unrelated test failure
```java
[2022-04-08T17:31:23.221Z]
org.apache.kafka.streams.integration.IQv2Stor
C0urante commented on PR #11986:
URL: https://github.com/apache/kafka/pull/11986#issuecomment-1093149178
I've updated the approach to extract `RecordingMap` into a separate file
that's in an internal package. It should now be acceptable to merge these
changes without a KIP since that elimin
[
https://issues.apache.org/jira/browse/KAFKA-13764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519733#comment-17519733
]
Chris Egerton edited comment on KAFKA-13764 at 4/8/22 5:26 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-13764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519733#comment-17519733
]
Chris Egerton edited comment on KAFKA-13764 at 4/8/22 5:26 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-13764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519733#comment-17519733
]
Chris Egerton commented on KAFKA-13764:
---
While reviewing the existing rebalancing
C0urante commented on PR #10367:
URL: https://github.com/apache/kafka/pull/10367#issuecomment-1093107179
@showuon FYI, I've just opened https://github.com/apache/kafka/pull/12019,
which should address KAFKA-12495 and some other issues with rebalancing, but
without using consecutive revocati
C0urante opened a new pull request, #12019:
URL: https://github.com/apache/kafka/pull/12019
[Jira](https://issues.apache.org/jira/browse/KAFKA-13764)
Depends on https://github.com/apache/kafka/pull/11983
The primary goal of this PR is to address several outstanding issues with
artemlivshits commented on PR #12006:
URL: https://github.com/apache/kafka/pull/12006#issuecomment-1093103372
LGTM, thank you for the fix.
--
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 spec
dajac commented on PR #12018:
URL: https://github.com/apache/kafka/pull/12018#issuecomment-1093069190
@cadonna It might be worth getting this one in 3.2. It is low risk. This is
a good one to improve the debugability of Streams. What do you think?
--
This is an automated message from the
lihaosky opened a new pull request, #12018:
URL: https://github.com/apache/kafka/pull/12018
Add rebalance reason in Kafka Streams. Ran benchmark and it looks good.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test cov
ijuma commented on PR #12014:
URL: https://github.com/apache/kafka/pull/12014#issuecomment-1093038346
@cadonna I cherry-picked this to 3.2 since it was a regression and it
affects the build only.
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
ijuma merged PR #12014:
URL: https://github.com/apache/kafka/pull/12014
--
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
aloknnikhil commented on PR #12017:
URL: https://github.com/apache/kafka/pull/12017#issuecomment-1093020096
I agree without the logging there's not much value doing it manually.
Changed it to use the `ignorable` attribute
--
This is an automated message from the Apache Git Service.
To res
[
https://issues.apache.org/jira/browse/KAFKA-13809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Urban resolved KAFKA-13809.
--
Resolution: Won't Fix
Connector configs are used for consumer/producer overrides, converter cl
Karsten Spang created KAFKA-13810:
-
Summary: Document behavior of KafkaProducer.flush() w.r.t callbacks
Key: KAFKA-13810
URL: https://issues.apache.org/jira/browse/KAFKA-13810
Project: Kafka
ijuma commented on PR #12017:
URL: https://github.com/apache/kafka/pull/12017#issuecomment-1092940128
@cadonna This is probably a 3.2 blocker.
--
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
ijuma commented on PR #12017:
URL: https://github.com/apache/kafka/pull/12017#issuecomment-1092939875
Thanks for the PR. In my opinion, we should set the field to ignorable and
add a comment where we set the error code stating that it's ignored for
versions older than 3. The generator code
aloknnikhil opened a new pull request, #12017:
URL: https://github.com/apache/kafka/pull/12017
With KAFKA-13527 / KIP-784 we introduced a new top-level error code for
the DescribeLogDirs API for versions 3 and above. However, the change
regressed the error handling for versions less tha
[
https://issues.apache.org/jira/browse/KAFKA-13809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Urban updated KAFKA-13809:
-
Description:
The 2 example connectors do not propagate the full connector configuration to
the
Daniel Urban created KAFKA-13809:
Summary: FileStreamSinkConnector and FileStreamSourceConnector
should propagate full configuration to tasks
Key: KAFKA-13809
URL: https://issues.apache.org/jira/browse/KAFKA-13809
RivenSun2 commented on PR #12010:
URL: https://github.com/apache/kafka/pull/12010#issuecomment-1092692088
I created a KIP:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-828%3A+Add+the+corresponding+validator+to+the+configuration+where+the+validator+is+missing
--
This is an aut
yangl opened a new pull request, #12016:
URL: https://github.com/apache/kafka/pull/12016
fix the https://issues.apache.org/jira/browse/KAFKA-13808
--
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-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YANGLiiN updated KAFKA-13808:
-
Description:
When use the mirrormaker2 with the "Running a dedicated MirrorMaker cluster"
mode, we mod
[
https://issues.apache.org/jira/browse/KAFKA-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YANGLiiN updated KAFKA-13808:
-
Description:
When use the mirrormaker2 with the "Running a dedicated MirrorMaker cluster"
mode, we mod
YANGLiiN created KAFKA-13808:
Summary: Mirrormaker2 stop sync data when modify topic partition
in "Running a dedicated MirrorMaker cluster" mode
Key: KAFKA-13808
URL: https://issues.apache.org/jira/browse/KAFKA-13808
[
https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519441#comment-17519441
]
RivenSun commented on KAFKA-13793:
--
Hi [~showuon]
I created a KIP, please help to revi
showuon commented on code in PR #10827:
URL: https://github.com/apache/kafka/pull/10827#discussion_r845892551
##
core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala:
##
@@ -140,25 +150,28 @@ object ReplicaVerificationTool extends Logging {
val maxWaitMs = options.
[
https://issues.apache.org/jira/browse/KAFKA-13191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519434#comment-17519434
]
Fabio Hecht commented on KAFKA-13191:
-
According to my tests with Confluent 7.1.0 /
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519431#comment-17519431
]
Nicholas Telford commented on KAFKA-13272:
--
There appears to be a viable work-a
[
https://issues.apache.org/jira/browse/KAFKA-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519420#comment-17519420
]
Robin Van Praet commented on KAFKA-7491:
[~k.schnit...@sap.com] we include the ka
[
https://issues.apache.org/jira/browse/KAFKA-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519412#comment-17519412
]
Karsten Schnitter commented on KAFKA-7491:
--
[~robin.vanpr...@aca-it.be] I do not
dajac opened a new pull request, #12015:
URL: https://github.com/apache/kafka/pull/12015
Made a few edits while reading that file.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [
[
https://issues.apache.org/jira/browse/KAFKA-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519371#comment-17519371
]
Robin Van Praet commented on KAFKA-7491:
What we did was using the shade-plugin t
dajac commented on PR #12012:
URL: https://github.com/apache/kafka/pull/12012#issuecomment-1092533545
@EvansJahja Thanks for the PR!
As the PR changes the public interface of the command line tool, we need to
do a KIP for it. The process is described here:
https://cwiki.apache.org/co
63 matches
Mail list logo
