[GitHub] [kafka] chia7712 commented on a change in pull request #9401: KAFKA-9628 Replace Produce request/response with automated protocol

chia7712 commented on a change in pull request #9401: URL: https://github.com/apache/kafka/pull/9401#discussion_r519251671 ## File path: clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java ## @@ -204,118 +75,78 @@ public ProduceResponse(Map responses) {

[jira] [Created] (KAFKA-10698) Avoid casting BaseRecords to MemoryRecords

Chia-Ping Tsai created KAFKA-10698: -- Summary: Avoid casting BaseRecords to MemoryRecords Key: KAFKA-10698 URL: https://issues.apache.org/jira/browse/KAFKA-10698 Project: Kafka Issue Type: Im

[GitHub] [kafka] chia7712 commented on a change in pull request #9401: KAFKA-9628 Replace Produce request/response with automated protocol

chia7712 commented on a change in pull request #9401: URL: https://github.com/apache/kafka/pull/9401#discussion_r519251328 ## File path: core/src/main/scala/kafka/server/KafkaApis.scala ## @@ -517,19 +517,23 @@ class KafkaApis(val requestChannel: RequestChannel, }

[GitHub] [kafka] chia7712 commented on a change in pull request #9401: KAFKA-9628 Replace Produce request/response with automated protocol

chia7712 commented on a change in pull request #9401: URL: https://github.com/apache/kafka/pull/9401#discussion_r519251131 ## File path: clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java ## @@ -204,118 +75,78 @@ public ProduceResponse(Map responses) {

[jira] [Created] (KAFKA-10697) Remove ProduceResponse.responses

Chia-Ping Tsai created KAFKA-10697: -- Summary: Remove ProduceResponse.responses Key: KAFKA-10697 URL: https://issues.apache.org/jira/browse/KAFKA-10697 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-10696) Replace ProduceResponse.PartitionResponse by auto-generated PartitionProduceResponse

Chia-Ping Tsai created KAFKA-10696: -- Summary: Replace ProduceResponse.PartitionResponse by auto-generated PartitionProduceResponse Key: KAFKA-10696 URL: https://issues.apache.org/jira/browse/KAFKA-10696

[GitHub] [kafka] chia7712 commented on a change in pull request #9401: KAFKA-9628 Replace Produce request/response with automated protocol

chia7712 commented on a change in pull request #9401: URL: https://github.com/apache/kafka/pull/9401#discussion_r519250823 ## File path: clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java ## @@ -560,13 +561,23 @@ private void handleProduceResponse(Cl

[jira] [Created] (KAFKA-10695) Improve interface for sensor expiration

David Mao created KAFKA-10695: - Summary: Improve interface for sensor expiration Key: KAFKA-10695 URL: https://issues.apache.org/jira/browse/KAFKA-10695 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-10694) Implement zero copy for FetchSnapshot

[ https://issues.apache.org/jira/browse/KAFKA-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio updated KAFKA-10694: --- Description: Change the _RawSnapshotWriter_ and _RawSnapshotReader_

[jira] [Updated] (KAFKA-10694) Implement zero copy for FetchSnapshot

[ https://issues.apache.org/jira/browse/KAFKA-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio updated KAFKA-10694: --- Description: Change the _RawSnapshotWriter_ and _RawSnapshotReader_

[jira] [Updated] (KAFKA-10694) Implement zero copy for FetchSnapshot

[ https://issues.apache.org/jira/browse/KAFKA-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio updated KAFKA-10694: --- Description: Change the `RawSnapshotWriter` and `RawSnapshotReader`

[GitHub] [kafka] jsancio commented on a change in pull request #9512: KAFKA-10394: generate snapshot

jsancio commented on a change in pull request #9512: URL: https://github.com/apache/kafka/pull/9512#discussion_r519213671 ## File path: raft/src/main/java/org/apache/kafka/snapshot/SnapshotReader.java ## @@ -0,0 +1,36 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [kafka] jsancio commented on a change in pull request #9512: KAFKA-10394: generate snapshot

jsancio commented on a change in pull request #9512: URL: https://github.com/apache/kafka/pull/9512#discussion_r519211721 ## File path: raft/src/main/java/org/apache/kafka/snapshot/RawSnapshotReader.java ## @@ -0,0 +1,52 @@ +/* + * Licensed to the Apache Software Foundation (AS

[GitHub] [kafka] jsancio commented on a change in pull request #9512: KAFKA-10394: generate snapshot

jsancio commented on a change in pull request #9512: URL: https://github.com/apache/kafka/pull/9512#discussion_r519211586 ## File path: raft/src/main/java/org/apache/kafka/snapshot/RawSnapshotWriter.java ## @@ -0,0 +1,74 @@ +/* + * Licensed to the Apache Software Foundation (AS

[GitHub] [kafka] jsancio commented on a change in pull request #9512: KAFKA-10394: generate snapshot

jsancio commented on a change in pull request #9512: URL: https://github.com/apache/kafka/pull/9512#discussion_r519211390 ## File path: raft/src/main/java/org/apache/kafka/raft/QuorumState.java ## @@ -32,25 +32,25 @@ * This class is responsible for managing the current state

[jira] [Created] (KAFKA-10694) Implement zero copy for FetchSnapshot

Jose Armando Garcia Sancio created KAFKA-10694: -- Summary: Implement zero copy for FetchSnapshot Key: KAFKA-10694 URL: https://issues.apache.org/jira/browse/KAFKA-10694 Project: Kafka

[jira] [Updated] (KAFKA-8067) JsonConverter missing and optional field defaults result in a null pointer

[ https://issues.apache.org/jira/browse/KAFKA-8067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Pheatt updated KAFKA-8067: --- Affects Version/s: (was: 2.6.0) > JsonConverter missing and optional field defaults result in a n

[jira] [Updated] (KAFKA-8067) JsonConverter missing and optional field defaults result in a null pointer

[ https://issues.apache.org/jira/browse/KAFKA-8067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Pheatt updated KAFKA-8067: --- Affects Version/s: (was: 2.3.0) (was: 1.1.1) 2.6