dajac commented on pull request #11201:
URL: https://github.com/apache/kafka/pull/11201#issuecomment-897421076
@xvrl Thanks for the patch. I think that ordering tags make sense. However,
I am a little concerned by the potential implication of changing this. I
vaguely recall having to craft
[
https://issues.apache.org/jira/browse/KAFKA-12835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-12835:
Fix Version/s: 2.8.1
> Topic IDs can mismatch on brokers (after interbroker protocol version updat
[
https://issues.apache.org/jira/browse/KAFKA-13014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17397957#comment-17397957
]
Ahmed Toumi commented on KAFKA-13014:
-
thanks [~mjsax] : but the problem was more co
xdgrulez commented on pull request #10897:
URL: https://github.com/apache/kafka/pull/10897#issuecomment-897524395
Hi,
will do that as soon as I have some time - and sorry for not finding time
yet…
If anyone else would have some more time on her/his hand - you basically
just w
showuon commented on a change in pull request #11200:
URL: https://github.com/apache/kafka/pull/11200#discussion_r687624316
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1905,6 +1905,13 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
Boole
socutes opened a new pull request #11205:
URL: https://github.com/apache/kafka/pull/11205
KIP-630 enumerates a few metrics. Makes sure that those metrics are
implemented. Add the following Metrics.
kafka.controller:type=KafkaController,name=GenSnapshotLatencyMs | A
histogram of
showuon opened a new pull request #11206:
URL: https://github.com/apache/kafka/pull/11206
Update the streams doc:
1. close `KeyValueIterator` in example code
https://user-images.githubusercontent.com/43372967/129201334-326ff4f9-e06e-426d-9d2d-ce70e13cbf9c.png";>
2. Fix the examp
showuon commented on pull request #11206:
URL: https://github.com/apache/kafka/pull/11206#issuecomment-897622337
@bbejeck , please help review. 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
ryannedolan commented on a change in pull request #10277:
URL: https://github.com/apache/kafka/pull/10277#discussion_r687741760
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java
##
@@ -489,7 +489,17 @@ boolean isCycle(String
Ludo created KAFKA-13195:
Summary: StateSerde don't honor DeserializationExceptionHandler
Key: KAFKA-13195
URL: https://issues.apache.org/jira/browse/KAFKA-13195
Project: Kafka
Issue Type: Bug
tvainika commented on a change in pull request #10277:
URL: https://github.com/apache/kafka/pull/10277#discussion_r687772348
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java
##
@@ -489,7 +489,17 @@ boolean isCycle(String top
Jozef Vilcek created KAFKA-13196:
Summary: MirrorMaker 2 not always starting tasks after upgrade
2.4.0 -> 2.7.1
Key: KAFKA-13196
URL: https://issues.apache.org/jira/browse/KAFKA-13196
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jozef Vilcek updated KAFKA-13196:
-
Summary: MirrorMaker 2 not always starting tasks (was: MirrorMaker 2 not
always starting tasks
[
https://issues.apache.org/jira/browse/KAFKA-13196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jozef Vilcek updated KAFKA-13196:
-
Description:
I am using MirrorMaker 2.0 and running it via [
MirrorMaker.java|https://github.co
[
https://issues.apache.org/jira/browse/KAFKA-13196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jozef Vilcek updated KAFKA-13196:
-
Description:
I am using MirrorMaker 2.0 and running it via [
MirrorMaker.java|https://github.co
[
https://issues.apache.org/jira/browse/KAFKA-13196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jozef Vilcek updated KAFKA-13196:
-
Summary: MirrorMaker 2 not always start tasks (was: MirrorMaker 2 not
always starting tasks)
>
Tommy Becker created KAFKA-13197:
Summary: KStream-GlobalKTable join semantics don't match
documentation
Key: KAFKA-13197
URL: https://issues.apache.org/jira/browse/KAFKA-13197
Project: Kafka
SkyTianTian commented on pull request #10277:
URL: https://github.com/apache/kafka/pull/10277#issuecomment-897736948
Hi, is there anyone who knows any workaround to avoid this heartbeat issue?
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
jsancio commented on a change in pull request #11200:
URL: https://github.com/apache/kafka/pull/11200#discussion_r687854292
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1905,6 +1905,13 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
Boole
SkyTianTian edited a comment on pull request #10277:
URL: https://github.com/apache/kafka/pull/10277#issuecomment-897736948
Hi, is there anyone who knows any workaround to avoid this heartbeat issue
temporarily?
--
This is an automated message from the Apache Git Service.
To respond to t
jsancio commented on a change in pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#discussion_r687047710
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java
##
@@ -161,6 +163,14 @@ public void deactivate() {
r
socutes closed pull request #11205:
URL: https://github.com/apache/kafka/pull/11205
--
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.
[
https://issues.apache.org/jira/browse/KAFKA-13188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398148#comment-17398148
]
Alok Nikhil commented on KAFKA-13188:
-
[~luwang] I see that the consumer side memory
hachikuji commented on pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#issuecomment-897785278
@niket-goel I'm inclined to merge this as is so that we don't need to wait
for another build. Perhaps you can submit a small follow-up to address @jsancio
's comments?
--
T
hachikuji merged pull request #11191:
URL: https://github.com/apache/kafka/pull/11191
--
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-unsubsc
socutes opened a new pull request #11207:
URL: https://github.com/apache/kafka/pull/11207
KIP-630 enumerates a few metrics. Makes sure that those metrics are
implemented. Add the following Metrics.
kafka.controller:type=KafkaController,name=GenSnapshotLatencyMs , A
histogram of the
socutes commented on pull request #11207:
URL: https://github.com/apache/kafka/pull/11207#issuecomment-897797158
@jsancio @cmccabe 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 use th
[
https://issues.apache.org/jira/browse/KAFKA-13016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loboxu reassigned KAFKA-13016:
--
Assignee: loboxu
> Interpret snapshot header version to correctly parse the snapshot
> --
[
https://issues.apache.org/jira/browse/KAFKA-12956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loboxu reassigned KAFKA-12956:
--
Assignee: loboxu
> Validate the snapshot id when the state machine freeze a snapshot
> --
niket-goel commented on pull request #11191:
URL: https://github.com/apache/kafka/pull/11191#issuecomment-897806958
@hachikuji Will follow up with a follow-up. Thanks for merging this.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
niket-goel opened a new pull request #11208:
URL: https://github.com/apache/kafka/pull/11208
Some code refactoring based on https://github.com/apache/kafka/pull/11191
feedback
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/KAFKA-13162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398209#comment-17398209
]
Jason Gustafson commented on KAFKA-13162:
-
This has turned out to be more work t
[
https://issues.apache.org/jira/browse/KAFKA-13162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-13162:
Fix Version/s: (was: 3.0.0)
3.0.1
> ElectLeader API must be forward
[
https://issues.apache.org/jira/browse/KAFKA-13173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-13173.
--
Resolution: Fixed
> KRaft controller does not handle simultaneous broker expirations correctly
[
https://issues.apache.org/jira/browse/KAFKA-13142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-13142:
-
Fix Version/s: (was: 3.0.0)
3.0.1
Affects Version/s: 3.0.0
>
junrao commented on a change in pull request #11199:
URL: https://github.com/apache/kafka/pull/11199#discussion_r687993862
##
File path: core/src/main/scala/kafka/log/LogCleanerManager.scala
##
@@ -595,8 +595,8 @@ private[log] object LogCleanerManager extends Logging {
//
rondagostino commented on a change in pull request #11200:
URL: https://github.com/apache/kafka/pull/11200#discussion_r688014091
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1905,6 +1905,13 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
rondagostino commented on a change in pull request #11200:
URL: https://github.com/apache/kafka/pull/11200#discussion_r688016827
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1905,6 +1905,13 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
rondagostino commented on a change in pull request #11200:
URL: https://github.com/apache/kafka/pull/11200#discussion_r688016827
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1905,6 +1905,13 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
lbradstreet commented on a change in pull request #11199:
URL: https://github.com/apache/kafka/pull/11199#discussion_r688051673
##
File path: core/src/main/scala/kafka/log/LogCleanerManager.scala
##
@@ -595,8 +595,8 @@ private[log] object LogCleanerManager extends Logging {
lbradstreet commented on a change in pull request #11199:
URL: https://github.com/apache/kafka/pull/11199#discussion_r688051998
##
File path: core/src/test/scala/unit/kafka/log/LogCleanerManagerTest.scala
##
@@ -541,6 +541,29 @@ class LogCleanerManagerTest extends Logging {
Jose Armando Garcia Sancio created KAFKA-13198:
--
Summary: TopicsDelta doesn't update deleted topic when processing
PartitionChangeRecord
Key: KAFKA-13198
URL: https://issues.apache.org/jira/browse/KAF
junrao merged pull request #11154:
URL: https://github.com/apache/kafka/pull/11154
--
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..
[
https://issues.apache.org/jira/browse/KAFKA-13068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-13068.
-
Fix Version/s: 3.1.0
Resolution: Fixed
Merged the PR to trunk
> Rename Log to UnifiedLog
> -
guozhangwang commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r688142016
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
##
@@ -1369,4 +1385,67 @@ public void onCompletion(RecordMe
lbradstreet commented on pull request #11199:
URL: https://github.com/apache/kafka/pull/11199#issuecomment-898057637
> @lbradstreet : Thanks for the updated PR. LGTM. Are the 29 test failures
related to this PR?
@junrao yeah, they're looking related. Let me clean those up.
--
This
dengziming opened a new pull request #11209:
URL: https://github.com/apache/kafka/pull/11209
*More detailed description of your change*
When handling a response, invalid cluster id are fatal unless a previous
response contained a valid cluster id.
Note that this is not a perfect, see
dengziming commented on pull request #11209:
URL: https://github.com/apache/kafka/pull/11209#issuecomment-898134690
Hi @hachikuji @jsancio , PTAL. I also moved the logic for
`UNKNOWN_TOPIC_OR_PARTITION` in handleFetchSnapshot to `RaftUtil.java`.
--
This is an automated message from the
showuon commented on a change in pull request #11208:
URL: https://github.com/apache/kafka/pull/11208#discussion_r688206957
##
File path:
metadata/src/test/java/org/apache/kafka/controller/ReplicationControlManagerTest.java
##
@@ -200,6 +200,14 @@ void registerBrokers(Integer.
rodesai commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r688236582
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
##
@@ -590,9 +593,11 @@ else if (acks != -1)
public void in
rodesai commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r688239443
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java
##
@@ -178,12 +180,39 @@ public void resetProducer(
rodesai commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r688240676
##
File path:
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java
##
@@ -730,6 +732,41 @@ public void testFlushCompleteSendOfI
rodesai commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r688240994
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java
##
@@ -178,12 +180,39 @@ public void resetProducer(
rodesai commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r688242729
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java
##
@@ -200,6 +201,30 @@ public RocksDBMe
rodesai commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r68825
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsThreadTotalBlockedTime.java
##
@@ -0,0 +1,61 @@
+/*
+ * Licensed
rodesai commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r688245686
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
##
@@ -590,9 +593,11 @@ else if (acks != -1)
public void in
rodesai commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r688255651
##
File path:
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java
##
@@ -730,6 +732,41 @@ public void testFlushCompleteSendOfI
[
https://issues.apache.org/jira/browse/KAFKA-12155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengziming resolved KAFKA-12155.
Resolution: Fixed
> Delay increasing the log start offset
> -
kamalcph commented on pull request #11197:
URL: https://github.com/apache/kafka/pull/11197#issuecomment-898206391
retest
--
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
Xianghu Wang created KAFKA-13199:
Summary: Make Task extend Versioned
Key: KAFKA-13199
URL: https://issues.apache.org/jira/browse/KAFKA-13199
Project: Kafka
Issue Type: Wish
Repor
[
https://issues.apache.org/jira/browse/KAFKA-13199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xianghu Wang updated KAFKA-13199:
-
Summary: Make Task extends Versioned (was: Make Task extend Versioned)
> Make Task extends Vers
wangxianghu opened a new pull request #11210:
URL: https://github.com/apache/kafka/pull/11210
Since `Task` is versioned, we can make it extends `Versioned` directly, no
need to introduce `String version()` again
### Committer Checklist (excluded from commit message)
- [ ] Verify d
guozhangwang commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r688267294
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
##
@@ -590,9 +593,11 @@ else if (acks != -1)
public vo
guozhangwang commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r688267856
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsThreadTotalBlockedTime.java
##
@@ -0,0 +1,61 @@
+/*
+ * Lice
guozhangwang commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r688268274
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java
##
@@ -200,6 +201,30 @@ public Rock
showuon commented on a change in pull request #11201:
URL: https://github.com/apache/kafka/pull/11201#discussion_r688286213
##
File path:
clients/src/test/java/org/apache/kafka/common/metrics/JmxReporterTest.java
##
@@ -76,6 +77,21 @@ public void testJmxRegistration() throws E
showuon commented on pull request #11201:
URL: https://github.com/apache/kafka/pull/11201#issuecomment-898234132
Also, there are some `metrics` related tests failed. You might need to take
a look.
```
Build / ARM /
org.apache.kafka.streams.processor.internals.StreamTaskTest.testM
67 matches
Mail list logo
