Re: Can't build Kafka project

2017-10-08 Thread Ted Yu
Can you try including 'compileTestJava' in the gradlew command ? On Sun, Oct 1, 2017 at 12:20 PM, Waleed Fateem wrote: > Thanks Ted, > > But do I have to modify this manually or was this supposed to be done after > the project is built? > > I'm missing the following: > > /kafka/core/build/classe

[jira] [Created] (KAFKA-6023) ThreadCache#sizeBytes() should check overflow

2017-10-08 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6023: - Summary: ThreadCache#sizeBytes() should check overflow Key: KAFKA-6023 URL: https://issues.apache.org/jira/browse/KAFKA-6023 Project: Kafka Issue Type: Bug Rep

[GitHub] kafka pull request #4040: KAFKA-5829; Remove stray `printStackTrace()` in te...

2017-10-08 Thread ijuma
GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/4040 KAFKA-5829; Remove stray `printStackTrace()` in test You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka kafka-5829-follow-up Alternative

[jira] [Created] (KAFKA-6024) Consider moving validation in KafkaConsumer ahead of call to acquireAndEnsureOpen()

2017-10-08 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6024: - Summary: Consider moving validation in KafkaConsumer ahead of call to acquireAndEnsureOpen() Key: KAFKA-6024 URL: https://issues.apache.org/jira/browse/KAFKA-6024 Project: Kafka

Re: [VOTE] KIP-171 - Extend Consumer Group Reset Offset for Stream Application

2017-10-08 Thread Guozhang Wang
Thanks for the KIP Jorge, overall it looks good. As Matthias mentioned in the DISCUSS thread, while working on KIP-198 we realize that the o.a.k.admin.AdminClient does not yet have all the functionalities that k.a.AdminClient (in Scala) have, for example, describeConsumerGroup(). Thus, could you

[GitHub] kafka pull request #4041: KAFKA-6023 ThreadCache#sizeBytes() should check ov...

2017-10-08 Thread shivsantham
GitHub user shivsantham opened a pull request: https://github.com/apache/kafka/pull/4041 KAFKA-6023 ThreadCache#sizeBytes() should check overflow long sizeBytes() { long sizeInBytes = 0; for (final NamedCache namedCache : caches.values()) {

[GitHub] kafka pull request #4042: [KAFKA-5835][CLIENTS] CommitFailedException except...

2017-10-08 Thread rekhajoshm
GitHub user rekhajoshm opened a pull request: https://github.com/apache/kafka/pull/4042 [KAFKA-5835][CLIENTS] CommitFailedException exception versus KafkaConsumer flow The invalid offset/out of range offset is captured in IllegalArgumentException/RunTimeException. The CommitFai

Re: [DISCUSS] KIP-205: Add getAllKeys() API to ReadOnlyWindowStore

2017-10-08 Thread Guozhang Wang
Richard, Matthias: 0. Could you describe a bit what are the possible use cases of `allLatest`, `minKey` and `maxKey`? I'd prefer keeping the APIs to add at a minimum necessary amount, to avoid a swamp of new APIs that no one would really use but just complicated the internal code base. 1. One min