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

[ https://issues.apache.org/jira/browse/KAFKA-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Kokachev updated KAFKA-9011: - Description: Part of KIP-313:  [https://cwiki.apache.org/confluence/display/KAFKA/KIP-313%3A+Add+

[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=16948276#comment-16948276 ] Bruno Cadonna commented on KAFKA-8909: -- failed again in https://builds.apache.org/jo

[jira] [Commented] (KAFKA-9005) Kafka stream: “TopicAuthorizationException: Not authorized to access topics” for an internal state store

[ https://issues.apache.org/jira/browse/KAFKA-9005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948275#comment-16948275 ] Arnaud Villevieille commented on KAFKA-9005: [~cadonna] Thankyou for your he

[jira] [Created] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

Bruno Cadonna created KAFKA-9013: Summary: Flaky Test MirrorConnectorsIntegrationTest#testReplication Key: KAFKA-9013 URL: https://issues.apache.org/jira/browse/KAFKA-9013 Project: Kafka Issu

[jira] [Updated] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9013: - Description: h1. Stacktrace: {code:java} java.lang.AssertionError: Condition not met within time

[jira] [Resolved] (KAFKA-9005) Kafka stream: “TopicAuthorizationException: Not authorized to access topics” for an internal state store

[ https://issues.apache.org/jira/browse/KAFKA-9005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9005. -- Resolution: Not A Bug > Kafka stream: “TopicAuthorizationException: Not authorized to access to

[jira] [Commented] (KAFKA-9000) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFromRightThenDeleteRightEntity

[ https://issues.apache.org/jira/browse/KAFKA-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948287#comment-16948287 ] Bruno Cadonna commented on KAFKA-9000: -- Failed in https://builds.apache.org/job/kafk

[jira] [Commented] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948291#comment-16948291 ] Bruno Cadonna commented on KAFKA-8677: -- https://builds.apache.org/job/kafka-pr-jdk8-

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

[ https://issues.apache.org/jira/browse/KAFKA-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948297#comment-16948297 ] Bruno Cadonna commented on KAFKA-9011: -- [~akokachev], Thank you for the ticket. I gu

[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 ] Alex Kokachev updated KAFKA-9011: - Summary: Add KStream#flatTransform and KStream#flatTransformValues to Scala API (was: Add KStrea

[jira] [Commented] (KAFKA-7273) Converters should have access to headers.

[ https://issues.apache.org/jira/browse/KAFKA-7273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948354#comment-16948354 ] Gunnar Morling commented on KAFKA-7273: --- Hey [~rhauch], [~jcustenborder], just came

[jira] [Comment Edited] (KAFKA-7273) Converters should have access to headers.

[ https://issues.apache.org/jira/browse/KAFKA-7273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948354#comment-16948354 ] Gunnar Morling edited comment on KAFKA-7273 at 10/10/19 9:46 AM: --

[jira] [Commented] (KAFKA-9012) OutOfOrderSequenceException occurred, all stream stopped consuming

[ https://issues.apache.org/jira/browse/KAFKA-9012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948375#comment-16948375 ] panpan.liu commented on KAFKA-9012: --- OK， I will try  > OutOfOrderSequenceException occ

[jira] [Commented] (KAFKA-9012) OutOfOrderSequenceException occurred, all stream stopped consuming

[ https://issues.apache.org/jira/browse/KAFKA-9012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948392#comment-16948392 ] panpan.liu commented on KAFKA-9012: --- It is  difficult to reproduce this exception. How

[jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948413#comment-16948413 ] Ashish Surana commented on KAFKA-7149: -- I think along with these encoding changes we

[jira] [Created] (KAFKA-9014) AssertionError thrown by SourceRecordWriteCounter when SourceTask.poll returns an empty list

Richard Wise created KAFKA-9014: --- Summary: AssertionError thrown by SourceRecordWriteCounter when SourceTask.poll returns an empty list Key: KAFKA-9014 URL: https://issues.apache.org/jira/browse/KAFKA-9014

[jira] [Commented] (KAFKA-8897) Increase Version of RocksDB

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

[jira] [Commented] (KAFKA-9000) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFromRightThenDeleteRightEntity

[ https://issues.apache.org/jira/browse/KAFKA-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948459#comment-16948459 ] Bruno Cadonna commented on KAFKA-9000: -- Failed in https://builds.apache.org/job/kaf

[jira] [Created] (KAFKA-9015) Unify metric names

Viktor Somogyi-Vass created KAFKA-9015: -- Summary: Unify metric names Key: KAFKA-9015 URL: https://issues.apache.org/jira/browse/KAFKA-9015 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-9016) Warn when log dir stopped serving replicas

Viktor Somogyi-Vass created KAFKA-9016: -- Summary: Warn when log dir stopped serving replicas Key: KAFKA-9016 URL: https://issues.apache.org/jira/browse/KAFKA-9016 Project: Kafka Issue Ty

[jira] [Updated] (KAFKA-9015) Unify metric names

[ https://issues.apache.org/jira/browse/KAFKA-9015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass updated KAFKA-9015: --- Description: Some of the metrics use a lower-case style metrics name like "i-am-a-met

[jira] [Commented] (KAFKA-8455) Add VoidSerde to Serdes

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

[jira] [Created] (KAFKA-9017) We see timeout in kafka in production cluster

Suhas created KAFKA-9017: Summary: We see timeout in kafka in production cluster Key: KAFKA-9017 URL: https://issues.apache.org/jira/browse/KAFKA-9017 Project: Kafka Issue Type: Bug Compone

[jira] [Commented] (KAFKA-8169) Wrong topic on streams quick start documentation

[ https://issues.apache.org/jira/browse/KAFKA-8169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948674#comment-16948674 ] Tcheutchoua Steve commented on KAFKA-8169: -- Thank you [~mjsax]. I look forward t

[jira] [Created] (KAFKA-9018) Kafka Connect - throw clearer exceptions on serialisation errors

Robin Moffatt created KAFKA-9018: Summary: Kafka Connect - throw clearer exceptions on serialisation errors Key: KAFKA-9018 URL: https://issues.apache.org/jira/browse/KAFKA-9018 Project: Kafka

[jira] [Updated] (KAFKA-9018) Kafka Connect - throw clearer exceptions on serialisation errors

[ https://issues.apache.org/jira/browse/KAFKA-9018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robin Moffatt updated KAFKA-9018: - Description: When Connect fails on a deserialisation error, it doesn't show if that's the *key o

[jira] [Commented] (KAFKA-6098) Delete and Re-create topic operation could result in race condition

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

[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] [Commented] (KAFKA-7273) Converters should have access to headers.

[ https://issues.apache.org/jira/browse/KAFKA-7273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948750#comment-16948750 ] Yaroslav Tkachenko commented on KAFKA-7273: --- Hey [~gunnar.morling], yes, Header

[jira] [Commented] (KAFKA-4164) Kafka produces excessive logs when publishing message to non-existent topic

[ https://issues.apache.org/jira/browse/KAFKA-4164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948803#comment-16948803 ] Tin Nguyen commented on KAFKA-4164: --- I'm facing the same issue, the issue happened many

[jira] [Commented] (KAFKA-9010) Add PartitionGrower, Support partition requery in ProduceBench test.

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

[jira] [Commented] (KAFKA-7273) Converters should have access to headers.

[ https://issues.apache.org/jira/browse/KAFKA-7273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948830#comment-16948830 ] Randall Hauch commented on KAFKA-7273: -- Yes, I think the intention is that the conve

[jira] [Commented] (KAFKA-8169) Wrong topic on streams quick start documentation

[ https://issues.apache.org/jira/browse/KAFKA-8169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948847#comment-16948847 ] Matthias J. Sax commented on KAFKA-8169: [https://issues.apache.org/jira/plugins/

[jira] [Commented] (KAFKA-9012) OutOfOrderSequenceException occurred, all stream stopped consuming

[ https://issues.apache.org/jira/browse/KAFKA-9012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948853#comment-16948853 ] Matthias J. Sax commented on KAFKA-9012: Maybe you can use a mock for the produce

[jira] [Commented] (KAFKA-7273) Converters should have access to headers.

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

[jira] [Commented] (KAFKA-7273) Converters should have access to headers.

[ https://issues.apache.org/jira/browse/KAFKA-7273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948868#comment-16948868 ] Gunnar Morling commented on KAFKA-7273: --- {quote} Headers is modifiable, it has add/

[jira] [Commented] (KAFKA-7263) Container exception java.lang.IllegalStateException: Coordinator selected invalid assignment protocol: null

[ https://issues.apache.org/jira/browse/KAFKA-7263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948887#comment-16948887 ] amuthan Ganeshan commented on KAFKA-7263: - I encountering this problem even in th

[jira] [Commented] (KAFKA-8942) Document RocksDB metrics

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

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948929#comment-16948929 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-

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

[ https://issues.apache.org/jira/browse/KAFKA-8260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8260. Resolution: Duplicate Closing this as duplicate. > Flaky test > ConsumerBounceTest#testRo

[jira] [Commented] (KAFKA-8967) Flaky test kafka.api.SaslSslAdminClientIntegrationTest.testCreateTopicsResponseMetadataAndConfig

[ https://issues.apache.org/jira/browse/KAFKA-8967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948933#comment-16948933 ] Matthias J. Sax commented on KAFKA-8967: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-9014) AssertionError thrown by SourceRecordWriteCounter when SourceTask.poll returns an empty list

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

[jira] [Commented] (KAFKA-8729) Augment ProduceResponse error messaging for specific culprit records

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

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

Guozhang Wang created KAFKA-9020: Summary: Streams sub-topologies should be sorted by sink -> source relationship Key: KAFKA-9020 URL: https://issues.apache.org/jira/browse/KAFKA-9020 Project: Kafka

[jira] [Commented] (KAFKA-8743) Flaky Test RepartitionWithMergeOptimizingIntegrationTest#shouldSendCorrectRecords_OPTIMIZED

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

[jira] [Assigned] (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:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-9020: -- Assignee: Sophie Blee-Goldman > Streams sub-topologies should be sorted by sin

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16949002#comment-16949002 ] Alex Kokachev commented on KAFKA-9011: -- I came up with the code below. If it's accep

[jira] [Created] (KAFKA-9021) Broker shutdown during SSL handshake may be handled as handshake failure (Regression)

Graham Campbell created KAFKA-9021: -- Summary: Broker shutdown during SSL handshake may be handled as handshake failure (Regression) Key: KAFKA-9021 URL: https://issues.apache.org/jira/browse/KAFKA-9021

[jira] [Commented] (KAFKA-9021) Broker shutdown during SSL handshake may be handled as handshake failure (Regression)

[ https://issues.apache.org/jira/browse/KAFKA-9021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16949027#comment-16949027 ] Graham Campbell commented on KAFKA-9021: Issue priority based on previous instanc

[jira] [Commented] (KAFKA-8988) Replace CreatePartitions request/response with automated protocol

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

[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=16949071#comment-16949071 ] ASF GitHub Bot commented on KAFKA-9020: --- ableegoldman commented on pull request #74

[jira] [Commented] (KAFKA-9000) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFromRightThenDeleteRightEntity

[ https://issues.apache.org/jira/browse/KAFKA-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16949079#comment-16949079 ] Sophie Blee-Goldman commented on KAFKA-9000: Failed locally:  java.lang.Asse

[jira] [Created] (KAFKA-9022) Flaky Test KTableKTableForeignKeyJoinIntegrationTest. doInnerJoinFilterOutRapidlyChangingForeignKeyValues

Sophie Blee-Goldman created KAFKA-9022: -- Summary: Flaky Test KTableKTableForeignKeyJoinIntegrationTest. doInnerJoinFilterOutRapidlyChangingForeignKeyValues Key: KAFKA-9022 URL: https://issues.apache.org/jira/

[jira] [Assigned] (KAFKA-9018) Kafka Connect - throw clearer exceptions on serialisation errors

[ https://issues.apache.org/jira/browse/KAFKA-9018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mario Molina reassigned KAFKA-9018: --- Assignee: Mario Molina > Kafka Connect - throw clearer exceptions on serialisation errors >

[jira] [Commented] (KAFKA-9018) Kafka Connect - throw clearer exceptions on serialisation errors

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