[GitHub] kafka pull request #3882: MINOR: Add metric templates for sender/fetcher rat...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3882 ---

Build failed in Jenkins: kafka-trunk-jdk8 #2027

See Changes: [damian.guy] KAFKA-5754; Refactor Streams to use LogContext -- [...truncated 2.55 MB...] org.apache.kafka.streams.integration.RegexSourceIntegrationTest >

Build failed in Jenkins: kafka-trunk-jdk7 #2768

See Changes: [ismael] MINOR: Add metric templates for sender/fetcher rate totals [rajinisivaram] MINOR: Update powermock and enable its tests when running with Java 9 [ismael] MINOR: Fix needless GC + Result

[GitHub] kafka pull request #3858: MINOR: update docs to add note about removing SNAP...

Github user dguy closed the pull request at: https://github.com/apache/kafka/pull/3858 ---

[GitHub] kafka pull request #3727: KAFKA-5754 : Refactor Streams to use LogContext

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3727 ---

Build failed in Jenkins: kafka-trunk-jdk7 #2767

See Changes: [damian.guy] KAFKA-5754; Refactor Streams to use LogContext -- [...truncated 2.54 MB...] org.apache.kafka.streams.KafkaStreamsTest >

Build failed in Jenkins: kafka-trunk-jdk8 #2028

See Changes: [ismael] MINOR: Add metric templates for sender/fetcher rate totals [rajinisivaram] MINOR: Update powermock and enable its tests when running with Java 9

[GitHub] kafka pull request #3888: TRIVIAL: Fix typo in mapper parameter of flatMapVa...

GitHub user cddr opened a pull request: https://github.com/apache/kafka/pull/3888 TRIVIAL: Fix typo in mapper parameter of flatMapValues The parameter is already called `mapper` in the KStreamImpl class. I think it was probably named `processor` here because it was copy/pasted from

[GitHub] kafka pull request #3827: KAFKA-5654: add materialized count, reduce, aggreg...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3827 ---

[jira] [Resolved] (KAFKA-5757) Scheduled or Delayed connector start

