[jira] [Comment Edited] (KAFKA-5545) Kafka Stream not able to successfully restart over new broker ip

2017-08-28 Thread Yogesh BG (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16091115#comment-16091115 ] Yogesh BG edited comment on KAFKA-5545 at 8/29/17 5:00 AM: --- ok. Thanks for

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

2017-08-28 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144519#comment-16144519 ] Richard Yu commented on KAFKA-4468: --- [~mjsax] [~guozhang] : Can you review my pull request? Thanks. >

[jira] [Created] (KAFKA-5803) KafkaProducer should ignore invalid record from ProducerInterceptors

2017-08-28 Thread Yingji Zhang (JIRA)
Yingji Zhang created KAFKA-5803: --- Summary: KafkaProducer should ignore invalid record from ProducerInterceptors Key: KAFKA-5803 URL: https://issues.apache.org/jira/browse/KAFKA-5803 Project: Kafka

[jira] [Commented] (KAFKA-4915) Don't include "error" in log messages at non-error levels

2017-08-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144256#comment-16144256 ] ASF GitHub Bot commented on KAFKA-4915: --- GitHub user dernasherbrezon opened a pull request:

[jira] [Created] (KAFKA-5802) ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get()

2017-08-28 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-5802: - Summary: ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get() Key: KAFKA-5802 URL: https://issues.apache.org/jira/browse/KAFKA-5802

[jira] [Commented] (KAFKA-5545) Kafka Stream not able to successfully restart over new broker ip

2017-08-28 Thread Yogesh BG (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144147#comment-16144147 ] Yogesh BG commented on KAFKA-5545: -- I have one qn. As part of this release when I call close on

[jira] [Comment Edited] (KAFKA-5764) KafkaShortnamer should allow for case inensitive matches

2017-08-28 Thread Ruslan Dautkhanov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143947#comment-16143947 ] Ruslan Dautkhanov edited comment on KAFKA-5764 at 8/28/17 4:24 PM: ---

[jira] [Created] (KAFKA-5801) Use hadoop.security.auth_to_local if available

2017-08-28 Thread Ruslan Dautkhanov (JIRA)
Ruslan Dautkhanov created KAFKA-5801: Summary: Use hadoop.security.auth_to_local if available Key: KAFKA-5801 URL: https://issues.apache.org/jira/browse/KAFKA-5801 Project: Kafka Issue

[jira] [Resolved] (KAFKA-5788) "IllegalArgumentException: long is not a value type" when running ReassignPartitionsCommand

2017-08-28 Thread Ansel Zandegran (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ansel Zandegran resolved KAFKA-5788. Resolution: Fixed It was a version mismatch.. Pitfalls of working with different versions

[jira] [Updated] (KAFKA-5800) FileAreadyExist when writing tmp Shutdown Server Suddenly

2017-08-28 Thread Ahmed Mohsen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmed Mohsen updated KAFKA-5800: Description: the server shutdown suddenly with this Exception {code:java} [2017-08-28

[jira] [Commented] (KAFKA-5545) Kafka Stream not able to successfully restart over new broker ip

2017-08-28 Thread Yogesh BG (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143568#comment-16143568 ] Yogesh BG commented on KAFKA-5545: -- [~guozhang] When this feature is expected to release?I mean date?? >

[jira] [Commented] (KAFKA-5764) KafkaShortnamer should allow for case inensitive matches

2017-08-28 Thread David Kaspar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143499#comment-16143499 ] David Kaspar commented on KAFKA-5764: - We are using {{sasl.kerberos.principal.to.local.rules}}

[jira] [Updated] (KAFKA-5799) New KafkaSpoutConfig(Scheme)-ByteArrayKeyValueScheme

2017-08-28 Thread Juhong NamGung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juhong NamGung updated KAFKA-5799: -- Description: I try to integrate Kafka with Apache Strom. I want to get data from Kafka, using

[jira] [Updated] (KAFKA-5799) New KafkaSpoutConfig(Scheme)-ByteArrayKeyValueScheme

2017-08-28 Thread Juhong NamGung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juhong NamGung updated KAFKA-5799: -- Description: I try to integrate Kafka with Apache Strom. I want to get data from Kafka, using

[jira] [Updated] (KAFKA-5799) New KafkaSpoutConfig(Scheme)-ByteArrayKeyValueScheme

2017-08-28 Thread Juhong NamGung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juhong NamGung updated KAFKA-5799: -- Description: I try to integrate Kafka with Apache Strom. I want to get data from Kafka, using

[jira] [Updated] (KAFKA-5799) New KafkaSpoutConfig(Scheme)-ByteArrayKeyValueScheme

2017-08-28 Thread Juhong NamGung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juhong NamGung updated KAFKA-5799: -- Summary: New KafkaSpoutConfig(Scheme)-ByteArrayKeyValueScheme (was: New

[jira] [Updated] (KAFKA-5799) New KafkaSpoutConfig(Scheme)

2017-08-28 Thread Juhong NamGung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juhong NamGung updated KAFKA-5799: -- Description: I try to integrate Kafka with Apache Strom. I want to get data from Kafka, using

[jira] [Updated] (KAFKA-5799) New KafkaSpoutConfig(Scheme)

2017-08-28 Thread Juhong NamGung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juhong NamGung updated KAFKA-5799: -- Affects Version/s: 0.11.0.0 Attachment: 1.JPG 2.JPG

[jira] [Created] (KAFKA-5799) New KafkaSpoutConfig(Scheme

2017-08-28 Thread Juhong NamGung (JIRA)
Juhong NamGung created KAFKA-5799: - Summary: New KafkaSpoutConfig(Scheme Key: KAFKA-5799 URL: https://issues.apache.org/jira/browse/KAFKA-5799 Project: Kafka Issue Type: New Feature

[jira] [Commented] (KAFKA-5779) Single message may exploit application based on KStream

2017-08-28 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143414#comment-16143414 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5779: --- What you had written makes sense (I

[jira] [Commented] (KAFKA-5706) log the name of the error instead of the error code in response objects

2017-08-28 Thread holdenk (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143412#comment-16143412 ] holdenk commented on KAFKA-5706: Awesome, no pressure just was looking for some small kafka things to work

[jira] [Commented] (KAFKA-5786) Yet another exception is causing that streamming app is zombie

2017-08-28 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143406#comment-16143406 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5786: --- IMHO no. It does not solve the