[jira] [Commented] (KAFKA-4277) creating ephemeral node already exist

[ https://issues.apache.org/jira/browse/KAFKA-4277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691514#comment-16691514 ] Birger Brunswiek commented on KAFKA-4277: - I am not sure if the issue I experienc

[jira] [Created] (KAFKA-7654) Relax requirements on serializing-only methods.

Bruno Bieth created KAFKA-7654: -- Summary: Relax requirements on serializing-only methods. Key: KAFKA-7654 URL: https://issues.apache.org/jira/browse/KAFKA-7654 Project: Kafka Issue Type: Improve

[jira] [Commented] (KAFKA-4493) Connections to Kafka brokers should be validated

[ https://issues.apache.org/jira/browse/KAFKA-4493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691676#comment-16691676 ] Stanislav Kozlovski commented on KAFKA-4493: [~taku-k] , I'd like to fix this

[jira] [Comment Edited] (KAFKA-4493) Connections to Kafka brokers should be validated

[ https://issues.apache.org/jira/browse/KAFKA-4493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691676#comment-16691676 ] Stanislav Kozlovski edited comment on KAFKA-4493 at 11/19/18 1:07 PM: -

[jira] [Commented] (KAFKA-7397) Ability to apply DSL stateless transformation on a global table

[ https://issues.apache.org/jira/browse/KAFKA-7397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691751#comment-16691751 ] Frederic Tardif commented on KAFKA-7397: Hi [~vvcephei], BTW, the work around cod

[jira] [Commented] (KAFKA-7577) Semantics of Table-Table Join with Null Message Are Incorrect

[ https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691821#comment-16691821 ] Daren Thomas commented on KAFKA-7577: - [~guozhang] I have unit tests for the issue, b

[jira] [Created] (KAFKA-7655) Metadata spamming requests from Kafka Streams under some circumstances, potential DOS

Pasquale Vazzana created KAFKA-7655: --- Summary: Metadata spamming requests from Kafka Streams under some circumstances, potential DOS Key: KAFKA-7655 URL: https://issues.apache.org/jira/browse/KAFKA-7655

[jira] [Commented] (KAFKA-7655) Metadata spamming requests from Kafka Streams under some circumstances, potential DOS

[ https://issues.apache.org/jira/browse/KAFKA-7655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691875#comment-16691875 ] ASF GitHub Bot commented on KAFKA-7655: --- Pasvaz opened a new pull request #5929: KA

[jira] [Resolved] (KAFKA-7554) zookeeper.session.timeout.ms Value

[ https://issues.apache.org/jira/browse/KAFKA-7554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7554. -- Resolution: Not A Problem Default Zookeeper session timeout value 6 seconds. If the server fails to he

[jira] [Resolved] (KAFKA-7323) add replication factor doesn't work

[ https://issues.apache.org/jira/browse/KAFKA-7323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7323. -- Resolution: Not A Problem Closing as per above comment. probably heap memory is not sufficient. Please

[jira] [Commented] (KAFKA-7654) Relax requirements on serializing-only methods.

[ https://issues.apache.org/jira/browse/KAFKA-7654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692023#comment-16692023 ] Bill Bejeck commented on KAFKA-7654: Hi Bruno Bieth,  I understand your point, but b

[jira] [Commented] (KAFKA-7361) Kafka wont reconnect after NoRouteToHostException

[ https://issues.apache.org/jira/browse/KAFKA-7361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692035#comment-16692035 ] Manikumar commented on KAFKA-7361: -- This must be fixed in https://issues.apache.org/jira

[jira] [Commented] (KAFKA-4277) creating ephemeral node already exist

[ https://issues.apache.org/jira/browse/KAFKA-4277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692047#comment-16692047 ] Jun Rao commented on KAFKA-4277: [~birger] : Hmm, according to [http://mail-archives.apa

[jira] [Commented] (KAFKA-7654) Relax requirements on serializing-only methods.

[ https://issues.apache.org/jira/browse/KAFKA-7654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692065#comment-16692065 ] Matthias J. Sax commented on KAFKA-7654: `Produced` also allows to hand in an `St

[jira] [Commented] (KAFKA-7577) Semantics of Table-Table Join with Null Message Are Incorrect

[ https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692066#comment-16692066 ] Matthias J. Sax commented on KAFKA-7577: `aggregate()` will drop any `null`-value

[jira] [Commented] (KAFKA-7446) Better error message to explain the upper limit of TimeWindow

[ https://issues.apache.org/jira/browse/KAFKA-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692077#comment-16692077 ] ASF GitHub Bot commented on KAFKA-7446: --- mrsrinivas opened a new pull request #5930

[jira] [Comment Edited] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin()

[ https://issues.apache.org/jira/browse/KAFKA-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690159#comment-16690159 ] Eugen Feller edited comment on KAFKA-7634 at 11/19/18 6:39 PM:

[jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin()

[ https://issues.apache.org/jira/browse/KAFKA-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692099#comment-16692099 ] Eugen Feller commented on KAFKA-7634: - Sure. Punctuate call looks like this:. {code:j

[jira] [Comment Edited] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin()

[ https://issues.apache.org/jira/browse/KAFKA-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692099#comment-16692099 ] Eugen Feller edited comment on KAFKA-7634 at 11/19/18 6:40 PM:

[jira] [Resolved] (KAFKA-764) Race Condition in Broker Registration after ZooKeeper disconnect

[ https://issues.apache.org/jira/browse/KAFKA-764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-764. - Resolution: Duplicate This old issue is similar to KAFKA-7165. Closing this as duplicate KAFKA-7165 > Rac

[jira] [Comment Edited] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin()

[ https://issues.apache.org/jira/browse/KAFKA-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692099#comment-16692099 ] Eugen Feller edited comment on KAFKA-7634 at 11/19/18 6:40 PM:

[jira] [Comment Edited] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692108#comment-16692108 ] Jason Gustafson edited comment on KAFKA-7610 at 11/19/18 6:49 PM: -

[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692108#comment-16692108 ] Jason Gustafson commented on KAFKA-7610: [~guozhang] Here is a quick sketch of th

[jira] [Commented] (KAFKA-6585) Consolidate duplicated logic on reset tools

[ https://issues.apache.org/jira/browse/KAFKA-6585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692118#comment-16692118 ] Samuel Hawker commented on KAFKA-6585: -- [~adityavivek94] are you still working on th

[jira] [Commented] (KAFKA-6585) Consolidate duplicated logic on reset tools

[ https://issues.apache.org/jira/browse/KAFKA-6585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692129#comment-16692129 ] Samuel Hawker commented on KAFKA-6585: -- Assuming I can pick it up I have a question.

[jira] [Commented] (KAFKA-7577) Semantics of Table-Table Join with Null Message Are Incorrect

[ https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692136#comment-16692136 ] Daren Thomas commented on KAFKA-7577: - What is the reasoning behind that being the de

[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692148#comment-16692148 ] Michael Noll commented on KAFKA-7653: - Thanks for raising this, [~mark.tranter]! The

[jira] [Commented] (KAFKA-7577) Semantics of Table-Table Join with Null Message Are Incorrect

[ https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692143#comment-16692143 ] Daren Thomas commented on KAFKA-7577: - This is the detailed behavior of KGroupedTable

[jira] [Commented] (KAFKA-7654) Relax requirements on serializing-only methods.

[ https://issues.apache.org/jira/browse/KAFKA-7654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692168#comment-16692168 ] Bruno Bieth commented on KAFKA-7654: Hi, [~bbejeck] this is future proofing and in t

[jira] [Commented] (KAFKA-4277) creating ephemeral node already exist

[ https://issues.apache.org/jira/browse/KAFKA-4277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692211#comment-16692211 ] Jonathan Santilli commented on KAFKA-4277: -- Hello [~birger],  KAFKA-7165 will so

[jira] [Created] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

Patrick Haas created KAFKA-7656: --- Summary: ReplicaManager fetch fails on leader due to long/integer overflow Key: KAFKA-7656 URL: https://issues.apache.org/jira/browse/KAFKA-7656 Project: Kafka

[jira] [Updated] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Patrick Haas updated KAFKA-7656: Description: (Note: From 2.0.1-cp1 from confluent distribution) This may not be the root cause, bu

[jira] [Updated] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Patrick Haas updated KAFKA-7656: Description: (Note: From 2.0.1-cp1 from confluent distribution) {{[2018-11-19 21:13:13,687] ERROR

[jira] [Updated] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Patrick Haas updated KAFKA-7656: Description: (Note: From 2.0.1-cp1 from confluent distribution) Edit: Misread the code, issue is w

[jira] [Commented] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692316#comment-16692316 ] Jason Gustafson commented on KAFKA-7531: [~spuzon] Thanks for the additional info

[jira] [Commented] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692347#comment-16692347 ] Sebastian Puzoń commented on KAFKA-7531: [~guozhang] Your're right, kafka documen

[jira] [Commented] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692365#comment-16692365 ] Sebastian Puzoń commented on KAFKA-7531: ok I'll check this : [https://github.com

[jira] [Commented] (KAFKA-7638) Trogdor - Support mass task creation endpoint

[ https://issues.apache.org/jira/browse/KAFKA-7638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692366#comment-16692366 ] ASF GitHub Bot commented on KAFKA-7638: --- stanislavkozlovski opened a new pull reque

[jira] [Commented] (KAFKA-7192) State-store can desynchronise with changelog

[ https://issues.apache.org/jira/browse/KAFKA-7192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692414#comment-16692414 ] ASF GitHub Bot commented on KAFKA-7192: --- mjsax closed pull request #5767: KAFKA-719

[jira] [Updated] (KAFKA-7192) State-store can desynchronise with changelog

[ https://issues.apache.org/jira/browse/KAFKA-7192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7192: --- Fix Version/s: 1.1.2 > State-store can desynchronise with changelog > ---

[jira] [Commented] (KAFKA-7192) State-store can desynchronise with changelog

[ https://issues.apache.org/jira/browse/KAFKA-7192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692417#comment-16692417 ] Matthias J. Sax commented on KAFKA-7192: [~tobiajo] Back ported to 1.1 branch :)

[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&focusedCommentId=16692424#comment-16692424 ] Adam Bellemare commented on KAFKA-4212: --- We have some business requirements where w

[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692440#comment-16692440 ] Mark Tranter commented on KAFKA-7653: - Thanks [~miguno] Yes that is one workaround.

[jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

[ https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692496#comment-16692496 ] Boyang Chen commented on KAFKA-7641: [Stanislav Kozlovski|x-note://3AF09C0A-0D9D-4EF

[jira] [Comment Edited] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

[ https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692496#comment-16692496 ] Boyang Chen edited comment on KAFKA-7641 at 11/20/18 12:52 AM:

[jira] [Commented] (KAFKA-7566) Add sidecar job to leader (or a random single follower) only

[ https://issues.apache.org/jira/browse/KAFKA-7566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692501#comment-16692501 ] Boyang Chen commented on KAFKA-7566: [~guozhang] Yep, for example our KStream applica

[jira] [Commented] (KAFKA-7577) Semantics of Table-Table Join with Null Message Are Incorrect

[ https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692535#comment-16692535 ] Matthias J. Sax commented on KAFKA-7577: An `aggregation()` is designed like in S

[jira] [Commented] (KAFKA-7654) Relax requirements on serializing-only methods.

[ https://issues.apache.org/jira/browse/KAFKA-7654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692570#comment-16692570 ] Matthias J. Sax commented on KAFKA-7654: Thanks for sharing your thoughts. I thin

[jira] [Commented] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate

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

[jira] [Created] (KAFKA-7657) Invalid reporting of StreamState in KafkaStreams application

Thomas Crowley created KAFKA-7657: - Summary: Invalid reporting of StreamState in KafkaStreams application Key: KAFKA-7657 URL: https://issues.apache.org/jira/browse/KAFKA-7657 Project: Kafka

[jira] [Updated] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Crowley updated KAFKA-7657: -- Summary: Invalid reporting of stream state in Kafka streams application (was: Invalid reportin

[jira] [Updated] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Crowley updated KAFKA-7657: -- Description: We have a streams application with 3 instances running, two of which are reportin

[jira] [Updated] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Crowley updated KAFKA-7657: -- Description: We have a streams application with 3 instances running, two of which are reportin

[jira] [Updated] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Crowley updated KAFKA-7657: -- Description: We have a streams application with 3 instances running, two of which are reportin

[jira] [Created] (KAFKA-7658) Add KStream#toTable to the Streams DSL

Guozhang Wang created KAFKA-7658: Summary: Add KStream#toTable to the Streams DSL Key: KAFKA-7658 URL: https://issues.apache.org/jira/browse/KAFKA-7658 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7658: - Description: We'd like to add a new API to the KStream object of the Streams DSL: {code} KTable

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692791#comment-16692791 ] Jan Filipiak commented on KAFKA-7658: - [~guozhang] I remember our conversations when

[jira] [Comment Edited] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692791#comment-16692791 ] Jan Filipiak edited comment on KAFKA-7658 at 11/20/18 7:46 AM: