[jira] [Created] (KAFKA-10446) add "lz4" and "zstd" to compression type of benchmark_test.py
Chia-Ping Tsai created KAFKA-10446: -- Summary: add "lz4" and "zstd" to compression type of benchmark_test.py Key: KAFKA-10446 URL: https://issues.apache.org/jira/browse/KAFKA-10446 Project: Kafka Issue Type: Improvement Reporter: Chia-Ping Tsai Assignee: Chia-Ping Tsai Both "lz4" and "zstd" are popular and important compressions supported by kafka. They are worth being benchmark. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (KAFKA-10447) Migrate tools module from JUnit 4 to JUnit 5
Ismael Juma created KAFKA-10447: --- Summary: Migrate tools module from JUnit 4 to JUnit 5 Key: KAFKA-10447 URL: https://issues.apache.org/jira/browse/KAFKA-10447 Project: Kafka Issue Type: Sub-task Reporter: Ismael Juma Assignee: Ismael Juma -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (KAFKA-10448) Preserve Source Partition in Kafka Streams from context
satya created KAFKA-10448: - Summary: Preserve Source Partition in Kafka Streams from context Key: KAFKA-10448 URL: https://issues.apache.org/jira/browse/KAFKA-10448 Project: Kafka Issue Type: Improvement Components: streams Affects Versions: 2.5.0 Reporter: satya Currently Kafka streams Sink Nodes use default partitioner or has the provision of using a custom partitioner which has to be dependent on key/value. I am looking for an enhancement of Sink Node to ensure source partition is preserved instead of deriving the partition again using key/value. One of our use case has producers which have customer partitioners that we dont have access to as it is a third-party application. By simply preserving the partition through context.partition() would be helpful. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (KAFKA-10449) Connect-distributed sample configuration file does not have instructions for listeners
tinawenqiao created KAFKA-10449: --- Summary: Connect-distributed sample configuration file does not have instructions for listeners Key: KAFKA-10449 URL: https://issues.apache.org/jira/browse/KAFKA-10449 Project: Kafka Issue Type: Improvement Components: KafkaConnect Affects Versions: 2.6.0 Reporter: tinawenqiao In WokerConfig.java we found that REST_HOST_NAME_CONFIG(rest.host.name) and REST_PORT_CONFIG(rest.port) were deprecated. And some new configuration parameters are introduced such as LISTENERS_CONFIG(listeners), REST_ADVERTISED_LISTENER_CONFIG(rest.advertised.listener),ADMIN_LISTENERS_CONFIG(admin.listeners) but not list in the sample conf file. -- This message was sent by Atlassian Jira (v8.3.4#803005)
