[
https://issues.apache.org/jira/browse/KAFKA-12205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275793#comment-17275793
]
dengziming commented on KAFKA-12205:
Here is my understanding about when to delete a snapshot, first
rohitrmd commented on a change in pull request #9744:
URL: https://github.com/apache/kafka/pull/9744#discussion_r567356968
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java
##
@@ -45,7 +45,6 @@
private boolean
[
https://issues.apache.org/jira/browse/KAFKA-12236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-12236.
-
Resolution: Fixed
> Add version 1 of meta.properties for KIP-500
>
hachikuji merged pull request #9967:
URL: https://github.com/apache/kafka/pull/9967
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
hachikuji commented on pull request #9967:
URL: https://github.com/apache/kafka/pull/9967#issuecomment-770307353
One test failure fixed by https://github.com/apache/kafka/pull/10006.
Merging to trunk.
This is an automated
hachikuji edited a comment on pull request #10006:
URL: https://github.com/apache/kafka/pull/10006#issuecomment-770119487
@abbccdda See for example this trace, which is often found in an unrelated
test case (https://github.com/apache/kafka/runs/1794689847):
```
[
https://issues.apache.org/jira/browse/KAFKA-12260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-12260:
---
Assignee: Boyang Chen
> PartitionsFor should not return null value
>
Boyang Chen created KAFKA-12260:
---
Summary: PartitionsFor should not return null value
Key: KAFKA-12260
URL: https://issues.apache.org/jira/browse/KAFKA-12260
Project: Kafka
Issue Type:
rondagostino commented on a change in pull request #10005:
URL: https://github.com/apache/kafka/pull/10005#discussion_r567315872
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -3008,7 +3107,8 @@ class KafkaApis(val requestChannel: RequestChannel,
hachikuji commented on pull request #9967:
URL: https://github.com/apache/kafka/pull/9967#issuecomment-770279434
@ijuma Yep, got a little lazy verifying the case class conversion. Hopefully
fixed now. We were in fact relying on the `equals`, but I modified the test
case.
rondagostino commented on a change in pull request #10005:
URL: https://github.com/apache/kafka/pull/10005#discussion_r567313320
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -249,6 +270,7 @@ class KafkaApis(val requestChannel: RequestChannel,
}
ijuma commented on pull request #9967:
URL: https://github.com/apache/kafka/pull/9967#issuecomment-770276918
I think the case class change caused a compiler error, we probably need to
make the field accessible.
This is an
hachikuji commented on a change in pull request #9967:
URL: https://github.com/apache/kafka/pull/9967#discussion_r567309420
##
File path: clients/src/main/java/org/apache/kafka/common/Uuid.java
##
@@ -106,6 +106,9 @@ public String toString() {
*/
public static Uuid
hachikuji commented on a change in pull request #9967:
URL: https://github.com/apache/kafka/pull/9967#discussion_r567306870
##
File path: core/src/main/scala/kafka/server/BrokerMetadataCheckpoint.scala
##
@@ -21,38 +21,203 @@ import java.io._
import java.nio.file.{Files,
ijuma commented on a change in pull request #9967:
URL: https://github.com/apache/kafka/pull/9967#discussion_r566168366
##
File path: core/src/main/scala/kafka/server/BrokerMetadataCheckpoint.scala
##
@@ -21,38 +21,203 @@ import java.io._
import java.nio.file.{Files,
hachikuji commented on pull request #9739:
URL: https://github.com/apache/kafka/pull/9739#issuecomment-770267814
@feyman2016 I can help getting this over the line if you don't have time. I
think it's just a couple small changes after rebasing.
hachikuji commented on a change in pull request #9967:
URL: https://github.com/apache/kafka/pull/9967#discussion_r567301638
##
File path: core/src/main/scala/kafka/server/BrokerMetadataCheckpoint.scala
##
@@ -21,38 +21,203 @@ import java.io._
import java.nio.file.{Files,
rondagostino commented on a change in pull request #10005:
URL: https://github.com/apache/kafka/pull/10005#discussion_r567300660
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1654,6 +1702,7 @@ class KafkaApis(val requestChannel: RequestChannel,
rondagostino commented on a change in pull request #10005:
URL: https://github.com/apache/kafka/pull/10005#discussion_r567300510
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -2609,14 +2672,27 @@ class KafkaApis(val requestChannel: RequestChannel,
rondagostino commented on a change in pull request #10005:
URL: https://github.com/apache/kafka/pull/10005#discussion_r567300461
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -150,7 +167,11 @@ class KafkaApis(val requestChannel: RequestChannel,
}
chia7712 commented on a change in pull request #9967:
URL: https://github.com/apache/kafka/pull/9967#discussion_r567254453
##
File path: core/src/main/scala/kafka/server/BrokerMetadataCheckpoint.scala
##
@@ -21,38 +21,203 @@ import java.io._
import java.nio.file.{Files,
[
https://issues.apache.org/jira/browse/KAFKA-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-10555.
--
> Improve client state machine
>
>
> Key:
[
https://issues.apache.org/jira/browse/KAFKA-12227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-12227:
---
Parent: KAFKA-10733
Issue Type: Sub-task (was: Improvement)
> Add method
chia7712 merged pull request #10001:
URL: https://github.com/apache/kafka/pull/10001
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
chia7712 commented on pull request #10001:
URL: https://github.com/apache/kafka/pull/10001#issuecomment-770201214
the flaky is traced by #9777
This is an automated message from the Apache Git Service.
To respond to the
dengziming edited a comment on pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#issuecomment-770140196
The 2 failures in
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-9769/22/#showFailuresLink
seem to be related to Mockito, maybe #10006 will fix it.
26 matches
Mail list logo
