[jira] [Commented] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1

2018-03-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383292#comment-16383292 ] ASF GitHub Bot commented on KAFKA-6054: --- mjsax opened a new pull request #4636: [WIP] KAFKA-6054:

[jira] [Commented] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1

2018-03-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383259#comment-16383259 ] Matthias J. Sax commented on KAFKA-6054: We need to change the metadata version again for

[jira] [Assigned] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1

2018-03-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6054: -- Assignee: Matthias J. Sax > ERROR "SubscriptionInfo - unable to decode subscription

[jira] [Updated] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1

2018-03-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6054: --- Labels: needs-kip (was: ) > ERROR "SubscriptionInfo - unable to decode subscription data:

[jira] [Commented] (KAFKA-5891) Cast transformation fails if record schema contains timestamp field

2018-03-01 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383227#comment-16383227 ] Maciej Bryński commented on KAFKA-5891: --- [~broartem] Could you test my patch ? > Cast

[jira] [Updated] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

2018-03-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6592: --- Component/s: streams > NullPointerException thrown when executing ConsoleCosumer with

[jira] [Resolved] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

2018-03-01 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-6592. --- Resolution: Duplicate Seems it's a duplicate of

[jira] [Commented] (KAFKA-6595) Kafka connect commit offset incorrectly.

2018-03-01 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383062#comment-16383062 ] huxihx commented on KAFKA-6595: --- Could we simply cancel the flush if we find another thread has already

[jira] [Commented] (KAFKA-4936) Allow dynamic routing of output records

2018-03-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383038#comment-16383038 ] Matthias J. Sax commented on KAFKA-4936: If you provide an unknown topic name for an output topic,

[jira] [Commented] (KAFKA-6111) Tests for KafkaZkClient

2018-03-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383007#comment-16383007 ] ASF GitHub Bot commented on KAFKA-6111: --- junrao opened a new pull request #4635: Revert "KAFKA-6111:

[jira] [Commented] (KAFKA-6111) Tests for KafkaZkClient

2018-03-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383008#comment-16383008 ] ASF GitHub Bot commented on KAFKA-6111: --- junrao closed pull request #4635: Revert "KAFKA-6111:

[jira] [Commented] (KAFKA-6111) Tests for KafkaZkClient

2018-03-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382993#comment-16382993 ] ASF GitHub Bot commented on KAFKA-6111: --- junrao closed pull request #4596: KAFKA-6111: Improve test

[jira] [Commented] (KAFKA-4936) Allow dynamic routing of output records

