[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=16998665#comment-16998665 ] Bill Bejeck commented on KAFKA-9311: All other table based configs have the same issue. > Jumbled

[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=16997705#comment-16997705 ] Bill Bejeck commented on KAFKA-9273: Hi [~sujayopensource] Yes, feel free to start working on this

[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=16997656#comment-16997656 ] Bill Bejeck commented on KAFKA-8025: I ran this test locally 10K times and I was not able to get a

[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=16997490#comment-16997490 ] Bill Bejeck commented on KAFKA-8705: cherry-picked to 2.4 > NullPointerException was thrown by

[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

[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:

[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=16989190#comment-16989190 ] Bill Bejeck commented on KAFKA-9274: At the risk of stating the obvious,I think we should have a

[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:

[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=16983665#comment-16983665 ] Bill Bejeck commented on KAFKA-9225: I don't recall the conversation either, but it makes sense to

[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=16974343#comment-16974343 ] Bill Bejeck commented on KAFKA-9181: Failed again in 

[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

[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] [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

[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 > --- > >

[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:

[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=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=16954154#comment-16954154 ] Bill Bejeck commented on KAFKA-9053: cherry-picked to 2.2 > AssignmentInfo#encode hardcodes the

[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=16951334#comment-16951334 ] Bill Bejeck commented on KAFKA-9020: cherry-picked to 2.4 > Streams sub-topologies should be sorted

[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

[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 

[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=16947824#comment-16947824 ] Bill Bejeck commented on KAFKA-8909: seen again in 

[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 >

[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 >

[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

[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

[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

[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

[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=16919908#comment-16919908 ] Bill Bejeck commented on KAFKA-8803: [~rocketraman] I think what happened is that the brokers fully

[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=16919856#comment-16919856 ] Bill Bejeck commented on KAFKA-8803: [~rocketraman], I'm glad to hear that setting the config helped. 

[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=16918868#comment-16918868 ] Bill Bejeck commented on KAFKA-8803: [~rocketraman] I think what is going is when the broker is

[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=16918868#comment-16918868 ] Bill Bejeck edited comment on KAFKA-8803 at 8/29/19 6:44 PM: - [~rocketraman]

[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=16918675#comment-16918675 ] Bill Bejeck commented on KAFKA-8803: [~rocketraman] sorry I've been tied up with some other things,

[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=16911651#comment-16911651 ] Bill Bejeck commented on KAFKA-8737: I tested this on trunk with an existing unit test and it failed

[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=16911429#comment-16911429 ] Bill Bejeck commented on KAFKA-8803: Thanks for clarifying! > Stream will not start due to

[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=16911395#comment-16911395 ] Bill Bejeck commented on KAFKA-8803: Thanks, [~rocketraman] I'll take a look over the logs.   BTW

[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 >

[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

[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=16908447#comment-16908447 ] Bill Bejeck commented on KAFKA-8737: [~abhinavisin] thanks for reporting this.  > TaskMigrated

[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=16906664#comment-16906664 ] Bill Bejeck commented on KAFKA-8736: Cherry-picked [https://github.com/apache/kafka/pull/7177] into

[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=16905380#comment-16905380 ] Bill Bejeck commented on KAFKA-8558: [~apurva] > Bill, where are we with fixing this? I've started

[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=16897546#comment-16897546 ] Bill Bejeck edited comment on KAFKA-8731 at 7/31/19 9:33 PM: - merged to trunk

[jira] [Commented] (KAFKA-8260) Flaky test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-8260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897416#comment-16897416 ] Bill Bejeck commented on KAFKA-8260: Failed again on 

[jira] [Commented] (KAFKA-8541) Flakey test LeaderElectionCommandTest#testTopicPartition

[ https://issues.apache.org/jira/browse/KAFKA-8541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897410#comment-16897410 ] Bill Bejeck commented on KAFKA-8541: Failed again on 

[jira] [Comment Edited] (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=16891887#comment-16891887 ] Bill Bejeck edited comment on KAFKA-8705 at 7/24/19 2:12 PM: - [~hiro116s] 

[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=16891887#comment-16891887 ] Bill Bejeck commented on KAFKA-8705: [~hiro116s] thanks for reporting this, we'll take a look into

[jira] [Assigned] (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 reassigned KAFKA-8705: -- Assignee: Bill Bejeck > NullPointerException was thrown by topology optimization when two

[jira] [Created] (KAFKA-8692) Transient failure in kafka.api.SaslScramSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

Bill Bejeck created KAFKA-8692: -- Summary: Transient failure in kafka.api.SaslScramSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl Key: KAFKA-8692 URL:

[jira] [Resolved] (KAFKA-8689) Cannot Name Join State Store Topics

[ https://issues.apache.org/jira/browse/KAFKA-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8689. Resolution: Duplicate Duplicate of https://issues.apache.org/jira/browse/KAFKA-8558 > Cannot Name

[jira] [Commented] (KAFKA-8689) Cannot Name Join State Store Topics

[ https://issues.apache.org/jira/browse/KAFKA-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16888974#comment-16888974 ] Bill Bejeck commented on KAFKA-8689: Hi [~msmsimondean] Thanks for filing a Jira on this item and

[jira] [Updated] (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:all-tabpanel ] Bill Bejeck updated KAFKA-8558: --- Description: To prevent a topology incompatibility with the release of 2.4 and the naming of Join

[jira] [Resolved] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

[ https://issues.apache.org/jira/browse/KAFKA-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8602. Resolution: Fixed > StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic >

[jira] [Created] (KAFKA-8666) Improve Documentation on usage of Materialized config object

Bill Bejeck created KAFKA-8666: -- Summary: Improve Documentation on usage of Materialized config object Key: KAFKA-8666 URL: https://issues.apache.org/jira/browse/KAFKA-8666 Project: Kafka

[jira] [Commented] (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:comment-tabpanel=16885391#comment-16885391 ] Bill Bejeck commented on KAFKA-8646: Thanks again [~jmhostalet] for reporting this. After looking

[jira] [Commented] (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:comment-tabpanel=16883951#comment-16883951 ] Bill Bejeck commented on KAFKA-8646: [~jmhostalet] thanks for reporting this, we'll look into this.

[jira] [Assigned] (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 ] Bill Bejeck reassigned KAFKA-8646: -- Assignee: Bill Bejeck > Materialized.withLoggingDisabled() does not disable changelog topics

[jira] [Commented] (KAFKA-8198) KStreams testing docs use non-existent method "pipe"

[ https://issues.apache.org/jira/browse/KAFKA-8198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883908#comment-16883908 ] Bill Bejeck commented on KAFKA-8198: cherry-picked to 2.3, 2.2, 2.1, 2.0 and 1.1 > KStreams testing

[jira] [Updated] (KAFKA-8198) KStreams testing docs use non-existent method "pipe"

[ https://issues.apache.org/jira/browse/KAFKA-8198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8198: --- Fix Version/s: 1.1.0 2.0.0 2.1.0 2.2.0

[jira] [Assigned] (KAFKA-8198) KStreams testing docs use non-existent method "pipe"

[ https://issues.apache.org/jira/browse/KAFKA-8198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8198: -- Assignee: Slim Ouertani (was: Victoria Bialas) > KStreams testing docs use non-existent

[jira] [Resolved] (KAFKA-8198) KStreams testing docs use non-existent method "pipe"

[ https://issues.apache.org/jira/browse/KAFKA-8198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8198. Resolution: Fixed > KStreams testing docs use non-existent method "pipe" >

[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=16883862#comment-16883862 ] Bill Bejeck commented on KAFKA-8555: Seen again 

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883856#comment-16883856 ] Bill Bejeck commented on KAFKA-5998: cherry-picked to 2.3 and 2.2 > /.checkpoint.tmp Not found

[jira] [Updated] (KAFKA-5998) /.checkpoint.tmp Not found exception

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

[jira] [Resolved] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-5998. Resolution: Fixed > /.checkpoint.tmp Not found exception > >

<    1   2   3   4   5   6   7   8   >