[jira] [Updated] (KAFKA-9500) Foreign-Key Join creates an invalid topology

[ https://issues.apache.org/jira/browse/KAFKA-9500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9500: --- Priority: Blocker (was: Critical) > Foreign-Key Join creates an invalid topology > -

[jira] [Updated] (KAFKA-9500) Foreign-Key Join creates an invalid topology

[ https://issues.apache.org/jira/browse/KAFKA-9500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9500: --- Affects Version/s: (was: 2.4.1) (was: 2.5.0) > Foreign-Key Join create

[jira] [Updated] (KAFKA-9500) Foreign-Key Join creates an invalid topology

[ https://issues.apache.org/jira/browse/KAFKA-9500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9500: --- Fix Version/s: 2.4.1, 2.5.0 > Foreign-Key Join creates an invalid topology >

[jira] [Resolved] (KAFKA-9152) Improve Sensor Retrieval

[ https://issues.apache.org/jira/browse/KAFKA-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-9152. Resolution: Fixed > Improve Sensor Retrieval > - > > Key:

[jira] [Updated] (KAFKA-9152) Improve Sensor Retrieval

[ https://issues.apache.org/jira/browse/KAFKA-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9152: --- Fix Version/s: 2.5.0 > Improve Sensor Retrieval > - > > Key:

[jira] [Resolved] (KAFKA-7317) Use collections subscription for main consumer to reduce metadata

[ https://issues.apache.org/jira/browse/KAFKA-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-7317. Resolution: Fixed > Use collections subscription for main consumer to reduce metadata > ---

[jira] [Updated] (KAFKA-7317) Use collections subscription for main consumer to reduce metadata

[ https://issues.apache.org/jira/browse/KAFKA-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-7317: --- Fix Version/s: 2.5.0 > Use collections subscription for main consumer to reduce metadata > --

[jira] [Resolved] (KAFKA-8821) Avoid pattern subscription to allow for stricter ACL settings

[ https://issues.apache.org/jira/browse/KAFKA-8821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8821. Resolution: Fixed Resolved via [https://github.com/apache/kafka/pull/7969] > Avoid pattern subscri

[jira] [Updated] (KAFKA-8821) Avoid pattern subscription to allow for stricter ACL settings

[ https://issues.apache.org/jira/browse/KAFKA-8821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8821: --- Fix Version/s: 2.5.0 > Avoid pattern subscription to allow for stricter ACL settings > --

[jira] [Commented] (KAFKA-9253) Test failure : ReassignPartitionsClusterTest.shouldListMovingPartitionsThroughApi

[ https://issues.apache.org/jira/browse/KAFKA-9253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013152#comment-17013152 ] Bill Bejeck commented on KAFKA-9253: Seen again in  [https://builds.apache.org/job/ka

[jira] [Commented] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

[ https://issues.apache.org/jira/browse/KAFKA-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013044#comment-17013044 ] Bill Bejeck commented on KAFKA-9398: A PR is available for this ticket [https://githu

[jira] [Updated] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

[ https://issues.apache.org/jira/browse/KAFKA-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9398: --- Description: Kafka Streams offers the KafkaStreams.close() method when shutting down a Kafka Streams

[jira] [Updated] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

[ https://issues.apache.org/jira/browse/KAFKA-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9398: --- Description: Kafka Streams offers the KafkaStreams.close() method when shutting down a Kafka Streams

[jira] [Updated] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

[ https://issues.apache.org/jira/browse/KAFKA-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9398: --- Priority: Critical (was: Major) > Kafka Streams main thread may not exit even after close timeout ha

[jira] [Created] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

Bill Bejeck created KAFKA-9398: -- Summary: Kafka Streams main thread may not exit even after close timeout has passed Key: KAFKA-9398 URL: https://issues.apache.org/jira/browse/KAFKA-9398 Project: Kafka

[jira] [Assigned] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-4969: -- Assignee: (was: Bill Bejeck) > State-store workload-aware StreamsPartitionAssignor > -

[jira] [Updated] (KAFKA-9294) Enhance DSL Naming Guide to Include All Naming Rules

[ https://issues.apache.org/jira/browse/KAFKA-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9294: --- Description: We already have a naming guide in the docs, but we should expand it to cover how all co

[jira] [Updated] (KAFKA-9294) Enhance DSL Naming Guide to Include All Naming Rules

[ https://issues.apache.org/jira/browse/KAFKA-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9294: --- Description: We already have a naming guide in the docs, but we should expand it to cover how all co

[jira] [Commented] (KAFKA-8785) Flakey test LeaderElectionCommandTest#testPathToJsonFile

[ https://issues.apache.org/jira/browse/KAFKA-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17009899#comment-17009899 ] Bill Bejeck commented on KAFKA-8785: Observed again  [https://builds.apache.org/job/k

[jira] [Commented] (KAFKA-9311) Jumbled table content for broker config doc

[ https://issues.apache.org/jira/browse/KAFKA-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16998665#comment-16998665 ] Bill Bejeck commented on KAFKA-9311: All other table based configs have the same issu

[jira] [Assigned] (KAFKA-9273) Refactor AbstractJoinIntegrationTest and Sub-classes

[ https://issues.apache.org/jira/browse/KAFKA-9273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-9273: -- Assignee: Sujay Hegde > Refactor AbstractJoinIntegrationTest and Sub-classes > ---

[jira] [Commented] (KAFKA-9273) Refactor AbstractJoinIntegrationTest and Sub-classes

[ https://issues.apache.org/jira/browse/KAFKA-9273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997705#comment-16997705 ] Bill Bejeck commented on KAFKA-9273: Hi [~sujayopensource] Yes, feel free to start w

[jira] [Commented] (KAFKA-8025) Flaky Test RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest#shouldForwardAllDbOptionsCalls

[ https://issues.apache.org/jira/browse/KAFKA-8025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997656#comment-16997656 ] Bill Bejeck commented on KAFKA-8025: I ran this test locally 10K times and I was not

[jira] [Commented] (KAFKA-8705) NullPointerException was thrown by topology optimization when two MergeNodes have common KeyChaingingNode

[ https://issues.apache.org/jira/browse/KAFKA-8705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997490#comment-16997490 ] Bill Bejeck commented on KAFKA-8705: cherry-picked to 2.4 > NullPointerException was

[jira] [Updated] (KAFKA-8705) NullPointerException was thrown by topology optimization when two MergeNodes have common KeyChaingingNode

[ https://issues.apache.org/jira/browse/KAFKA-8705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8705: --- Fix Version/s: 2.4.1 > NullPointerException was thrown by topology optimization when two MergeNodes

[jira] [Assigned] (KAFKA-9298) Reuse of a mapped stream causes an Invalid Topology

[ https://issues.apache.org/jira/browse/KAFKA-9298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-9298: -- Assignee: Bill Bejeck > Reuse of a mapped stream causes an Invalid Topology >

[jira] [Assigned] (KAFKA-9299) Over eager optimization

[ https://issues.apache.org/jira/browse/KAFKA-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-9299: -- Assignee: Bill Bejeck > Over eager optimization > --- > >

[jira] [Updated] (KAFKA-8705) NullPointerException was thrown by topology optimization when two MergeNodes have common KeyChaingingNode

[ https://issues.apache.org/jira/browse/KAFKA-8705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8705: --- Fix Version/s: 2.3.2 2.5.0 2.2.3 > NullPointerException was thr

[jira] [Created] (KAFKA-9294) Enhance DSL Naming Guide to Include All Naming Rules

Bill Bejeck created KAFKA-9294: -- Summary: Enhance DSL Naming Guide to Include All Naming Rules Key: KAFKA-9294 URL: https://issues.apache.org/jira/browse/KAFKA-9294 Project: Kafka Issue Type: Im

[jira] [Commented] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-9274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989190#comment-16989190 ] Bill Bejeck commented on KAFKA-9274: At the risk of stating the obvious,I think we sh

[jira] [Created] (KAFKA-9273) Refactor AbstractJoinIntegrationTest and Sub-classes

Bill Bejeck created KAFKA-9273: -- Summary: Refactor AbstractJoinIntegrationTest and Sub-classes Key: KAFKA-9273 URL: https://issues.apache.org/jira/browse/KAFKA-9273 Project: Kafka Issue Type: Te

[jira] [Commented] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983665#comment-16983665 ] Bill Bejeck commented on KAFKA-9225: I don't recall the conversation either, but it m

[jira] [Resolved] (KAFKA-9086) Refactor Processor Node Streams Metrics

[ https://issues.apache.org/jira/browse/KAFKA-9086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-9086. Resolution: Fixed > Refactor Processor Node Streams Metrics > -

[jira] [Created] (KAFKA-9188) Flaky Test SslAdminClientIntegrationTest.testSynchronousAuthorizerAclUpdatesBlockRequestThreads

Bill Bejeck created KAFKA-9188: -- Summary: Flaky Test SslAdminClientIntegrationTest.testSynchronousAuthorizerAclUpdatesBlockRequestThreads Key: KAFKA-9188 URL: https://issues.apache.org/jira/browse/KAFKA-9188

[jira] [Commented] (KAFKA-9181) Flaky test kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe

[ https://issues.apache.org/jira/browse/KAFKA-9181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16974343#comment-16974343 ] Bill Bejeck commented on KAFKA-9181: Failed again in [https://builds.apache.org/job/k

[jira] [Created] (KAFKA-9187) kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

Bill Bejeck created KAFKA-9187: -- Summary: kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl Key: KAFKA-9187 URL: https://issues.apache.org/jira/browse/KAFKA-9187

[jira] [Updated] (KAFKA-9072) Add Section to Streams Developer Guide for Topology Naming (KIP-307)

[ https://issues.apache.org/jira/browse/KAFKA-9072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9072: --- Fix Version/s: (was: 2.5.0) 2.4.0 > Add Section to Streams Developer Guide for

[jira] [Created] (KAFKA-9182) Flaky Test org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest.shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosEnabled

Bill Bejeck created KAFKA-9182: -- Summary: Flaky Test org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest.shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosEnabled Key: KAFKA-9182

[jira] [Created] (KAFKA-9181) Flaky test kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe

Bill Bejeck created KAFKA-9181: -- Summary: Flaky test kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe Key: KAFKA-9181 URL: https://issues.apache.org/jira/browse/KAFKA-9181

[jira] [Resolved] (KAFKA-9072) Add Section to Streams Developer Guide for Topology Naming (KIP-307)

[ https://issues.apache.org/jira/browse/KAFKA-9072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-9072. Resolution: Fixed > Add Section to Streams Developer Guide for Topology Naming (KIP-307) >

[jira] [Reopened] (KAFKA-9011) Add KStream#flatTransform and KStream#flatTransformValues to Scala API

[ https://issues.apache.org/jira/browse/KAFKA-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reopened KAFKA-9011: There's still something left to address on this PR [https://github.com/apache/kafka/pull/7520#discussi

[jira] [Updated] (KAFKA-9011) Add KStream#flatTransform and KStream#flatTransformValues to Scala API

[ https://issues.apache.org/jira/browse/KAFKA-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9011: --- Fix Version/s: 2.5.0 > Add KStream#flatTransform and KStream#flatTransformValues to Scala API > -

[jira] [Updated] (KAFKA-9098) Name Repartition Filter, Source, and Sink Processors

[ https://issues.apache.org/jira/browse/KAFKA-9098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9098: --- Fix Version/s: 2.5.0 > Name Repartition Filter, Source, and Sink Processors > ---

[jira] [Updated] (KAFKA-8980) Refactor State-Store-level Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8980: --- Fix Version/s: 2.5.0 > Refactor State-Store-level Metrics > -- > >

[jira] [Resolved] (KAFKA-8980) Refactor State-Store-level Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8980. Resolution: Fixed > Refactor State-Store-level Metrics > -- > >

[jira] [Updated] (KAFKA-8980) Refactor State-Store-level Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8980: --- Affects Version/s: 2.5.0 > Refactor State-Store-level Metrics > -- >

[jira] [Resolved] (KAFKA-9077) System Test Failure: StreamsSimpleBenchmarkTest

[jira] [Updated] (KAFKA-8968) Refactor Task-level Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8968: --- Affects Version/s: 2.5.0 > Refactor Task-level Metrics > --- > >

[jira] [Resolved] (KAFKA-8968) Refactor Task-level Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8968. Resolution: Fixed > Refactor Task-level Metrics > --- > > K

[jira] [Updated] (KAFKA-8968) Refactor Task-level Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8968: --- Fix Version/s: 2.5.0 > Refactor Task-level Metrics > --- > >

[jira] [Created] (KAFKA-9098) Name Repartition Filter, Source, and Sink Processors

Bill Bejeck created KAFKA-9098: -- Summary: Name Repartition Filter, Source, and Sink Processors Key: KAFKA-9098 URL: https://issues.apache.org/jira/browse/KAFKA-9098 Project: Kafka Issue Type: Bu

[jira] [Created] (KAFKA-9072) Add Section to Streams Developer Guide for Topology Naming (KIP-307)

Bill Bejeck created KAFKA-9072: -- Summary: Add Section to Streams Developer Guide for Topology Naming (KIP-307) Key: KAFKA-9072 URL: https://issues.apache.org/jira/browse/KAFKA-9072 Project: Kafka

[jira] [Comment Edited] (KAFKA-9053) AssignmentInfo#encode hardcodes the LATEST_SUPPORTED_VERSION

[ https://issues.apache.org/jira/browse/KAFKA-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16954154#comment-16954154 ] Bill Bejeck edited comment on KAFKA-9053 at 10/17/19 10:56 PM:

[jira] [Commented] (KAFKA-9053) AssignmentInfo#encode hardcodes the LATEST_SUPPORTED_VERSION

[ https://issues.apache.org/jira/browse/KAFKA-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16954154#comment-16954154 ] Bill Bejeck commented on KAFKA-9053: cherry-picked to 2.2 > AssignmentInfo#encode ha

[jira] [Resolved] (KAFKA-9053) AssignmentInfo#encode hardcodes the LATEST_SUPPORTED_VERSION

[ https://issues.apache.org/jira/browse/KAFKA-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-9053. Resolution: Fixed > AssignmentInfo#encode hardcodes the LATEST_SUPPORTED_VERSION > ---

[jira] [Commented] (KAFKA-9020) Streams sub-topologies should be sorted by sink -> source relationship

[ https://issues.apache.org/jira/browse/KAFKA-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16951334#comment-16951334 ] Bill Bejeck commented on KAFKA-9020: cherry-picked to 2.4 > Streams sub-topologies s

[jira] [Created] (KAFKA-9019) Flaky Test kafka.api.SslAdminClientIntegrationTest.testCreateTopicsResponseMetadataAndConfig

Bill Bejeck created KAFKA-9019: -- Summary: Flaky Test kafka.api.SslAdminClientIntegrationTest.testCreateTopicsResponseMetadataAndConfig Key: KAFKA-9019 URL: https://issues.apache.org/jira/browse/KAFKA-9019

[jira] [Created] (KAFKA-9009) Flaky Test kafka.integration.MetricsDuringTopicCreationDeletionTest.testMetricsDuringTopicCreateDelete

Bill Bejeck created KAFKA-9009: -- Summary: Flaky Test kafka.integration.MetricsDuringTopicCreationDeletionTest.testMetricsDuringTopicCreateDelete Key: KAFKA-9009 URL: https://issues.apache.org/jira/browse/KAFKA-9009

[jira] [Created] (KAFKA-9008) Flaky Test kafka.api.SaslSslAdminClientIntegrationTest.testDescribeConfigsForTopic

Bill Bejeck created KAFKA-9008: -- Summary: Flaky Test kafka.api.SaslSslAdminClientIntegrationTest.testDescribeConfigsForTopic Key: KAFKA-9008 URL: https://issues.apache.org/jira/browse/KAFKA-9008 Project:

[jira] [Created] (KAFKA-9007) Flaky Test kafka.api.SaslPlaintextConsumerTest.testCoordinatorFailover

Bill Bejeck created KAFKA-9007: -- Summary: Flaky Test kafka.api.SaslPlaintextConsumerTest.testCoordinatorFailover Key: KAFKA-9007 URL: https://issues.apache.org/jira/browse/KAFKA-9007 Project: Kafka

[jira] [Reopened] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reopened KAFKA-8460: Test failed again in  [https://builds.apache.org/job/kafka-pr-jdk8-scala2.11/25644/testReport/junit/kaf

[jira] [Commented] (KAFKA-8909) Flaky Test ReassignPartitionsClusterTest#shouldPerformMultipleReassignmentOperationsOverVariousTopics

[ https://issues.apache.org/jira/browse/KAFKA-8909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947824#comment-16947824 ] Bill Bejeck commented on KAFKA-8909: seen again in  [https://builds.apache.org/job/ka

[jira] [Updated] (KAFKA-9006) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFilterOutRapidlyChangingForeignKeyValues

[ https://issues.apache.org/jira/browse/KAFKA-9006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9006: --- Issue Type: Test (was: Improvement) > Flaky Test > KTableKTableForeignKeyJoinIntegrationTest.doLeft

[jira] [Created] (KAFKA-9006) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFilterOutRapidlyChangingForeignKeyValues

Bill Bejeck created KAFKA-9006: -- Summary: Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFilterOutRapidlyChangingForeignKeyValues Key: KAFKA-9006 URL: https://issues.apache.org/jira/browse/KAFKA-9006

[jira] [Resolved] (KAFKA-8944) Compiler Warning

[ https://issues.apache.org/jira/browse/KAFKA-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8944. Resolution: Fixed > Compiler Warning > > > Key: KAFKA-8944 >

[jira] [Updated] (KAFKA-9002) org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-9002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9002: --- Component/s: unit tests > org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMa

[jira] [Updated] (KAFKA-9002) Flaky Test org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-9002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9002: --- Summary: Flaky Test org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesT

[jira] [Updated] (KAFKA-9002) org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-9002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9002: --- Issue Type: Bug (was: Improvement) > org.apache.kafka.streams.integration.RegexSourceIntegrationTest

[jira] [Created] (KAFKA-9002) org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenCreated

Bill Bejeck created KAFKA-9002: -- Summary: org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenCreated Key: KAFKA-9002 URL: https://issues.apache.org/jira/browse/KAFKA-9002

[jira] [Resolved] (KAFKA-3705) Support non-key joining in KTable

[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-3705. Resolution: Fixed > Support non-key joining in KTable > - > >

[jira] [Updated] (KAFKA-3705) Support non-key joining in KTable

[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-3705: --- Fix Version/s: 2.4.0 > Support non-key joining in KTable > - > >

[jira] [Updated] (KAFKA-8911) Implicit TimeWindowedSerde creates Serde with null inner serializer

[ https://issues.apache.org/jira/browse/KAFKA-8911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8911: --- Fix Version/s: 2.4.0 > Implicit TimeWindowedSerde creates Serde with null inner serializer >

[jira] [Reopened] (KAFKA-8807) Flaky Test GlobalThreadShutDownOrderTest.shouldFinishGlobalStoreOperationOnShutDown

[ https://issues.apache.org/jira/browse/KAFKA-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reopened KAFKA-8807: Reopening this as I am going to refactor the test to check that close is only called once during shutd

[jira] [Resolved] (KAFKA-6958) Allow to define custom processor names with KStreams DSL

[ https://issues.apache.org/jira/browse/KAFKA-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-6958. Resolution: Fixed Thanks again [~fhussonnois] for your hard work and persistence in seeing this va

[jira] [Updated] (KAFKA-6958) Allow to define custom processor names with KStreams DSL

[ https://issues.apache.org/jira/browse/KAFKA-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-6958: --- Fix Version/s: 2.4.0 > Allow to define custom processor names with KStreams DSL > ---

[jira] [Updated] (KAFKA-8859) Refactor Cache-level Streams Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8859: --- Affects Version/s: 2.4.0 > Refactor Cache-level Streams Metrics > ---

[jira] [Updated] (KAFKA-8859) Refactor Cache-level Streams Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8859: --- Fix Version/s: 2.4.0 > Refactor Cache-level Streams Metrics > >

[jira] [Resolved] (KAFKA-8859) Refactor Cache-level Streams Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8859. Resolution: Fixed > Refactor Cache-level Streams Metrics > > >

[jira] [Resolved] (KAFKA-8878) Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAndEOS

[ https://issues.apache.org/jira/browse/KAFKA-8878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8878. Resolution: Fixed > Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAndEOS >

[jira] [Updated] (KAFKA-8878) Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAndEOS

[ https://issues.apache.org/jira/browse/KAFKA-8878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8878: --- Fix Version/s: 2.4.0 > Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAndEOS

[jira] [Updated] (KAFKA-8878) Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAndEOS

[ https://issues.apache.org/jira/browse/KAFKA-8878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8878: --- Affects Version/s: 2.4.0 > Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAnd

[jira] [Updated] (KAFKA-8861) Fix flaky RegexSourceIntegrationTest.testMultipleConsumersCanReadFromPartitionedTopic

[ https://issues.apache.org/jira/browse/KAFKA-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8861: --- Fix Version/s: 2.3.1 2.4.0 2.2.2 2.1.2

[jira] [Updated] (KAFKA-8861) Fix flaky RegexSourceIntegrationTest.testMultipleConsumersCanReadFromPartitionedTopic

[ https://issues.apache.org/jira/browse/KAFKA-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8861: --- Affects Version/s: 2.4.0 2.0.1 2.1.1

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16919908#comment-16919908 ] Bill Bejeck commented on KAFKA-8803: [~rocketraman] I think what happened is that the

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16919856#comment-16919856 ] Bill Bejeck commented on KAFKA-8803: [~rocketraman], I'm glad to hear that setting th

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16918868#comment-16918868 ] Bill Bejeck commented on KAFKA-8803: [~rocketraman] I think what is going is when th

[jira] [Comment Edited] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16918868#comment-16918868 ] Bill Bejeck edited comment on KAFKA-8803 at 8/29/19 6:44 PM: -

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16918675#comment-16918675 ] Bill Bejeck commented on KAFKA-8803: [~rocketraman] sorry I've been tied up with some

[jira] [Commented] (KAFKA-8737) TaskMigrated Exception while rebalancing kafka streams

[ https://issues.apache.org/jira/browse/KAFKA-8737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911651#comment-16911651 ] Bill Bejeck commented on KAFKA-8737: I tested this on trunk with an existing unit tes

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911429#comment-16911429 ] Bill Bejeck commented on KAFKA-8803: Thanks for clarifying! > Stream will not start

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911395#comment-16911395 ] Bill Bejeck commented on KAFKA-8803: Thanks, [~rocketraman] I'll take a look over the

[jira] [Assigned] (KAFKA-8807) Flaky Test GlobalThreadShutDownOrderTest.shouldFinishGlobalStoreOperationOnShutDown

[ https://issues.apache.org/jira/browse/KAFKA-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8807: -- Assignee: Bill Bejeck > Flaky Test > GlobalThreadShutDownOrderTest.shouldFinishGlobalStoreOpe

[jira] [Assigned] (KAFKA-8802) ConcurrentSkipListMap shows performance regression in cache and in-memory store

[ https://issues.apache.org/jira/browse/KAFKA-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8802: -- Assignee: Sophie Blee-Goldman > ConcurrentSkipListMap shows performance regression in cache an

[jira] [Assigned] (KAFKA-8737) TaskMigrated Exception while rebalancing kafka streams

[ https://issues.apache.org/jira/browse/KAFKA-8737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8737: -- Assignee: Bill Bejeck > TaskMigrated Exception while rebalancing kafka streams > -

[jira] [Commented] (KAFKA-8737) TaskMigrated Exception while rebalancing kafka streams

[ https://issues.apache.org/jira/browse/KAFKA-8737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16908447#comment-16908447 ] Bill Bejeck commented on KAFKA-8737: [~abhinavisin] thanks for reporting this.  > Ta

[jira] [Assigned] (KAFKA-8793) StickyTaskAssignor throws java.lang.ArithmeticException

[ https://issues.apache.org/jira/browse/KAFKA-8793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8793: -- Assignee: Bill Bejeck > StickyTaskAssignor throws java.lang.ArithmeticException >

[jira] [Commented] (KAFKA-8736) Performance: ThreadCache uses size() for empty cache check

[ https://issues.apache.org/jira/browse/KAFKA-8736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16906664#comment-16906664 ] Bill Bejeck commented on KAFKA-8736: Cherry-picked [https://github.com/apache/kafka/p

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

[ https://issues.apache.org/jira/browse/KAFKA-8558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16905380#comment-16905380 ] Bill Bejeck commented on KAFKA-8558: [~apurva] > Bill, where are we with fixing this

[jira] [Created] (KAFKA-8744) Add Support to Scala API for KIP-307

Bill Bejeck created KAFKA-8744: -- Summary: Add Support to Scala API for KIP-307 Key: KAFKA-8744 URL: https://issues.apache.org/jira/browse/KAFKA-8744 Project: Kafka Issue Type: Task Com

[jira] [Comment Edited] (KAFKA-8731) InMemorySessionStore throws NullPointerException on startup

[ https://issues.apache.org/jira/browse/KAFKA-8731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16897546#comment-16897546 ] Bill Bejeck edited comment on KAFKA-8731 at 7/31/19 9:33 PM: -

<    1   2   3   4   5   6   7   8   >