[GitHub] [kafka] chia7712 opened a new pull request #10171: MINOR: avoid duplicate array copying from BufferValue#serialize

chia7712 opened a new pull request #10171: URL: https://github.com/apache/kafka/pull/10171 We can write ProcessorRecordContext to target `ByteBuffer` directly. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test

[GitHub] [kafka] chia7712 commented on pull request #10024: KAFKA-12273 InterBrokerSendThread#pollOnce throws FatalExitError even…

chia7712 commented on pull request #10024: URL: https://github.com/apache/kafka/pull/10024#issuecomment-783116760 `Build / JDK 11 / org.apache.kafka.connect.integration.InternalTopicsIntegrationTest.testCreateInternalTopicsWithFewerReplicasThanBrokers` It is fixed by #10152 and

[GitHub] [kafka] chia7712 commented on a change in pull request #10157: MINOR: Raft request thread should discover api versions

chia7712 commented on a change in pull request #10157: URL: https://github.com/apache/kafka/pull/10157#discussion_r579977803 ## File path: core/src/main/scala/kafka/raft/KafkaNetworkChannel.scala ## @@ -124,8 +124,18 @@ class KafkaNetworkChannel( } def

[GitHub] [kafka] hachikuji commented on a change in pull request #10157: MINOR: Raft request thread should discover api versions

hachikuji commented on a change in pull request #10157: URL: https://github.com/apache/kafka/pull/10157#discussion_r579959527 ## File path: core/src/main/scala/kafka/raft/KafkaNetworkChannel.scala ## @@ -124,8 +124,14 @@ class KafkaNetworkChannel( } def

[jira] [Created] (KAFKA-12355) Consider inter-broker authentication error handling

Jason Gustafson created KAFKA-12355: --- Summary: Consider inter-broker authentication error handling Key: KAFKA-12355 URL: https://issues.apache.org/jira/browse/KAFKA-12355 Project: Kafka

[jira] [Created] (KAFKA-12354) PHP Kafka Client longyan/phpkafka

Zhang Runyu created KAFKA-12354: --- Summary: PHP Kafka Client longyan/phpkafka Key: KAFKA-12354 URL: https://issues.apache.org/jira/browse/KAFKA-12354 Project: Kafka Issue Type: Wish

[jira] [Created] (KAFKA-12353) Improve ClientResponse error handling

Jason Gustafson created KAFKA-12353: --- Summary: Improve ClientResponse error handling Key: KAFKA-12353 URL: https://issues.apache.org/jira/browse/KAFKA-12353 Project: Kafka Issue Type:

[GitHub] [kafka] hachikuji commented on a change in pull request #10157: MINOR: Raft request thread should discover api versions

hachikuji commented on a change in pull request #10157: URL: https://github.com/apache/kafka/pull/10157#discussion_r579954768 ## File path: core/src/main/scala/kafka/server/AlterIsrManager.scala ## @@ -165,9 +165,19 @@ class DefaultAlterIsrManager( new

[GitHub] [kafka] jsancio commented on a change in pull request #10157: MINOR: Raft request thread should discover api versions

jsancio commented on a change in pull request #10157: URL: https://github.com/apache/kafka/pull/10157#discussion_r579892241 ## File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java ## @@ -2244,7 +2244,6 @@ private Long append(int epoch, List records, boolean

[GitHub] [kafka] ijuma commented on a change in pull request #10157: MINOR: Raft request thread should discover api versions

ijuma commented on a change in pull request #10157: URL: https://github.com/apache/kafka/pull/10157#discussion_r579875328 ## File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java ## @@ -2244,7 +2244,6 @@ private Long append(int epoch, List records, boolean

[GitHub] [kafka] ijuma commented on a change in pull request #10157: MINOR: Raft request thread should discover api versions

ijuma commented on a change in pull request #10157: URL: https://github.com/apache/kafka/pull/10157#discussion_r579875306 ## File path: core/src/main/scala/kafka/server/AlterIsrManager.scala ## @@ -165,9 +165,19 @@ class DefaultAlterIsrManager( new

[GitHub] [kafka] ijuma commented on a change in pull request #10157: MINOR: Raft request thread should discover api versions

ijuma commented on a change in pull request #10157: URL: https://github.com/apache/kafka/pull/10157#discussion_r579875266 ## File path: core/src/main/scala/kafka/raft/KafkaNetworkChannel.scala ## @@ -124,8 +124,14 @@ class KafkaNetworkChannel( } def

[jira] [Commented] (KAFKA-10034) Clarify Usage of "batch.size" and "max.request.size" Producer Configs

[ https://issues.apache.org/jira/browse/KAFKA-10034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288088#comment-17288088 ] Badai Aqrandista commented on KAFKA-10034: -- Yes, I am. Will do that this week. > Clarify Usage

[GitHub] [kafka] sknop commented on a change in pull request #9950: KAFKA-12170: Fix for Connect Cast SMT to correctly transform a Byte array into a string

sknop commented on a change in pull request #9950: URL: https://github.com/apache/kafka/pull/9950#discussion_r579839255 ## File path: connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java ## @@ -364,11 +365,24 @@ private static String

[GitHub] [kafka] sknop commented on a change in pull request #9950: KAFKA-12170: Fix for Connect Cast SMT to correctly transform a Byte array into a string

sknop commented on a change in pull request #9950: URL: https://github.com/apache/kafka/pull/9950#discussion_r579838511 ## File path: connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java ## @@ -364,11 +365,24 @@ private static String

[jira] [Resolved] (KAFKA-12337) provide full scala api for operators naming

[ https://issues.apache.org/jira/browse/KAFKA-12337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] GeordieMai resolved KAFKA-12337. Resolution: Duplicate > provide full scala api for operators naming >