[jira] [Commented] (KAFKA-7630) Clarify that broker doesn't need scram username/password for delegation tokens

2018-11-14 Thread Andras Beni (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16687615#comment-16687615 ] Andras Beni commented on KAFKA-7630: [~asasvari], [~viktorsomogyi] you might want to take a look at

[jira] [Created] (KAFKA-7630) Clarify that broker doesn't need scram username/password for delegation tokens

2018-11-14 Thread Andras Beni (JIRA)
Andras Beni created KAFKA-7630: -- Summary: Clarify that broker doesn't need scram username/password for delegation tokens Key: KAFKA-7630 URL: https://issues.apache.org/jira/browse/KAFKA-7630 Project:

[jira] [Commented] (KAFKA-7628) KafkaStream is not closing

2018-11-14 Thread Ozgur (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16687486#comment-16687486 ] Ozgur commented on KAFKA-7628: -- Hi John, It returns *false* from the close() method, but state is

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

2018-11-14 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16687475#comment-16687475 ] Boyang Chen commented on KAFKA-7610: Thanks [~guozhang] for jumping into the discussion! Just to

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

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16687443#comment-16687443 ] ASF GitHub Bot commented on KAFKA-7192: --- mjsax opened a new pull request #5915: KAFKA-7192: Wipe

[jira] [Commented] (KAFKA-7615) Support different topic name in source and destination server in Mirrormaker

2018-11-14 Thread James Cheng (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16687423#comment-16687423 ] James Cheng commented on KAFKA-7615: [~adeetikaushal]: This can be implemented by supplying a

[jira] [Resolved] (KAFKA-7626) Possible duplicate message delivery with exactly-once semantics

2018-11-14 Thread Noam Berman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Noam Berman resolved KAFKA-7626. Resolution: Not A Problem > Possible duplicate message delivery with exactly-once semantics >

[jira] [Commented] (KAFKA-7626) Possible duplicate message delivery with exactly-once semantics

2018-11-14 Thread Noam Berman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16687373#comment-16687373 ] Noam Berman commented on KAFKA-7626: after talking with Matthias J Sax in the confluent slack, it

[jira] [Commented] (KAFKA-7628) KafkaStream is not closing

2018-11-14 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16687359#comment-16687359 ] John Roesler commented on KAFKA-7628: - Hi [~lugrugzo], To confirm, you see that Streams successfully

[jira] [Commented] (KAFKA-7626) Possible duplicate message delivery with exactly-once semantics

2018-11-14 Thread Noam Berman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16687330#comment-16687330 ] Noam Berman commented on KAFKA-7626: I set the kafka consumer/producer logs to TRACE so we can have a

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

2018-11-14 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16687336#comment-16687336 ] Guozhang Wang commented on KAFKA-7610: -- This is a great discussion! 1) I think today we do not

[jira] [Updated] (KAFKA-7626) Possible duplicate message delivery with exactly-once semantics

2018-11-14 Thread Noam Berman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Noam Berman updated KAFKA-7626: --- Attachment: full.tar.gz > Possible duplicate message delivery with exactly-once semantics >

[jira] [Assigned] (KAFKA-7443) OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic

2018-11-14 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-7443: --- Assignee: John Roesler > OffsetOutOfRangeException in restoring state store from changelog

[jira] [Commented] (KAFKA-7367) Streams should not create state store directories unless they are needed

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16687113#comment-16687113 ] ASF GitHub Bot commented on KAFKA-7367: --- vvcephei closed pull request #5647: KAFKA-7367: Ensure

[jira] [Commented] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

2018-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16687038#comment-16687038 ] ASF GitHub Bot commented on KAFKA-5117: --- qiao-meng-zefr closed pull request #4269: KAFKA-5117: Add

[jira] [Assigned] (KAFKA-7620) ConfigProvider is broken for KafkaConnect when TTL is not null

2018-11-14 Thread Robert Yokota (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota reassigned KAFKA-7620: Assignee: Robert Yokota > ConfigProvider is broken for KafkaConnect when TTL is not null

[jira] [Updated] (KAFKA-7629) Mirror maker goes into infinite loop

2018-11-14 Thread Darshan Mehta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Darshan Mehta updated KAFKA-7629: - Description: *Setup:* I have 2 kafka images running Spoify Kafka image :

[jira] [Updated] (KAFKA-7629) Mirror maker goes into infinite loop

2018-11-14 Thread Darshan Mehta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Darshan Mehta updated KAFKA-7629: - Description: *Setup:* I have 2 kafka images running (Spoify Kafka image :

[jira] [Updated] (KAFKA-7629) Mirror maker goes into infinite loop

2018-11-14 Thread Darshan Mehta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Darshan Mehta updated KAFKA-7629: - Description: *Setup:* I have 2 kafka images running Spoify Kafka image

[jira] [Updated] (KAFKA-7629) Mirror maker goes into infinite loop

2018-11-14 Thread Darshan Mehta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Darshan Mehta updated KAFKA-7629: - Description: *Setup:* I have 2 kafka images running (Spoify Kafka image :

[jira] [Created] (KAFKA-7629) Mirror maker goes into infinite loop

2018-11-14 Thread Darshan Mehta (JIRA)
Darshan Mehta created KAFKA-7629: Summary: Mirror maker goes into infinite loop Key: KAFKA-7629 URL: https://issues.apache.org/jira/browse/KAFKA-7629 Project: Kafka Issue Type: Bug

[jira] [Assigned] (KAFKA-5505) Connect: Do not restart connector and existing tasks on task-set change

2018-11-14 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch reassigned KAFKA-5505: Assignee: Konstantine Karantasis > Connect: Do not restart connector and existing tasks

[jira] [Created] (KAFKA-7628) KafkaStream is not closing

2018-11-14 Thread Ozgur (JIRA)
Ozgur created KAFKA-7628: Summary: KafkaStream is not closing Key: KAFKA-7628 URL: https://issues.apache.org/jira/browse/KAFKA-7628 Project: Kafka Issue Type: Bug Components: streams

[jira] [Updated] (KAFKA-7625) Kafka Broker node JVM crash - kafka.coordinator.transaction.TransactionCoordinator.$anonfun$handleEndTransaction

2018-11-14 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-7625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Puzoń updated KAFKA-7625: --- Attachment: hs_err_pid4194.log hs_err_pid4299.log

[jira] [Created] (KAFKA-7626) Possible duplicate message delivery with exactly-once semantics

2018-11-14 Thread Noam Berman (JIRA)
Noam Berman created KAFKA-7626: -- Summary: Possible duplicate message delivery with exactly-once semantics Key: KAFKA-7626 URL: https://issues.apache.org/jira/browse/KAFKA-7626 Project: Kafka

[jira] [Created] (KAFKA-7625) Kafka Broker node JVM crash - kafka.coordinator.transaction.TransactionCoordinator.$anonfun$handleEndTransaction

2018-11-14 Thread JIRA
Sebastian Puzoń created KAFKA-7625: -- Summary: Kafka Broker node JVM crash - kafka.coordinator.transaction.TransactionCoordinator.$anonfun$handleEndTransaction Key: KAFKA-7625 URL:

[jira] [Created] (KAFKA-7624) HOW TO FILETER NESTED THROUGH KAFKA CONNECT

2018-11-14 Thread Chenchu Lakshman kumar (JIRA)
Chenchu Lakshman kumar created KAFKA-7624: - Summary: HOW TO FILETER NESTED THROUGH KAFKA CONNECT Key: KAFKA-7624 URL: https://issues.apache.org/jira/browse/KAFKA-7624 Project: Kafka

[jira] [Resolved] (KAFKA-7623) SMT STRUCT to MASK or FILTER

2018-11-14 Thread Chenchu Lakshman kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chenchu Lakshman kumar resolved KAFKA-7623. --- Resolution: Fixed > SMT STRUCT to MASK or FILTER >

[jira] [Commented] (KAFKA-6812) Async ConsoleProducer exits with 0 status even after data loss

2018-11-14 Thread Stanislav Kozlovski (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686259#comment-16686259 ] Stanislav Kozlovski commented on KAFKA-6812: [~kamalkang] I don't have access to that