[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] [Created] (KAFKA-5800) FileAreadyExist when writing tmp Shutdown Server Suddenly

2017-08-28 Thread Ahmed Mohsen (JIRA)
Ahmed Mohsen created KAFKA-5800: --- Summary: FileAreadyExist when writing tmp Shutdown Server Suddenly Key: KAFKA-5800 URL: https://issues.apache.org/jira/browse/KAFKA-5800 Project: Kafka Issue T

[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] [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 Ty

Re: [DISCUSS] KIP-91 Provide Intuitive User Timeouts in The Producer

2017-08-28 Thread Becket Qin
Hi Jun, I was thinking of the last try. In that case the remaining delivery.timeout.ms is smaller than request timeout.ms. I am thinking that we can always wait up to request timeout after sending that request to avoid potential unnecessary PID reset. The concern of use remaining delivery.timeout.

[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

[GitHub] kafka pull request #3751: KAFKA-4915: do not use word "error" while logging ...

2017-08-28 Thread dernasherbrezon
GitHub user dernasherbrezon opened a pull request: https://github.com/apache/kafka/pull/3751 KAFKA-4915: do not use word "error" while logging with non-error level Normally if logging event is an error, then it should have log level "ERROR". If it's not an error, it should not have

[GitHub] kafka pull request #3752: Make ByteBufferInputStream.read(byte[], int, int) ...

2017-08-28 Thread leventov
GitHub user leventov opened a pull request: https://github.com/apache/kafka/pull/3752 Make ByteBufferInputStream.read(byte[], int, int) to follow the contract You can merge this pull request into a Git repository by running: $ git pull https://github.com/leventov/kafka patch-1

Re: [DISCUSS] KIP-189: Improve principal builder interface and add support for SASL

2017-08-28 Thread Jason Gustafson
Thanks all for the discussion. I'll begin a vote in the next couple days. -Jason On Fri, Aug 25, 2017 at 5:01 PM, Don Bosco Durai wrote: > Jason, thanks for the clarification. > > Bosco > > > On 8/25/17, 4:59 PM, "Jason Gustafson" wrote: > > Hey Don, > > That is not actually part of th

[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

Re: [DISCUSS] KIP-189: Improve principal builder interface and add support for SASL

2017-08-28 Thread Colin McCabe
Thanks, Jason, this is a great improvement! One minor nit. The current KafkaPrincipal#equals looks like this: >@Override >public boolean equals(Object o) { >if (this == o) return true; >if (!(o instanceof KafkaPrincipal)) return false; > >KafkaPrincipal that = (Ka

Re: [DISCUSS] KIP-189: Improve principal builder interface and add support for SASL

2017-08-28 Thread Ted Yu
bq. change the check in equals() to be this.getClass().equals(other. getClass()) I happened to have Effective Java on hand. Please take a look at related discussion on page 39. Josh later on mentioned Liskov substitution principle and a workaround (favoring composition). FYI On Mon, Aug 28, 2