dielhennr removed a comment on pull request #11141:
URL: https://github.com/apache/kafka/pull/11141#issuecomment-892837165
@hachikuji @rajinisivaram since this build is green I’m fairly confident
that dynamic config behavior hasn’t changed in a zk cluster. I am wondering if
it is better t
[
https://issues.apache.org/jira/browse/KAFKA-9914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17397208#comment-17397208
]
Al Ricafort commented on KAFKA-9914:
Hi,
I have the same issue.
I have 2 Kafka setu
CS User created KAFKA-13191:
---
Summary: Kafka 2.8 - simultaneous restarts of Kafka and zookeeper
result in broken cluster
Key: KAFKA-13191
URL: https://issues.apache.org/jira/browse/KAFKA-13191
Project: Kafk
[
https://issues.apache.org/jira/browse/KAFKA-13191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CS User updated KAFKA-13191:
Description:
We're using confluent platform 6.2, running in a Kubernetes environment. The
cluster has bee
chia7712 commented on a change in pull request #10881:
URL: https://github.com/apache/kafka/pull/10881#discussion_r686709179
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerUtilTest.java
##
@@ -42,77 +39,65 @@
import static java.
[
https://issues.apache.org/jira/browse/KAFKA-13191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CS User updated KAFKA-13191:
Description:
We're using confluent platform 6.2, running in a Kubernetes environment. The
cluster has bee
[
https://issues.apache.org/jira/browse/KAFKA-13191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CS User updated KAFKA-13191:
Description:
We're using confluent platform 6.2, running in a Kubernetes environment. The
cluster has bee
[
https://issues.apache.org/jira/browse/KAFKA-13191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CS User updated KAFKA-13191:
Description:
We're using confluent platform 6.2, running in a Kubernetes environment. The
cluster has bee
[
https://issues.apache.org/jira/browse/KAFKA-13191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CS User updated KAFKA-13191:
Description:
We're using confluent platform 6.2, running in a Kubernetes environment. The
cluster has bee
[
https://issues.apache.org/jira/browse/KAFKA-13191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CS User updated KAFKA-13191:
Description:
We're using confluent platform 6.2, running in a Kubernetes environment. The
cluster has bee
[
https://issues.apache.org/jira/browse/KAFKA-13191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CS User updated KAFKA-13191:
Description:
We're using confluent platform 6.2, running in a Kubernetes environment. The
cluster has bee
[
https://issues.apache.org/jira/browse/KAFKA-13191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CS User updated KAFKA-13191:
Description:
We're using confluent platform 6.2, running in a Kubernetes environment. The
cluster has bee
rodesai commented on pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#issuecomment-896970248
@cadonna @ableegoldman @guozhangwang
--
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
Ron Dagostino created KAFKA-13192:
-
Summary: broker.id and node.id can be specified inconsistently
Key: KAFKA-13192
URL: https://issues.apache.org/jira/browse/KAFKA-13192
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-12954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17397503#comment-17397503
]
Josep Prat commented on KAFKA-12954:
There is a PR for supporting Scala 3 in Gradle:
Jose Armando Garcia Sancio created KAFKA-13193:
--
Summary: Replica manager doesn't update partition state when
transitioning from leader to follower with unknown leader
Key: KAFKA-13193
URL: https://is
Lucas Bradstreet created KAFKA-13194:
Summary: LogCleaner may clean past highwatermark
Key: KAFKA-13194
URL: https://issues.apache.org/jira/browse/KAFKA-13194
Project: Kafka
Issue Type: B
[
https://issues.apache.org/jira/browse/KAFKA-13192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino reassigned KAFKA-13192:
-
Assignee: Ron Dagostino
> broker.id and node.id can be specified inconsistently
> -
[
https://issues.apache.org/jira/browse/KAFKA-13194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Bradstreet updated KAFKA-13194:
-
Description:
Here we have the cleaning point being bounded to the active segment base of
[
https://issues.apache.org/jira/browse/KAFKA-13194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Bradstreet updated KAFKA-13194:
-
Priority: Minor (was: Major)
> LogCleaner may clean past highwatermark
> --
[
https://issues.apache.org/jira/browse/KAFKA-13194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17397601#comment-17397601
]
Justine Olshan commented on KAFKA-13194:
There was code to change this in [https
lbradstreet opened a new pull request #11199:
URL: https://github.com/apache/kafka/pull/11199
When the high watermark is contained in a non-active segment, we are not
correctly bounding it by the hwm. This means that uncommitted records may
overwrite committed data.
--
This is an automa
rondagostino opened a new pull request #11200:
URL: https://github.com/apache/kafka/pull/11200
If both `broker.id` and `node.id` are set, and they are set inconsistently
(e.g.`broker.id=0`, `node.id=1`) then currently the value of `node.id` is used
and the `broker.id` value is left at the
jsancio commented on a change in pull request #11200:
URL: https://github.com/apache/kafka/pull/11200#discussion_r687192965
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1420,6 +1420,17 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
Boole
hachikuji commented on a change in pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#discussion_r687186647
##
File path:
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java
##
@@ -173,6 +176,121 @@ private void
testDelayedConfigurat
rondagostino commented on a change in pull request #11200:
URL: https://github.com/apache/kafka/pull/11200#discussion_r687199159
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1420,6 +1420,17 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
hachikuji commented on a change in pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#discussion_r687194150
##
File path:
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java
##
@@ -173,6 +176,121 @@ private void
testDelayedConfigurat
xvrl opened a new pull request #11201:
URL: https://github.com/apache/kafka/pull/11201
Metric tag maps do not offer any ordering guarantees. We should
always sort tags when generating mbean names, or we could end up
with duplicate means with different tag order or orphaned mbeans
th
niket-goel commented on a change in pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#discussion_r687262045
##
File path:
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java
##
@@ -173,6 +176,121 @@ private void
testDelayedConfigura
niket-goel commented on a change in pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#discussion_r687262147
##
File path:
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java
##
@@ -173,6 +176,121 @@ private void
testDelayedConfigura
niket-goel commented on a change in pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#discussion_r687262311
##
File path:
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java
##
@@ -173,6 +176,121 @@ private void
testDelayedConfigura
niket-goel commented on a change in pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#discussion_r687262200
##
File path:
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java
##
@@ -173,6 +176,121 @@ private void
testDelayedConfigura
[
https://issues.apache.org/jira/browse/KAFKA-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loboxu updated KAFKA-10900:
---
Description:
KIP-630 enumerates a few metrics. Makes sure that those metrics are implemented.
|kafka.cont
socutes opened a new pull request #11202:
URL: https://github.com/apache/kafka/pull/11202
修复”snasphot”命名问题. 改为”snapshot”.
--
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
socutes closed pull request #11202:
URL: https://github.com/apache/kafka/pull/11202
--
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.
dengziming commented on pull request #11138:
URL: https://github.com/apache/kafka/pull/11138#issuecomment-897275322
Currently we add a `FileSnapshotReader` class and copy some original code to
it, a better way is to rename `SnapshotReader` to `FileSnapshotReader` and add
a `SnapshotReader`
socutes opened a new pull request #11203:
URL: https://github.com/apache/kafka/pull/11203
Fixed "snasphot" naming issue. Instead of "snapshot".
--
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 th
socutes commented on pull request #11203:
URL: https://github.com/apache/kafka/pull/11203#issuecomment-897310958
@showuon @niket-goel please help review this pr. Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
[
https://issues.apache.org/jira/browse/KAFKA-13165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-13165.
Resolution: Fixed
> Validate node id, process role and quorum voters
> ---
[
https://issues.apache.org/jira/browse/KAFKA-13188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alok Nikhil reassigned KAFKA-13188:
---
Assignee: Alok Nikhil
> Release the memory back into MemoryPool
> -
aloknnikhil opened a new pull request #11204:
URL: https://github.com/apache/kafka/pull/11204
**Forward porting** - https://github.com/linkedin/kafka/pull/186
**TICKET** = [KAFKA-13188](https://issues.apache.org/jira/browse/KAFKA-13188)
**LI_DESCRIPTION** =
The current KafkaCons
tvainika commented on a change in pull request #10277:
URL: https://github.com/apache/kafka/pull/10277#discussion_r687419372
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java
##
@@ -489,7 +489,17 @@ boolean isCycle(String top
42 matches
Mail list logo