[ https://issues.apache.org/jira/browse/KAFKA-5757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhananjay Patkar resolved KAFKA-5757. - Resolution: Not A Problem > Scheduled or Delayed connector start >

[GitHub] kafka pull request #3889: KAFKA-5921: add Materialized overloads to windowed...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/3889 KAFKA-5921: add Materialized overloads to windowed kstream Add `Materialized` overloads to `WindowedKStream`. Deprecate existing methods on `KGroupedStream` You can merge this pull request into a Git

[jira] [Resolved] (KAFKA-5754) Refactor Streams to use LogContext

[ https://issues.apache.org/jira/browse/KAFKA-5754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5754. --- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3727

[jira] [Resolved] (KAFKA-5881) Consuming from added partitions without restarting the consumer

[ https://issues.apache.org/jira/browse/KAFKA-5881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viliam Durina resolved KAFKA-5881. -- Resolution: Not A Problem I can confirm the behaviour, after setting "metadata.max.age.ms" to

[jira] [Created] (KAFKA-5920) Handle SSL authentication failures as non-retriable exceptions in clients

Rajini Sivaram created KAFKA-5920: - Summary: Handle SSL authentication failures as non-retriable exceptions in clients Key: KAFKA-5920 URL: https://issues.apache.org/jira/browse/KAFKA-5920 Project:

[jira] [Created] (KAFKA-5919) Delete records command "version" parameter ignored

Paolo Patierno created KAFKA-5919: - Summary: Delete records command "version" parameter ignored Key: KAFKA-5919 URL: https://issues.apache.org/jira/browse/KAFKA-5919 Project: Kafka Issue

[jira] [Created] (KAFKA-5921) Add Materialized overloads to WindowedKStream

Damian Guy created KAFKA-5921: - Summary: Add Materialized overloads to WindowedKStream Key: KAFKA-5921 URL: https://issues.apache.org/jira/browse/KAFKA-5921 Project: Kafka Issue Type: Sub-task

[GitHub] kafka pull request #2903: MINOR: Fix needless GC + Result time unit in JMH

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2903 ---

Re: 1.0.0 Feature Freeze Update

Sure, we do that for every PR anyway (i.e. we manage risk on a continuous scale - even if it's before the feature freeze). I am happy to cc you on any Core PR that we may consider after the feature freeze. Ismael On Mon, Sep 18, 2017 at 11:32 AM, Guozhang Wang wrote: >

[GitHub] kafka pull request #3783: KAFKA-5515: Remove date formatting from Segments

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3783 ---

[GitHub] kafka pull request #3886: MINOR: Code cleanup, subject: log statements.

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3886 ---

Re: 1.0.0 Feature Freeze Update

Hi Guozhang, Note that our documentation for the time-based release plan says the following about what happens after the feature freeze: "We will leave another week for "minor" features to get in (see below for definitions), but at this point we will start efforts to stabilize the release branch

Re: 1.0.0 Feature Freeze Update

Thanks for the reminder Ismael. I think after this Wednesday for KIP-related PRs we need to discuss case-by-case to estimate its impact on regression. Guozhang On Mon, Sep 18, 2017 at 5:56 PM, Ismael Juma wrote: > Hi Guozhang, > > Note that our documentation for the

[jira] [Created] (KAFKA-5922) Add SessionWindowedKStream

Damian Guy created KAFKA-5922: - Summary: Add SessionWindowedKStream Key: KAFKA-5922 URL: https://issues.apache.org/jira/browse/KAFKA-5922 Project: Kafka Issue Type: Sub-task

[GitHub] kafka pull request #3886: Code cleanup, subject: log statements.

GitHub user KoenDG opened a pull request: https://github.com/apache/kafka/pull/3886 Code cleanup, subject: log statements. I'm doing this in my spare time, so don't let reviewing this PR take away actual work time. This is just me going over the code with the Intellij analyzer and

[GitHub] kafka pull request #3887: KAFKA-5919: Delete records command "version" param...

GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3887 KAFKA-5919: Delete records command "version" parameter ignored Removed ignored "version" field in JSON file for deleting records You can merge this pull request into a Git repository by running:

[GitHub] kafka pull request #3881: MINOR: Update powermock and enable its tests when ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3881 ---

[jira] [Created] (KAFKA-5925) Adding records deletion operation to the new Admin Client API

Paolo Patierno created KAFKA-5925: - Summary: Adding records deletion operation to the new Admin Client API Key: KAFKA-5925 URL: https://issues.apache.org/jira/browse/KAFKA-5925 Project: Kafka

Build failed in Jenkins: kafka-trunk-jdk9 #21

See Changes: [ismael] MINOR: Fix replica_verification_tool.py to handle slight change in [damian.guy] KAFKA-5873; add materialized overloads to StreamsBuilder --

Jenkins build is back to normal : kafka-trunk-jdk8 #2031

See

[GitHub] kafka pull request #3869: MINOR: Make the state change log more consistent

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3869 ---

Build failed in Jenkins: kafka-trunk-jdk8 #2032

See Changes: [damian.guy] MINOR: Fix typo in mapper parameter of flatMapValues [ismael] MINOR: Fix replica_verification_tool.py to handle slight change in [damian.guy] KAFKA-5873; add materialized overloads to

[GitHub] kafka pull request #3888: MINOR: Fix typo in mapper parameter of flatMapValu...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3888 ---

Build failed in Jenkins: kafka-trunk-jdk7 #2771

See Changes: [damian.guy] MINOR: Fix typo in mapper parameter of flatMapValues -- [...truncated 2.54 MB...] org.apache.kafka.streams.TopologyTest >

Jenkins build is back to normal : kafka-trunk-jdk7 #2772

See

KIP-203: Add toLowerCase support to sasl.kerberos.principal.to.local rule

Hi all, I've created a small KIP to extend the sasl.kerberos.principal.to.local rule syntax to convert short names to lower case. https://cwiki.apache.org/confluence/display/KAFKA/KIP-203%3A+Add+toLowerCase+support+to+sasl.kerberos.principal.to.local+rule Please have a look at the KIP.

[GitHub] kafka pull request #3892: MINOR: use StoreBuilder in KStreamImpl rather than...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/3892 MINOR: use StoreBuilder in KStreamImpl rather than StateStoreSupplier You can merge this pull request into a Git repository by running: $ git pull https://github.com/dguy/kafka

[GitHub] kafka pull request #3837: KAFKA-5873: add materialized overloads to StreamsB...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3837 ---

Build failed in Jenkins: kafka-trunk-jdk8 #2029

See Changes: [ismael] MINOR: Fix needless GC + Result time unit in JMH [damian.guy] KAFKA-5654; add materialized count, reduce, aggregate to KGroupedStream [damian.guy] MINOR: Code cleanup, subject: log

Jenkins build is back to normal : kafka-trunk-jdk7 #2770

See

[GitHub] kafka pull request #3890: MINOR: Fix replica_verification_tool.py to handle ...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/3890 MINOR: Fix replica_verification_tool.py to handle slight change in output format The string representation of TopicPartition was changed to be {topic}-{partitition} consistently in the following

[jira] [Created] (KAFKA-5924) Add the compose method to the Kafka Stream API

Laurent T created KAFKA-5924: Summary: Add the compose method to the Kafka Stream API Key: KAFKA-5924 URL: https://issues.apache.org/jira/browse/KAFKA-5924 Project: Kafka Issue Type: Wish

[GitHub] kafka pull request #3890: MINOR: Fix replica_verification_tool.py to handle ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3890 ---

Build failed in Jenkins: kafka-trunk-jdk8 #2030

See Changes: [damian.guy] KAFKA-5515; Remove date formatting from Segments -- [...truncated 2.55 MB...] org.apache.kafka.streams.integration.RegexSourceIntegrationTest >

[jira] [Created] (KAFKA-5923) Output generated by kafka_acls, kafka_topics. kafka_topics should be easily usable in a pipe

Holger Rauch created KAFKA-5923: --- Summary: Output generated by kafka_acls, kafka_topics. kafka_topics should be easily usable in a pipe Key: KAFKA-5923 URL: https://issues.apache.org/jira/browse/KAFKA-5923

[jira] [Resolved] (KAFKA-5873) Add Materialized overloads to StreamBuilder

[ https://issues.apache.org/jira/browse/KAFKA-5873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5873. --- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3837

[GitHub] kafka pull request #3859: KAFKA-5893: ResetIntegrationTest fails

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3859 ---

Build failed in Jenkins: kafka-trunk-jdk7 #2769

See Changes: [damian.guy] KAFKA-5654; add materialized count, reduce, aggregate to KGroupedStream [damian.guy] MINOR: Code cleanup, subject: log statements. [damian.guy] KAFKA-5515; Remove date formatting

Re: KIP-203: Add toLowerCase support to sasl.kerberos.principal.to.local rule

Makes sense. Please fill out JIRA name, etc. On Mon, Sep 18, 2017 at 9:30 AM, Manikumar wrote: > Hi all, > > I've created a small KIP to extend the sasl.kerberos.principal.to.local > rule syntax to convert short names to lower case. > >

Re: unsubscribe

Please look at instruction on https://kafka.apache.org/contact for unsubscribing On Mon, Sep 18, 2017 at 10:24 AM, Madhav Ancha (BLOOMBERG/ 919 3RD A) < manc...@bloomberg.net> wrote: > unsubscribe > >

Jenkins build is back to normal : kafka-trunk-jdk9 #22

See

unsubscribe

unsubscribe From: dev@kafka.apache.org At: 09/18/17 13:24:09 To: dev@kafka.apache.org Subject: Re: KIP-203: Add toLowerCase support to sasl.kerberos.principal.to.local rule Makes sense. Please fill out JIRA name, etc. On Mon, Sep 18, 2017 at 9:30 AM, Manikumar

Build failed in Jenkins: kafka-trunk-jdk8 #2033

See Changes: [jason] MINOR: Make the state change log more consistent -- [...truncated 2.55 MB...] org.apache.kafka.streams.integration.RegexSourceIntegrationTest >

Build failed in Jenkins: kafka-trunk-jdk7 #2773

See Changes: [jason] MINOR: Make the state change log more consistent -- [...truncated 932.34 KB...] kafka.server.epoch.LeaderEpochFileCacheTest >

Re: KIP-203: Add toLowerCase support to sasl.kerberos.principal.to.local rule

What locale is used for the case conversion, the JVM default one or a specific one? On 18 Sep 2017 5:31 pm, "Manikumar" wrote: > Hi all, > > I've created a small KIP to extend the sasl.kerberos.principal.to.local > rule syntax to convert short names to lower case. > >

[DISCUSS] KIP-204 : adding records deletion operation to the new Admin Client API

Hi devs, I'd like to start a discussion around adding the delete records operation, already available at protocol level and in the "legacy" Admin Client in Scala, to the "new" Admin Client API in Java.

[jira] [Created] (KAFKA-5926) --force option is ginored by kafka-configs and kafka-topics tools

Mickael Maison created KAFKA-5926: - Summary: --force option is ginored by kafka-configs and kafka-topics tools Key: KAFKA-5926 URL: https://issues.apache.org/jira/browse/KAFKA-5926 Project: Kafka

[GitHub] kafka pull request #3893: KAFKA-5893: Preserve original System.out in Printe...

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/3893 KAFKA-5893: Preserve original System.out in PrintedTest You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka

Re: [DISCUSS] KIP-204 : adding records deletion operation to the new Admin Client API

+1 (non-binding) On Mon, Sep 18, 2017 at 1:04 PM, Ted Yu wrote: > +1 > > On Mon, Sep 18, 2017 at 9:19 AM, Paolo Patierno > wrote: > > > Hi devs, > > > > > > I'd like to start a discussion around adding the delete records > operation, > > already

[jira] [Resolved] (KAFKA-5825) Streams not processing when exactly once is set

[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan Worsley resolved KAFKA-5825. - Resolution: Done > Streams not processing when exactly once is set >

Build failed in Jenkins: kafka-trunk-jdk8 #2034

See Changes: [jason] MINOR: Fix KafkaConsumer.commitSync() javadoc @throws declarations -- [...truncated 2.55 MB...]

[GitHub] kafka pull request #3780: MINOR: Updated KafkaConsumer.commitSync() javadoc

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3780 ---

Build failed in Jenkins: kafka-trunk-jdk9 #23

See Changes: [jason] MINOR: Fix KafkaConsumer.commitSync() javadoc @throws declarations -- [...truncated 1.39 MB...] kafka.server.epoch.LeaderEpochFileCacheTest >

Re: [Discuss] KIP-202 Move merge() from StreamsBuilder to KStream

The discussion should not stay idle. Since this issue is so small, we should move it into the voting phase. On Sun, Sep 17, 2017 at 1:39 PM, Matthias J. Sax wrote: > Thanks for updating the KIP. > > You are of course right, that we internally need access to >

[GitHub] kafka pull request #3841: KAFKA-5833: Reset thread interrupt state in case o...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3841 ---

Jenkins build is back to normal : kafka-trunk-jdk7 #2778

See

[jira] [Resolved] (KAFKA-5917) Kafka not starting

[ https://issues.apache.org/jira/browse/KAFKA-5917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5917. -- Resolution: Won't Fix These kinds of issues can be avoided once we completely move Kafka tools to Java

Build failed in Jenkins: kafka-trunk-jdk8 #2037

See Changes: [wangguoz] KAFKA-5918: Fix minor typos and errors in the Kafka Streams turotial -- [...truncated 4.46 MB...] kafka.security.auth.SimpleAclAuthorizerTest >

[GitHub] kafka pull request #3895: MINOR: Protocol schema refactor follow-up

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/3895 MINOR: Protocol schema refactor follow-up Minor clean-ups from the review. You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka

[GitHub] kafka pull request #3813: MINOR: Move request/response schemas to the corres...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3813 ---

[GitHub] kafka pull request #3788: MINOR: update security docs

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3788 ---

[GitHub] kafka pull request #3885: MINOR: Added ">" prompt in examples where kafka-co...

GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3885 MINOR: Added ">" prompt in examples where kafka-console-producer is used You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka

[jira] [Created] (KAFKA-5928) Avoid redundant requests to zookeeper when reassign topic partition

Genmao Yu created KAFKA-5928: Summary: Avoid redundant requests to zookeeper when reassign topic partition Key: KAFKA-5928 URL: https://issues.apache.org/jira/browse/KAFKA-5928 Project: Kafka

[GitHub] kafka pull request #3894: KAFKA-5928: Avoid redundant requests to zookeeper ...

GitHub user uncleGen opened a pull request: https://github.com/apache/kafka/pull/3894 KAFKA-5928: Avoid redundant requests to zookeeper when reassign topic partition We mistakenly request topic level information according to partitions config in the assignment json file. For

Build failed in Jenkins: kafka-trunk-jdk7 #2777

See Changes: [wangguoz] KAFKA-5918: Fix minor typos and errors in the Kafka Streams turotial -- [...truncated 10.10 MB...] at

Jenkins build is back to normal : kafka-trunk-jdk8 #2036

See

Re: [DISCUSS] KIP-204 : adding records deletion operation to the new Admin Client API

+1 On Mon, Sep 18, 2017 at 9:19 AM, Paolo Patierno wrote: > Hi devs, > > > I'd like to start a discussion around adding the delete records operation, > already available at protocol level and in the "legacy" Admin Client in > Scala, to the "new" Admin Client API in Java. > >

Build failed in Jenkins: kafka-trunk-jdk7 #2774

See Changes: [jason] MINOR: Fix KafkaConsumer.commitSync() javadoc @throws declarations -- [...truncated 932.70 KB...] kafka.server.epoch.LeaderEpochFileCacheTest >

Re: [VOTE] KIP-202

KIP-202 Move merge() from StreamsBuilder to KStream. https://cwiki.apache.org/confluence/display/KAFKA/KIP-202+Move+merge%28%29+from+StreamsBuilder+to+KStream This is the link for the VOTE. On Mon, Sep 18, 2017 at 4:27 PM, Richard Yu wrote: > Hello, I would like to

[GitHub] kafka pull request #3893: KAFKA-5893: Preserve original System.out in Printe...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3893 ---

Re: Please grant me Wiki Access

Any update please? On 15 September 2017 at 09:48, chetna chaudhari wrote: > Hi, >Please grant me wiki page access. I need the access to create a KIP for > change . > my wiki id is 'chetna' . > > -- > Thanks and Regards, >

Build failed in Jenkins: kafka-trunk-jdk8 #2035

See Changes: [wangguoz] KAFKA-5833: Reset thread interrupt state in case of InterruptedException -- [...truncated 2.55 MB...]

[jira] [Created] (KAFKA-5927) Capitalise topicPurgatory Name

Chetna Chaudhari created KAFKA-5927: --- Summary: Capitalise topicPurgatory Name Key: KAFKA-5927 URL: https://issues.apache.org/jira/browse/KAFKA-5927 Project: Kafka Issue Type: Task

Build failed in Jenkins: kafka-trunk-jdk9 #24

See Changes: [wangguoz] KAFKA-5833: Reset thread interrupt state in case of InterruptedException -- [...truncated 1.81 MB...]

Jenkins build is back to normal : kafka-trunk-jdk7 #2776

See

[VOTE] KIP-202

Hello, I would like to start a VOTE thread on KIP-202. Thanks.

Build failed in Jenkins: kafka-trunk-jdk7 #2775

See Changes: [wangguoz] KAFKA-5833: Reset thread interrupt state in case of InterruptedException -- [...truncated 2.53 MB...]

[jira] [Resolved] (KAFKA-5918) Fix minor typos and errors in the Kafka Streams turotial

[ https://issues.apache.org/jira/browse/KAFKA-5918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5918. -- Resolution: Fixed Issue resolved by pull request 3883

[GitHub] kafka pull request #3883: KAFKA-5918: Fix minor typos and errors in the Kafk...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3883 ---

Build failed in Jenkins: kafka-0.11.0-jdk7 #309

See Changes: [jason] MINOR: Fix KafkaConsumer.commitSync() javadoc @throws declarations -- [...truncated 865.07 KB...] kafka.api.AdminClientIntegrationTest >

Jenkins build is back to normal : kafka-trunk-jdk9 #25

See