[
https://issues.apache.org/jira/browse/KAFKA-13804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-13804:
--
Description:
Currently, when the broker hit exception during startup, we will first log the
exception
[
https://issues.apache.org/jira/browse/KAFKA-13804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-13804:
--
Summary: Log broker shutdown reason during startup at the end of log output
(was: Log broker shutdown
mjsax commented on code in PR #12030:
URL: https://github.com/apache/kafka/pull/12030#discussion_r847995239
##
streams/src/main/java/org/apache/kafka/streams/state/internals/PrefixedWindowKeySchemas.java:
##
@@ -33,8 +33,8 @@
public class PrefixedWindowKeySchemas {
priva
showuon commented on PR #12028:
URL: https://github.com/apache/kafka/pull/12028#issuecomment-1096122509
@mimaison @dajac , please take a look. 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 above to go
cmccabe opened a new pull request, #12033:
URL: https://github.com/apache/kafka/pull/12033
Ensure that we can set log.flush.interval.ms at the broker or cluster level
via
IncrementalAlterConfigs. THis was broken by KAFKA-13749, which added
log.flush.interval.ms as the
second synonym r
hachikuji commented on code in PR #12032:
URL: https://github.com/apache/kafka/pull/12032#discussion_r847812399
##
core/src/main/scala/kafka/controller/KafkaController.scala:
##
@@ -2348,7 +2348,20 @@ class KafkaController(val config: KafkaConfig,
controllerContext.pa
jsancio commented on code in PR #12032:
URL: https://github.com/apache/kafka/pull/12032#discussion_r847810681
##
core/src/main/scala/kafka/controller/KafkaController.scala:
##
@@ -2348,7 +2348,20 @@ class KafkaController(val config: KafkaConfig,
controllerContext.part
[
https://issues.apache.org/jira/browse/KAFKA-13816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-13816:
--
Description:
The rebalancing protocol for a Kafka Connect cluster can be downgraded from
incr
hachikuji opened a new pull request, #12032:
URL: https://github.com/apache/kafka/pull/12032
Currently we validate recovery state before checking leader epoch. It seems
more intuitive to validate leader epoch first since the leader might be working
with stale state. This patch fixes this an
vvcephei commented on code in PR #11993:
URL: https://github.com/apache/kafka/pull/11993#discussion_r84395
##
streams/src/test/java/org/apache/kafka/test/MockProcessorNode.java:
##
@@ -60,7 +61,7 @@ public void init(final InternalProcessorContext
context) {
@Override
vvcephei merged PR #11999:
URL: https://github.com/apache/kafka/pull/11999
--
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
jsancio merged PR #12021:
URL: https://github.com/apache/kafka/pull/12021
--
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-8318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520787#comment-17520787
]
padavan edited comment on KAFKA-8318 at 4/11/22 7:51 PM:
-
any new
[
https://issues.apache.org/jira/browse/KAFKA-8318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520787#comment-17520787
]
padavan commented on KAFKA-8318:
any news?
> Session Window Aggregations generate an ex
lihaosky commented on code in PR #11896:
URL: https://github.com/apache/kafka/pull/11896#discussion_r847621808
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java:
##
@@ -80,22 +109,54 @@ public void enableSendingOldValues() {
[
https://issues.apache.org/jira/browse/KAFKA-13819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13819:
-
Component/s: streams
> Add application.server to Streams assignor logs when set
> --
John Roesler created KAFKA-13820:
Summary: Add debug-level logs to explain why a store is filtered
out during interactive query
Key: KAFKA-13820
URL: https://issues.apache.org/jira/browse/KAFKA-13820
[
https://issues.apache.org/jira/browse/KAFKA-13818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13818:
-
Component/s: consumer
> Add generation to consumer assignor logs
> -
[
https://issues.apache.org/jira/browse/KAFKA-13820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13820:
-
Component/s: streams
> Add debug-level logs to explain why a store is filtered out during
> int
lihaosky commented on code in PR #11896:
URL: https://github.com/apache/kafka/pull/11896#discussion_r847582057
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java:
##
@@ -232,11 +247,19 @@
);
John Roesler created KAFKA-13819:
Summary: Add application.server to Streams assignor logs when set
Key: KAFKA-13819
URL: https://issues.apache.org/jira/browse/KAFKA-13819
Project: Kafka
Issu
John Roesler created KAFKA-13818:
Summary: Add generation to consumer assignor logs
Key: KAFKA-13818
URL: https://issues.apache.org/jira/browse/KAFKA-13818
Project: Kafka
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/KAFKA-13818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-13818:
Assignee: John Roesler
> Add generation to consumer assignor logs
> -
hachikuji opened a new pull request, #12031:
URL: https://github.com/apache/kafka/pull/12031
This patch adds audit support through the `kafka.authorizer.logger` logger
to `StandardAuthorizer`. It follows the same conventions in `AclAuthorizer`.
When `logIfAllowed` is set in the `Action`, t
Hao Li created KAFKA-13817:
--
Summary: Schedule nextTimeToEmit to system time every time instead
of just once
Key: KAFKA-13817
URL: https://issues.apache.org/jira/browse/KAFKA-13817
Project: Kafka
I
vvcephei commented on code in PR #12020:
URL: https://github.com/apache/kafka/pull/12020#discussion_r847561327
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java:
##
@@ -86,10 +87,23 @@
import static
org.apache.kafka.streams.pro
ccding commented on code in PR #12029:
URL: https://github.com/apache/kafka/pull/12029#discussion_r847548177
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -678,7 +678,7 @@ class UnifiedLog(@volatile var logStartOffset: Long,
*
* @throws KafkaStorageException i
lihaosky opened a new pull request, #12030:
URL: https://github.com/apache/kafka/pull/12030
### Description
A new cache for `RocksDBTimeOrderedWindowStore`. Need this because
`RocksDBTimeOrderedWindowStore`'s key ordering if different from
`CachingWindowStore` which has issues for `Merge
YeonCheolGit commented on code in PR #12019:
URL: https://github.com/apache/kafka/pull/12019#discussion_r847446537
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java:
##
@@ -200,283 +229,149 @@ private Long ensureLea
hachikuji commented on code in PR #12027:
URL: https://github.com/apache/kafka/pull/12027#discussion_r847524509
##
tests/kafkatest/tests/core/downgrade_test.py:
##
@@ -139,13 +139,13 @@ def test_upgrade_and_downgrade(self, version,
compression_types, security_protoc
gitlw commented on PR #12029:
URL: https://github.com/apache/kafka/pull/12029#issuecomment-1095270481
@dajac @junrao This PR is related to
https://github.com/apache/kafka/pull/8672.
Can you please take a look? Thank you!
--
This is an automated message from the Apache Git Service.
To
YeonCheolGit commented on code in PR #12019:
URL: https://github.com/apache/kafka/pull/12019#discussion_r847446537
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java:
##
@@ -200,283 +229,149 @@ private Long ensureLea
YeonCheolGit commented on code in PR #12019:
URL: https://github.com/apache/kafka/pull/12019#discussion_r847446537
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java:
##
@@ -200,283 +229,149 @@ private Long ensureLea
YeonCheolGit commented on code in PR #12019:
URL: https://github.com/apache/kafka/pull/12019#discussion_r847446537
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java:
##
@@ -200,283 +229,149 @@ private Long ensureLea
YeonCheolGit commented on code in PR #12019:
URL: https://github.com/apache/kafka/pull/12019#discussion_r847446537
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java:
##
@@ -200,283 +229,149 @@ private Long ensureLea
gitlw opened a new pull request, #12029:
URL: https://github.com/apache/kafka/pull/12029
This PR tries to avoid the reinitialization of the leader epoch cache
and the partition metadata if the corresponding replica is being deleted.
With this change, the asyncDelete method can run more
[
https://issues.apache.org/jira/browse/KAFKA-13816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520572#comment-17520572
]
Chris Egerton commented on KAFKA-13816:
---
I won't have time to work on this but I h
dengziming commented on PR #12024:
URL: https://github.com/apache/kafka/pull/12024#issuecomment-1095046509
Hello @dajac , Maybe you can take a look at this because those tests in
`TopicCommandIntegrationTest` are created by you.
--
This is an automated message from the Apache Git Service.
Chris Egerton created KAFKA-13816:
-
Summary: Downgrading Connect rebalancing protocol from incremental
to eager causes duplicate task instances
Key: KAFKA-13816
URL: https://issues.apache.org/jira/browse/KAFKA-138
showuon commented on PR #10367:
URL: https://github.com/apache/kafka/pull/10367#issuecomment-1095006324
> @showuon @C0urante @kkonstantine What is the status of this PR? As far as
I understand this PR might resolve
[KAFKA-8391](https://issues.apache.org/jira/browse/KAFKA-8391),
[KAFKA-1228
[
https://issues.apache.org/jira/browse/KAFKA-13815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang reassigned KAFKA-13815:
--
Assignee: Lucas Wang
> Avoid reinitialization for a replica that is being deleted
> -
Lucas Wang created KAFKA-13815:
--
Summary: Avoid reinitialization for a replica that is being deleted
Key: KAFKA-13815
URL: https://issues.apache.org/jira/browse/KAFKA-13815
Project: Kafka
Issue
cadonna commented on PR #10367:
URL: https://github.com/apache/kafka/pull/10367#issuecomment-1094942596
@showuon @C0urante @kkonstantine What is the status of this PR? As far as I
understand this PR might resolve
[KAFKA-8391](https://issues.apache.org/jira/browse/KAFKA-8391),
[KAFKA-12283]
showuon opened a new pull request, #12028:
URL: https://github.com/apache/kafka/pull/12028
JIRA: [KAFKA-13804](https://issues.apache.org/jira/browse/KAFKA-13804)
improve the log readability by adding the exception why broker exit during
startup.
### Committer Checklist (exclude
[
https://issues.apache.org/jira/browse/KAFKA-13804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-13804:
--
Description:
Currently, when the broker hit exception, or SIGINT signal received, we will
first log t
[
https://issues.apache.org/jira/browse/KAFKA-13804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-13804:
--
Description:
Currently, when the broker hit exception, or SIGINT signal received, we will
first log t
[
https://issues.apache.org/jira/browse/KAFKA-13810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520477#comment-17520477
]
Luke Chen commented on KAFKA-13810:
---
Yes, after flush, all the requests are completed,
dajac commented on PR #12027:
URL: https://github.com/apache/kafka/pull/12027#issuecomment-1094821441
Got a successful run here:
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2022-04-11--001.system-test-kafka-branch-builder--1649665531--dajac--minor-fix
[
https://issues.apache.org/jira/browse/KAFKA-13810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520435#comment-17520435
]
Karsten Spang commented on KAFKA-13810:
---
[~showuon] I assume that all callbacks ar
Ge commented on PR #11945:
URL: https://github.com/apache/kafka/pull/11945#issuecomment-1094706378
@mjsax Can you please take another 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 the
dajac opened a new pull request, #12027:
URL: https://github.com/apache/kafka/pull/12027
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade
51 matches
Mail list logo
