[jira] [Updated] (KAFKA-8563) Minor: Remove method call in netoworkSend

[ https://issues.apache.org/jira/browse/KAFKA-8563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] karan kumar updated KAFKA-8563: --- Environment: Darwin WM-CXX 18.2.0 Darwin Kernel Version 18.2.0: Thu Dec 20 20:46:53 PST 2018; ro

[jira] [Created] (KAFKA-8563) Minor: Remove method call in netoworkSend

karan kumar created KAFKA-8563: -- Summary: Minor: Remove method call in netoworkSend Key: KAFKA-8563 URL: https://issues.apache.org/jira/browse/KAFKA-8563 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-8488) FetchSessionHandler logging create 73 mb allocation in TLAB which could be no op

[ https://issues.apache.org/jira/browse/KAFKA-8488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-8488: Fix Version/s: 2.4.0 > FetchSessionHandler logging create 73 mb allocation in TLAB

[jira] [Commented] (KAFKA-8559) PartitionStates.partitionStates cause array grow allocation.

[ https://issues.apache.org/jira/browse/KAFKA-8559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16867205#comment-16867205 ] ASF GitHub Bot commented on KAFKA-8559: --- ijuma commented on pull request #6964: KAF

[jira] [Resolved] (KAFKA-8559) PartitionStates.partitionStates cause array grow allocation.

[ https://issues.apache.org/jira/browse/KAFKA-8559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-8559. Resolution: Fixed Fix Version/s: 2.4.0 > PartitionStates.partitionStates cause array grow al

[jira] [Updated] (KAFKA-8561) Make Kafka Pluggable with customized Keystore/TrustStore

[ https://issues.apache.org/jira/browse/KAFKA-8561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Zhou updated KAFKA-8561: --- Priority: Major (was: Minor) > Make Kafka Pluggable with customized Keystore/TrustStore > --

[jira] [Commented] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16867181#comment-16867181 ] Boquan Tang commented on KAFKA-8335: [~francisco.juan] This patch worked for us. I h

[jira] [Commented] (KAFKA-8491) Bump up Consumer Protocol to v2 (part 1)

[ https://issues.apache.org/jira/browse/KAFKA-8491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16867163#comment-16867163 ] Boyang Chen commented on KAFKA-8491: Could we link the PR here? > Bump up Consumer P

[jira] [Created] (KAFKA-8562) SASL_SSL still performs reverse DNS lookup despite KAFKA-5051

Badai Aqrandista created KAFKA-8562: --- Summary: SASL_SSL still performs reverse DNS lookup despite KAFKA-5051 Key: KAFKA-8562 URL: https://issues.apache.org/jira/browse/KAFKA-8562 Project: Kafka

[jira] [Updated] (KAFKA-8562) SASL_SSL still performs reverse DNS lookup despite KAFKA-5051

[ https://issues.apache.org/jira/browse/KAFKA-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Badai Aqrandista updated KAFKA-8562: Priority: Minor (was: Major) > SASL_SSL still performs reverse DNS lookup despite KAFKA-50

[jira] [Created] (KAFKA-8561) Make Kafka Pluggable with customized Keystore/TrustStore

Thomas Zhou created KAFKA-8561: -- Summary: Make Kafka Pluggable with customized Keystore/TrustStore Key: KAFKA-8561 URL: https://issues.apache.org/jira/browse/KAFKA-8561 Project: Kafka Issue Type

[jira] [Comment Edited] (KAFKA-8450) Augment processed in MockProcessor as KeyValueAndTimestamp

[ https://issues.apache.org/jira/browse/KAFKA-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16866019#comment-16866019 ] SuryaTeja Duggi edited comment on KAFKA-8450 at 6/19/19 12:11 AM: -

[jira] [Resolved] (KAFKA-8491) Bump up Consumer Protocol to v2 (part 1)

[ https://issues.apache.org/jira/browse/KAFKA-8491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8491. Resolution: Fixed > Bump up Consumer Protocol to v2 (part 1) >

[jira] [Updated] (KAFKA-8559) PartitionStates.partitionStates cause array grow allocation.

[ https://issues.apache.org/jira/browse/KAFKA-8559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8559: --- Component/s: consumer > PartitionStates.partitionStates cause array grow allocation. > -

[jira] [Commented] (KAFKA-8560) The Kafka protocol generator should support common structures

[ https://issues.apache.org/jira/browse/KAFKA-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16867125#comment-16867125 ] ASF GitHub Bot commented on KAFKA-8560: --- cmccabe commented on pull request #6966: K

[jira] [Created] (KAFKA-8560) The Kafka protocol generator should support common structures

Colin P. McCabe created KAFKA-8560: -- Summary: The Kafka protocol generator should support common structures Key: KAFKA-8560 URL: https://issues.apache.org/jira/browse/KAFKA-8560 Project: Kafka

[jira] [Commented] (KAFKA-8488) FetchSessionHandler logging create 73 mb allocation in TLAB which could be no op

[ https://issues.apache.org/jira/browse/KAFKA-8488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16867119#comment-16867119 ] ASF GitHub Bot commented on KAFKA-8488: --- wenhoujx commented on pull request #6964:

[jira] [Created] (KAFKA-8559) PartitionStates.partitionStates cause array grow allocation.

Wenshuai Hou created KAFKA-8559: --- Summary: PartitionStates.partitionStates cause array grow allocation. Key: KAFKA-8559 URL: https://issues.apache.org/jira/browse/KAFKA-8559 Project: Kafka Is

[jira] [Commented] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-8179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16867049#comment-16867049 ] ASF GitHub Bot commented on KAFKA-8179: --- ableegoldman commented on pull request #69

[jira] [Created] (KAFKA-8558) KIP-479 - Add Materialized Overload to KStream#Join

Bill Bejeck created KAFKA-8558: -- Summary: KIP-479 - Add Materialized Overload to KStream#Join Key: KAFKA-8558 URL: https://issues.apache.org/jira/browse/KAFKA-8558 Project: Kafka Issue Type: Im

[jira] [Created] (KAFKA-8557) Support named listeners in system tests

Stanislav Vodetskyi created KAFKA-8557: -- Summary: Support named listeners in system tests Key: KAFKA-8557 URL: https://issues.apache.org/jira/browse/KAFKA-8557 Project: Kafka Issue Type:

[jira] [Reopened] (KAFKA-4222) Transient failure in QueryableStateIntegrationTest.queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reopened KAFKA-4222: Assignee: (was: Damian Guy) > Transient failure in QueryableStateIntegrationTest.queryOnRebal

[jira] [Commented] (KAFKA-4222) Transient failure in QueryableStateIntegrationTest.queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16867000#comment-16867000 ] Boyang Chen commented on KAFKA-4222: [https://builds.apache.org/job/kafka-pr-jdk8-sca

[jira] [Commented] (KAFKA-8245) Flaky Test DeleteConsumerGroupsTest#testDeleteCmdAllGroups

[ https://issues.apache.org/jira/browse/KAFKA-8245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16866997#comment-16866997 ] Boyang Chen commented on KAFKA-8245: [https://builds.apache.org/job/kafka-pr-jdk8-sca

[jira] [Commented] (KAFKA-8448) Too many kafka.log.Log instances (Memory Leak)

[ https://issues.apache.org/jira/browse/KAFKA-8448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16866994#comment-16866994 ] ASF GitHub Bot commented on KAFKA-8448: --- cmccabe commented on pull request #6892: K

[jira] [Assigned] (KAFKA-8556) Add system tests for assignment stickiness validation

[ https://issues.apache.org/jira/browse/KAFKA-8556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8556: -- Assignee: Boyang Chen > Add system tests for assignment stickiness validation > --

[jira] [Created] (KAFKA-8556) Add system tests for assignment stickiness validation

Boyang Chen created KAFKA-8556: -- Summary: Add system tests for assignment stickiness validation Key: KAFKA-8556 URL: https://issues.apache.org/jira/browse/KAFKA-8556 Project: Kafka Issue Type: S

[jira] [Resolved] (KAFKA-8448) Too many kafka.log.Log instances (Memory Leak)

[ https://issues.apache.org/jira/browse/KAFKA-8448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-8448. Resolution: Fixed Fix Version/s: 2.4.0 > Too many kafka.log.Log instances (Memory Le

[jira] [Commented] (KAFKA-8448) Too many kafka.log.Log instances (Memory Leak)

[ https://issues.apache.org/jira/browse/KAFKA-8448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16866889#comment-16866889 ] ASF GitHub Bot commented on KAFKA-8448: --- cmccabe commented on pull request #6847: K

[jira] [Commented] (KAFKA-8405) Remove deprecated preferred leader RPC and Command

[ https://issues.apache.org/jira/browse/KAFKA-8405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16866848#comment-16866848 ] Jose Armando Garcia Sancio commented on KAFKA-8405: --- Correct. In 2.4.0

[jira] [Created] (KAFKA-8555) Flaky test ExampleConnectIntegrationTest#testSourceConnector

Boyang Chen created KAFKA-8555: -- Summary: Flaky test ExampleConnectIntegrationTest#testSourceConnector Key: KAFKA-8555 URL: https://issues.apache.org/jira/browse/KAFKA-8555 Project: Kafka Issue

[jira] [Commented] (KAFKA-3287) Add over-wire encryption support between KAFKA and ZK

[ https://issues.apache.org/jira/browse/KAFKA-3287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16866772#comment-16866772 ] Gérald Quintana commented on KAFKA-3287: This means adding Zookeeper client SSL s

[jira] [Commented] (KAFKA-3288) Update ZK dependency to 3.5.1 when it is marked as stable

[ https://issues.apache.org/jira/browse/KAFKA-3288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16866761#comment-16866761 ] Gérald Quintana commented on KAFKA-3288: Zookeeper 3.5.5 is marked as stable > U

[jira] [Comment Edited] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1685#comment-1685 ] Francisco Juan edited comment on KAFKA-8335 at 6/18/19 2:51 PM: ---

[jira] [Comment Edited] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1685#comment-1685 ] Francisco Juan edited comment on KAFKA-8335 at 6/18/19 2:50 PM: ---

[jira] [Commented] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1685#comment-1685 ] Francisco Juan commented on KAFKA-8335: --- Hello, we have recently updated a Kafka cl

[jira] [Comment Edited] (KAFKA-4090) JVM runs into OOM if (Java) client uses a SSL port without setting the security protocol

[ https://issues.apache.org/jira/browse/KAFKA-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1681#comment-1681 ] Kurt T Stam edited comment on KAFKA-4090 at 6/18/19 2:43 PM: -

[jira] [Commented] (KAFKA-4090) JVM runs into OOM if (Java) client uses a SSL port without setting the security protocol

[ https://issues.apache.org/jira/browse/KAFKA-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1681#comment-1681 ] Kurt T Stam commented on KAFKA-4090: Is this a hard bug to fix? Can't we just add som

[jira] [Commented] (KAFKA-8554) Generate Topic/Key from Json Transform

[ https://issues.apache.org/jira/browse/KAFKA-8554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16866640#comment-16866640 ] ASF GitHub Bot commented on KAFKA-8554: --- gokhansari commented on pull request #6960

[jira] [Commented] (KAFKA-8554) Generate Topic/Key from Json Transform

[ https://issues.apache.org/jira/browse/KAFKA-8554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16866630#comment-16866630 ] ASF GitHub Bot commented on KAFKA-8554: --- gokhansari commented on pull request #6960

[jira] [Updated] (KAFKA-8554) Generate Topic/Key from Json Transform

[ https://issues.apache.org/jira/browse/KAFKA-8554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gokhan Sari updated KAFKA-8554: --- Description: In a configurable pattern, topic and key generation is needed. This pattern could inclu

[jira] [Created] (KAFKA-8554) Generate Topic/Key from Json Transform

Gokhan Sari created KAFKA-8554: -- Summary: Generate Topic/Key from Json Transform Key: KAFKA-8554 URL: https://issues.apache.org/jira/browse/KAFKA-8554 Project: Kafka Issue Type: New Feature

[jira] [Commented] (KAFKA-8534) retention.bytes does not work as documented

[ https://issues.apache.org/jira/browse/KAFKA-8534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16866592#comment-16866592 ] Evelyn Bayes commented on KAFKA-8534: - Right still getting my head around the test su

[jira] [Resolved] (KAFKA-8488) FetchSessionHandler logging create 73 mb allocation in TLAB which could be no op

[ https://issues.apache.org/jira/browse/KAFKA-8488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash resolved KAFKA-8488. - Resolution: Fixed > FetchSessionHandler logging create 73 mb allocation in TLAB w

[jira] [Updated] (KAFKA-8553) Kafka Connect Schema Compatibility Checks for Name Changes

[ https://issues.apache.org/jira/browse/KAFKA-8553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Omer van Kloeten updated KAFKA-8553: Description: {{SchemaProjector.checkMaybeCompatible}} checks whether the Connect schema is

[jira] [Updated] (KAFKA-8553) Kafka Connect Schema Compatibility Checks for Name Changes

[ https://issues.apache.org/jira/browse/KAFKA-8553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Omer van Kloeten updated KAFKA-8553: Attachment: image-2019-06-18-14-59-54-643.png > Kafka Connect Schema Compatibility Checks f

[jira] [Updated] (KAFKA-8553) Kafka Connect Schema Compatibility Checks for Name Changes

[ https://issues.apache.org/jira/browse/KAFKA-8553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Omer van Kloeten updated KAFKA-8553: Attachment: foo1.png > Kafka Connect Schema Compatibility Checks for Name Changes > ---

[jira] [Updated] (KAFKA-8553) Kafka Connect Schema Compatibility Checks for Name Changes

[ https://issues.apache.org/jira/browse/KAFKA-8553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Omer van Kloeten updated KAFKA-8553: Description: {{SchemaProjector.checkMaybeCompatible}} checks whether the Connect schema is

[jira] [Updated] (KAFKA-8553) Kafka Connect Schema Compatibility Checks for Name Changes

[ https://issues.apache.org/jira/browse/KAFKA-8553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Omer van Kloeten updated KAFKA-8553: Description: {{SchemaProjector.checkMaybeCompatible}} checks whether the Connect schema is

[jira] [Updated] (KAFKA-8553) Kafka Connect Schema Compatibility Checks for Name Changes

[ https://issues.apache.org/jira/browse/KAFKA-8553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Omer van Kloeten updated KAFKA-8553: Attachment: (was: data-pipelinescode_data-pipelines__idea_pants-projects_a44ff4

[jira] [Updated] (KAFKA-8553) Kafka Connect Schema Compatibility Checks for Name Changes

[ https://issues.apache.org/jira/browse/KAFKA-8553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Omer van Kloeten updated KAFKA-8553: Description: {{SchemaProjector.checkMaybeCompatible}} checks whether the Connect schema is

[jira] [Updated] (KAFKA-8553) Kafka Connect Schema Compatibility Checks for Name Changes

[ https://issues.apache.org/jira/browse/KAFKA-8553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Omer van Kloeten updated KAFKA-8553: Attachment: data-pipelinescode_data-pipelines__idea_pants-projects_a44ff4d5a7b47b28

[jira] [Updated] (KAFKA-8553) Kafka Connect Schema Compatibility Checks for Name Changes

[ https://issues.apache.org/jira/browse/KAFKA-8553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Omer van Kloeten updated KAFKA-8553: Description: {{SchemaProjector.checkMaybeCompatible}} checks whether the Connect schema is

[jira] [Updated] (KAFKA-8553) Kafka Connect Schema Compatibility Checks for Name Changes

[ https://issues.apache.org/jira/browse/KAFKA-8553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Omer van Kloeten updated KAFKA-8553: Description: {{SchemaProjector.checkMaybeCompatible}} checks whether the Connect schema is

[jira] [Updated] (KAFKA-8553) Kafka Connect Schema Compatibility Checks for Name Changes

[ https://issues.apache.org/jira/browse/KAFKA-8553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Omer van Kloeten updated KAFKA-8553: Description: {{SchemaProjector.checkMaybeCompatible}} checks whether the Connect schema is

[jira] [Created] (KAFKA-8553) Kafka Connect Schema Compatibility Checks for Name Changes

Omer van Kloeten created KAFKA-8553: --- Summary: Kafka Connect Schema Compatibility Checks for Name Changes Key: KAFKA-8553 URL: https://issues.apache.org/jira/browse/KAFKA-8553 Project: Kafka

[jira] [Created] (KAFKA-8552) Use SASL authentication in ConfigCommand for connection to zookeeper

Tim Lansbergen created KAFKA-8552: - Summary: Use SASL authentication in ConfigCommand for connection to zookeeper Key: KAFKA-8552 URL: https://issues.apache.org/jira/browse/KAFKA-8552 Project: Kafka