2018-03-01 Thread Blake Miller (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382969#comment-16382969 ] Blake Miller commented on KAFKA-4936: - That is a very good point about the potential to create oodles

[jira] [Commented] (KAFKA-6348) Kafka consumer can't restore from coordinator failure

2018-03-01 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382966#comment-16382966 ] Jason Gustafson commented on KAFKA-6348: Each groupId is mapped to one of the __consumer_offsets

[jira] [Commented] (KAFKA-6603) Kafka streams off heap memory usage does not match expected values from configuration

2018-03-01 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382871#comment-16382871 ] Guozhang Wang commented on KAFKA-6603: -- Hello Igor, thanks for reporting the issue, without further

[jira] [Updated] (KAFKA-6605) Flatten SMT does not properly handle fields that are null

2018-03-01 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6605: - Description: When a message has a null field, the `Flatten` SMT does not properly handle this

[jira] [Resolved] (KAFKA-3513) Transient failure of OffsetValidationTest

2018-03-01 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3513. Resolution: Fixed We haven't seen this in some time, so I'm going to close this. We can

[jira] [Updated] (KAFKA-6605) Flatten SMT does not properly handle fields that are null

2018-03-01 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6605: - Description: When a message has a null field, the `Flatten` SMT does not properly handle this

[jira] [Updated] (KAFKA-6605) Flatten SMT does not properly handle fields that are null

2018-03-01 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6605: - Description: When a message has a null field, the `Flatten` SMT does not properly handle this

[jira] [Created] (KAFKA-6605) Flatten SMT does not properly handle fields that are null

2018-03-01 Thread Randall Hauch (JIRA)
Randall Hauch created KAFKA-6605: Summary: Flatten SMT does not properly handle fields that are null Key: KAFKA-6605 URL: https://issues.apache.org/jira/browse/KAFKA-6605 Project: Kafka

[jira] [Commented] (KAFKA-6604) ReplicaManager should not remove partitions on the log dirctory from high watermark checkpoint file

2018-03-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382709#comment-16382709 ] ASF GitHub Bot commented on KAFKA-6604: --- lindong28 opened a new pull request #4634: KAFKA-6604;

[jira] [Created] (KAFKA-6604) ReplicaManager should not remove partitions on the log dirctory from high watermark checkpoint file

2018-03-01 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-6604: --- Summary: ReplicaManager should not remove partitions on the log dirctory from high watermark checkpoint file Key: KAFKA-6604 URL: https://issues.apache.org/jira/browse/KAFKA-6604

[jira] [Commented] (KAFKA-5891) Cast transformation fails if record schema contains timestamp field

2018-03-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382629#comment-16382629 ] ASF GitHub Bot commented on KAFKA-5891: --- maver1ck opened a new pull request #4633: [KAFKA-5891]

[jira] [Created] (KAFKA-6603) Kafka streams off heap memory usage does not match expected values from configuration

2018-03-01 Thread Igor Calabria (JIRA)
Igor Calabria created KAFKA-6603: Summary: Kafka streams off heap memory usage does not match expected values from configuration Key: KAFKA-6603 URL: https://issues.apache.org/jira/browse/KAFKA-6603

[jira] [Resolved] (KAFKA-6593) Coordinator disconnect in heartbeat thread can cause commitSync to block indefinitely

2018-03-01 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6593. Resolution: Fixed > Coordinator disconnect in heartbeat thread can cause commitSync to

[jira] [Commented] (KAFKA-6593) Coordinator disconnect in heartbeat thread can cause commitSync to block indefinitely

2018-03-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382469#comment-16382469 ] ASF GitHub Bot commented on KAFKA-6593: --- hachikuji closed pull request #4625: KAFKA-6593; Fix

[jira] [Created] (KAFKA-6602) Support Kafka to save credentials in Java Key Store on Zookeeper node

2018-03-01 Thread Chen He (JIRA)
Chen He created KAFKA-6602: -- Summary: Support Kafka to save credentials in Java Key Store on Zookeeper node Key: KAFKA-6602 URL: https://issues.apache.org/jira/browse/KAFKA-6602 Project: Kafka

[jira] [Assigned] (KAFKA-6602) Support Kafka to save credentials in Java Key Store on Zookeeper node

2018-03-01 Thread Chen He (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen He reassigned KAFKA-6602: -- Assignee: Chen He > Support Kafka to save credentials in Java Key Store on Zookeeper node >

[jira] [Commented] (KAFKA-6560) Use single-point queries than range queries for windowed aggregation operators

2018-03-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382347#comment-16382347 ] ASF GitHub Bot commented on KAFKA-6560: --- guozhangwang closed pull request #4578: KAFKA-6560: Replace

[jira] [Resolved] (KAFKA-6560) Use single-point queries than range queries for windowed aggregation operators

2018-03-01 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6560. -- Resolution: Fixed Fix Version/s: 1.2.0 > Use single-point queries than range queries for

[jira] [Assigned] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

2018-03-01 Thread Filipe Agapito (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Filipe Agapito reassigned KAFKA-6474: - Assignee: Filipe Agapito > Rewrite test to use new public TopologyTestDriver >

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

2018-03-01 Thread Filipe Agapito (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382069#comment-16382069 ] Filipe Agapito commented on KAFKA-6474: --- I'd like to work on this. I'm assigning the issue to

[jira] [Resolved] (KAFKA-6396) Possibly kafka-connect converter should be able to stop processing chain

2018-03-01 Thread Alexander Koval (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Koval resolved KAFKA-6396. Resolution: Invalid Thank you for the explanation. > Possibly kafka-connect converter