[jira] [Commented] (KAFKA-8620) Race condition in StreamThread state change

[ https://issues.apache.org/jira/browse/KAFKA-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882623#comment-16882623 ] ASF GitHub Bot commented on KAFKA-8620: --- ijuma commented on pull request #7021: KAFKA-8620: fix NPE

[jira] [Commented] (KAFKA-8620) Race condition in StreamThread state change

[ https://issues.apache.org/jira/browse/KAFKA-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882624#comment-16882624 ] ASF GitHub Bot commented on KAFKA-8620: --- abbccdda commented on pull request #7021: KAFKA-8620: fix

[jira] [Commented] (KAFKA-8653) Regression in JoinGroup v0 rebalance timeout handling

[ https://issues.apache.org/jira/browse/KAFKA-8653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882576#comment-16882576 ] ASF GitHub Bot commented on KAFKA-8653: --- hachikuji commented on pull request #7072: KAFKA-8653;

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882573#comment-16882573 ] Brian Putt commented on KAFKA-6520: --- Any updates on this? > When a Kafka Stream can't communicate with

[jira] [Assigned] (KAFKA-8653) Regression in JoinGroup v0 rebalance timeout handling

[ https://issues.apache.org/jira/browse/KAFKA-8653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-8653: -- Assignee: Jason Gustafson > Regression in JoinGroup v0 rebalance timeout handling >

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882520#comment-16882520 ] Matthias J. Sax commented on KAFKA-4212: I see. IMHO, we should not have a parameter for

[jira] [Created] (KAFKA-8653) Regression in JoinGroup v0 rebalance timeout handling

Jason Gustafson created KAFKA-8653: -- Summary: Regression in JoinGroup v0 rebalance timeout handling Key: KAFKA-8653 URL: https://issues.apache.org/jira/browse/KAFKA-8653 Project: Kafka

[jira] [Assigned] (KAFKA-7614) Fix scalac warnings and enable warnings as errors

[ https://issues.apache.org/jira/browse/KAFKA-7614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tu Tran reassigned KAFKA-7614: -- Assignee: Tu Tran > Fix scalac warnings and enable warnings as errors >

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882516#comment-16882516 ] Sophie Blee-Goldman commented on KAFKA-4212: Agreed, this wouldn't be possible within the

[jira] [Resolved] (KAFKA-8636) Document behavior change for static members with `max.poll.interval.ms`

[ https://issues.apache.org/jira/browse/KAFKA-8636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8636. Resolution: Fixed > Document behavior change for static members with `max.poll.interval.ms` >

[jira] [Commented] (KAFKA-8570) Downconversion could fail when log contains out of order message formats

[ https://issues.apache.org/jira/browse/KAFKA-8570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882488#comment-16882488 ] ASF GitHub Bot commented on KAFKA-8570: --- dhruvilshah3 commented on pull request #7071: KAFKA-8570:

[jira] [Commented] (KAFKA-8424) Replace ListGroups request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-8424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882469#comment-16882469 ] ASF GitHub Bot commented on KAFKA-8424: --- cmccabe commented on pull request #6805: KAFKA-8424:

[jira] [Commented] (KAFKA-7157) Connect TimestampConverter SMT doesn't handle null values

[ https://issues.apache.org/jira/browse/KAFKA-7157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882464#comment-16882464 ] ASF GitHub Bot commented on KAFKA-7157: --- rayokota commented on pull request #7070: KAFKA-7157: Fix

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882449#comment-16882449 ] James Ritt commented on KAFKA-4212: --- Thanks [~ableegoldman] & [~mjsax]! So I took a look at

[jira] [Created] (KAFKA-8652) Jenkins stop triggering tests for prs since 07/10

Boyang Chen created KAFKA-8652: -- Summary: Jenkins stop triggering tests for prs since 07/10 Key: KAFKA-8652 URL: https://issues.apache.org/jira/browse/KAFKA-8652 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-8571) Not complete delayed produce requests when processing StopReplicaRequest causing high produce latency for acks=all

[ https://issues.apache.org/jira/browse/KAFKA-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882357#comment-16882357 ] ASF GitHub Bot commented on KAFKA-8571: --- kidkun commented on pull request #7069: KAFKA-8571: Clean

[jira] [Commented] (KAFKA-8651) Add a #branch overload that takes a Map of predicate names to predicates

[ https://issues.apache.org/jira/browse/KAFKA-8651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882312#comment-16882312 ] Matthias J. Sax commented on KAFKA-8651: Seems to duplicate 

[jira] [Commented] (KAFKA-8650) Streams does not work as expected with auto.offset.reset=none

[ https://issues.apache.org/jira/browse/KAFKA-8650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882307#comment-16882307 ] Matthias J. Sax commented on KAFKA-8650: Thanks for creating this ticket. Sounds reasonable to

[jira] [Updated] (KAFKA-8651) Add a #branch overload that takes a Map of predicate names to predicates

[ https://issues.apache.org/jira/browse/KAFKA-8651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-8651: - Description: A map can be a more natural way to work with passing in predicates and extracting

[jira] [Commented] (KAFKA-8651) Add a #branch overload that takes a Map of predicate names to predicates

[ https://issues.apache.org/jira/browse/KAFKA-8651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882296#comment-16882296 ] ASF GitHub Bot commented on KAFKA-8651: --- astubbs commented on pull request #7068: KAFKA-8651: Add

[jira] [Created] (KAFKA-8651) Add a #branch overload that takes a Map of predicate names to predicates

Antony Stubbs created KAFKA-8651: Summary: Add a #branch overload that takes a Map of predicate names to predicates Key: KAFKA-8651 URL: https://issues.apache.org/jira/browse/KAFKA-8651 Project:

[jira] [Updated] (KAFKA-8650) Streams does not work as expected with auto.offset.reset=none

[ https://issues.apache.org/jira/browse/KAFKA-8650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8650: --- Labels: needs-kip (was: ) > Streams does not work as expected with auto.offset.reset=none >

[jira] [Commented] (KAFKA-8634) Update ZooKeeper to 3.5.5

[ https://issues.apache.org/jira/browse/KAFKA-8634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882249#comment-16882249 ] ASF GitHub Bot commented on KAFKA-8634: --- ijuma commented on pull request #6802: KAFKA-8634: Update

[jira] [Commented] (KAFKA-8648) Console tools should fail fast if an unrecognised --property is passed in

[ https://issues.apache.org/jira/browse/KAFKA-8648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882248#comment-16882248 ] ASF GitHub Bot commented on KAFKA-8648: --- astubbs commented on pull request #7066: KAFKA-8648: Throw

[jira] [Created] (KAFKA-8650) Streams does not work as expected with auto.offset.reset=none

Raman Gupta created KAFKA-8650: -- Summary: Streams does not work as expected with auto.offset.reset=none Key: KAFKA-8650 URL: https://issues.apache.org/jira/browse/KAFKA-8650 Project: Kafka

[jira] [Comment Edited] (KAFKA-8367) Non-heap memory leak in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880745#comment-16880745 ] Sophie Blee-Goldman edited comment on KAFKA-8367 at 7/10/19 4:26 PM: -

[jira] [Created] (KAFKA-8649) Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0

Suyash Garg created KAFKA-8649: -- Summary: Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0 Key: KAFKA-8649 URL: https://issues.apache.org/jira/browse/KAFKA-8649 Project: Kafka

[jira] [Updated] (KAFKA-8637) WriteBatch objects leak off-heap memory

[ https://issues.apache.org/jira/browse/KAFKA-8637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8637: --- Affects Version/s: 2.2.0 2.3.0 Priority: Blocker

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

[ https://issues.apache.org/jira/browse/KAFKA-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881972#comment-16881972 ] Bruno Cadonna commented on KAFKA-8555: -- Related pull requests: *

[jira] [Updated] (KAFKA-8648) Console tools should fail fast if an unrecognised --property is passed in

[ https://issues.apache.org/jira/browse/KAFKA-8648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-8648: - Description: Some people don't realise that the --property for the console producer and

[jira] [Updated] (KAFKA-8647) Add consumer-props option to match producer-props for kafka-consumer-perf-test

[ https://issues.apache.org/jira/browse/KAFKA-8647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-8647: - Description: kafka-consumer-perf-test is missing a consumer-props option like the producer perf

[jira] [Updated] (KAFKA-8648) Console tools should fail fast if an unrecognised --property is passed in

[ https://issues.apache.org/jira/browse/KAFKA-8648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-8648: - Summary: Console tools should fail fast if an unrecognised --property is passed in (was:

[jira] [Updated] (KAFKA-8647) Add consumer-props option to match producer-props for kafka-consumer-perf-test

[ https://issues.apache.org/jira/browse/KAFKA-8647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-8647: - Summary: Add consumer-props option to match producer-props for kafka-consumer-perf-test (was:

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

[ https://issues.apache.org/jira/browse/KAFKA-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881926#comment-16881926 ] Bruno Cadonna commented on KAFKA-8555: -- https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/141

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

[ https://issues.apache.org/jira/browse/KAFKA-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8555: - Attachment: log-job141.txt > Flaky test ExampleConnectIntegrationTest#testSourceConnector >

[jira] [Commented] (KAFKA-7937) Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup

[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881924#comment-16881924 ] Bruno Cadonna commented on KAFKA-7937: -- https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/6122

[jira] [Updated] (KAFKA-7937) Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup

[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-7937: - Attachment: log-job6122.txt > Flaky Test

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

[ https://issues.apache.org/jira/browse/KAFKA-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881907#comment-16881907 ] Bruno Cadonna commented on KAFKA-8555: -- https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/139

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

[ https://issues.apache.org/jira/browse/KAFKA-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8555: - Attachment: log-job139.txt > Flaky test ExampleConnectIntegrationTest#testSourceConnector >

[jira] [Created] (KAFKA-8648) Console tools should fail fast if an unrecognised option is passed in

Antony Stubbs created KAFKA-8648: Summary: Console tools should fail fast if an unrecognised option is passed in Key: KAFKA-8648 URL: https://issues.apache.org/jira/browse/KAFKA-8648 Project: Kafka

[jira] [Created] (KAFKA-8647) Add consumer-props option to match producer-props for console consumer

Antony Stubbs created KAFKA-8647: Summary: Add consumer-props option to match producer-props for console consumer Key: KAFKA-8647 URL: https://issues.apache.org/jira/browse/KAFKA-8647 Project: Kafka

[jira] [Updated] (KAFKA-8646) Materialized.withLoggingDisabled() does not disable changelog topics creation

[ https://issues.apache.org/jira/browse/KAFKA-8646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jmhostalet updated KAFKA-8646: -- Description: I have a cluster with 3 brokers running version 0.11 My kafka-streams app was using

[jira] [Updated] (KAFKA-8646) Materialized.withLoggingDisabled() does not disable changelog topics creation

[ https://issues.apache.org/jira/browse/KAFKA-8646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jmhostalet updated KAFKA-8646: -- Summary: Materialized.withLoggingDisabled() does not disable changelog topics creation (was:

[jira] [Created] (KAFKA-8646) Materialized.withLoggingDisabled() does not disable the changelog topics creation

jmhostalet created KAFKA-8646: - Summary: Materialized.withLoggingDisabled() does not disable the changelog topics creation Key: KAFKA-8646 URL: https://issues.apache.org/jira/browse/KAFKA-8646 Project:

[jira] [Commented] (KAFKA-8636) Document behavior change for static members with `max.poll.interval.ms`

[ https://issues.apache.org/jira/browse/KAFKA-8636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881853#comment-16881853 ] ASF GitHub Bot commented on KAFKA-8636: --- hachikuji commented on pull request #7048: KAFKA-8636: add

[jira] [Commented] (KAFKA-8610) Don't use /bin/bash in scripts

[ https://issues.apache.org/jira/browse/KAFKA-8610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881834#comment-16881834 ] Lee Dongjin commented on KAFKA-8610: Hi [~llamahunter], Here is the draft fix. Please have a test

[jira] [Assigned] (KAFKA-8610) Don't use /bin/bash in scripts

[ https://issues.apache.org/jira/browse/KAFKA-8610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-8610: -- Assignee: Lee Dongjin > Don't use /bin/bash in scripts > -- > >

[jira] [Commented] (KAFKA-8610) Don't use /bin/bash in scripts

[ https://issues.apache.org/jira/browse/KAFKA-8610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881828#comment-16881828 ] ASF GitHub Bot commented on KAFKA-8610: --- dongjinleekr commented on pull request #7063: KAFKA-8610:

[jira] [Created] (KAFKA-8645) Flakey test SaslSslAdminClientIntegrationTest#testElectUncleanLeadersAndNoop

Boyang Chen created KAFKA-8645: -- Summary: Flakey test SaslSslAdminClientIntegrationTest#testElectUncleanLeadersAndNoop Key: KAFKA-8645 URL: https://issues.apache.org/jira/browse/KAFKA-8645 Project: