[GitHub] kafka pull request #3917: MINOR: Extend release.py with a subcommand for sta...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/3917 MINOR: Extend release.py with a subcommand for staging docs into the kafka-site repo You can merge this pull request into a Git repository by running: $ git pull

[GitHub] kafka pull request #3916: KAFKA-5765 Move merge() from StreamsBuilder to KSt...

GitHub user ConcurrencyPractitioner opened a pull request: https://github.com/apache/kafka/pull/3916 KAFKA-5765 Move merge() from StreamsBuilder to KStream You can merge this pull request into a Git repository by running: $ git pull

[GitHub] kafka-site pull request #80: Added Xite and Zalando logo to Powered by page

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

[GitHub] kafka-site issue #80: Added Xite and Zalando logo to Powered by page

Github user ewencp commented on the issue: https://github.com/apache/kafka-site/pull/80 LGTM, thanks ---

[GitHub] kafka pull request #3880: KAFKA-5765 Move merge() from StreamsBuilder to KSt...

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

[GitHub] kafka pull request #3915: MINOR: add punctuate calls to test driver

GitHub user bbejeck opened a pull request: https://github.com/apache/kafka/pull/3915 MINOR: add punctuate calls to test driver You can merge this pull request into a Git repository by running: $ git pull https://github.com/bbejeck/kafka

Limit Jenkins jobs on H0 to H13

Hi, See Gavin's comment: https://issues.apache.org/jira/browse/INFRA-15084?page= com.atlassian.jira.plugin.system.issuetabpanels:comment- tabpanel=16172575#comment-16172575 Can someone with admin permission modify the Jenkins job(s) ? Thanks

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

See Changes: [wangguoz] MINOR: various random minor fixes and improve KafkaConsumer JavaDocs -- [...truncated 9.26 MB...] at

[GitHub] kafka pull request #3914: Adding See how Kafka Streams is being used section...

GitHub user manjuapu opened a pull request: https://github.com/apache/kafka/pull/3914 Adding See how Kafka Streams is being used section to Streams page You can merge this pull request into a Git repository by running: $ git pull https://github.com/confluentinc/kafka

[GitHub] kafka-site pull request #80: Added Xite and Zalando logo to Powered by page

Github user ewencp commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/80#discussion_r139852281 --- Diff: css/styles.css --- @@ -993,3 +993,76 @@ nav .btn { margin-right: 0; } } + +.customer__cards { +

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

See

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

The PR should be ready. I have removed the old merge() method for 1.0.0. On Tue, Sep 19, 2017 at 4:22 PM, Guozhang Wang wrote: > I'd like to make an exception for this KIP if it's PR can get in before the > the code freeze date, as it's a low risk small KIP that is unlikely

[GitHub] kafka pull request #3913: KAFKA-5937: Improve ProcessorStateManager exceptio...

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/3913 KAFKA-5937: Improve ProcessorStateManager exception handling You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka

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

I'd like to make an exception for this KIP if it's PR can get in before the the code freeze date, as it's a low risk small KIP that is unlikely to introduce regression. Guozhang On Wed, Sep 20, 2017 at 2:01 AM, Matthias J. Sax wrote: > @Damian, this KIP goes into 1.1

[GitHub] kafka pull request #3884: MINOR: various random minor fixes and improve Kafk...

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

[GitHub] kafka pull request #3910: MINOR: Only include transactional id in LogContext...

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

[GitHub] kafka-site pull request #80: Added Xite and Zalando logo to Powered by page

GitHub user manjuapu opened a pull request: https://github.com/apache/kafka-site/pull/80 Added Xite and Zalando logo to Powered by page You can merge this pull request into a Git repository by running: $ git pull https://github.com/manjuapu/kafka-site asf-site Alternatively

[jira] [Created] (KAFKA-5937) Improve ProcessorStateManager exception handling

Matthias J. Sax created KAFKA-5937: -- Summary: Improve ProcessorStateManager exception handling Key: KAFKA-5937 URL: https://issues.apache.org/jira/browse/KAFKA-5937 Project: Kafka Issue

[GitHub] kafka pull request #3912: KAFKA-5936: KafkaProducer.close should throw Inter...

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/3912 KAFKA-5936: KafkaProducer.close should throw InterruptException You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka

[jira] [Created] (KAFKA-5936) KafkaProducer should not wrap InterruptedException in close() with KafkaException

Matthias J. Sax created KAFKA-5936: -- Summary: KafkaProducer should not wrap InterruptedException in close() with KafkaException Key: KAFKA-5936 URL: https://issues.apache.org/jira/browse/KAFKA-5936

[GitHub] kafka pull request #3911: Kafka 5900

GitHub user rhauch opened a pull request: https://github.com/apache/kafka/pull/3911 Kafka 5900 You can merge this pull request into a Git repository by running: $ git pull https://github.com/rhauch/kafka kafka-5900 Alternatively you can review and apply these changes as the

Re: [VOTE] KIP-202

It is not possible, more than likely we are going to wait until after the release. On Tue, Sep 19, 2017 at 11:02 AM, Matthias J. Sax wrote: > +1 > > But I think we cannot get it into 1.0 as KIP vote deadline passed > already. Or is it possible to get an exception from

[GitHub] kafka pull request #3910: MINOR: Only include transactional id in LogContext...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/3910 MINOR: Only include transactional id in LogContext if it's set You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka

[GitHub] kafka pull request #3909: MINOR: Consistent terminal period in Errors.defaul...

GitHub user tombentley opened a pull request: https://github.com/apache/kafka/pull/3909 MINOR: Consistent terminal period in Errors.defaultExceptionMessage Some default messages ended with a period and some didn't, so make things consistent. The contribution is my original

[jira] [Created] (KAFKA-5935) Kafka connect should provide configurable CONNECTOR_EXCLUDES

Chen He created KAFKA-5935: -- Summary: Kafka connect should provide configurable CONNECTOR_EXCLUDES Key: KAFKA-5935 URL: https://issues.apache.org/jira/browse/KAFKA-5935 Project: Kafka Issue Type:

[GitHub] kafka-site pull request #79: Adding Customer section to Streams page

Github user ewencp commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/79#discussion_r139804545 --- Diff: 0110/streams/index.html --- @@ -202,7 +202,40 @@ The easiest way to write mission-critical real-tim -

[GitHub] kafka-site pull request #79: Adding Customer section to Streams page

Github user ewencp commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/79#discussion_r139804782 --- Diff: css/styles.css --- @@ -993,3 +993,76 @@ nav .btn { margin-right: 0; } } + +.customer__cards { +

[GitHub] kafka-site pull request #79: Adding Customer section to Streams page

Github user ewencp commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/79#discussion_r139804582 --- Diff: 0110/streams/index.html --- @@ -202,7 +202,40 @@ The easiest way to write mission-critical real-tim -

[GitHub] kafka-site pull request #79: Adding Customer section to Streams page

GitHub user manjuapu opened a pull request: https://github.com/apache/kafka-site/pull/79 Adding Customer section to Streams page You can merge this pull request into a Git repository by running: $ git pull https://github.com/manjuapu/kafka-site customer-kafka Alternatively

[jira] [Created] (KAFKA-5934) Cross build for scala 2.12

Srdan Srepfler created KAFKA-5934: - Summary: Cross build for scala 2.12 Key: KAFKA-5934 URL: https://issues.apache.org/jira/browse/KAFKA-5934 Project: Kafka Issue Type: Bug

[GitHub] kafka pull request #3908: KAFKA-5933: Move timeout and validate_only protoco...

GitHub user scholzj opened a pull request: https://github.com/apache/kafka/pull/3908 KAFKA-5933: Move timeout and validate_only protocol fields into CommonFields class Most of the fields which are shared by multiple protocol messages (requests ad responses) are in the CommonFields

[jira] [Created] (KAFKA-5933) Move timeout and validate_only protocol fields into CommonFields class

Jakub Scholz created KAFKA-5933: --- Summary: Move timeout and validate_only protocol fields into CommonFields class Key: KAFKA-5933 URL: https://issues.apache.org/jira/browse/KAFKA-5933 Project: Kafka

[GitHub] kafka pull request #3907: KAFKA-4950: Fix ConcurrentModificationException on...

GitHub user slaunay opened a pull request: https://github.com/apache/kafka/pull/3907 KAFKA-4950: Fix ConcurrentModificationException on assigned-partitions metric Code change: - prevent `java.util.ConcurrentModificationException` being thrown when fetching the consumer

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

See Changes: [jason] MINOR: Protocol schema refactor follow-up -- [...truncated 700.78 KB...] Failed to execute

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

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

Re: [VOTE] KIP-202

+1 But I think we cannot get it into 1.0 as KIP vote deadline passed already. Or is it possible to get an exception from this? -Matthias On 9/19/17 7:09 AM, Richard Yu wrote: > Kip has been changed to suit 1.0.0 release. > > On Tue, Sep 19, 2017 at 6:24 AM, Damian Guy

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

@Damian, this KIP goes into 1.1 but not 1.0, so we need to go the deprecation way... I would be happy to get it into 1.0 and avoid the deprecation. But strictly speaking, the KIP vote deadline passed already... Not sure if there is any exception from this. -Matthias On 9/19/17 12:17 AM, Damian

[GitHub] kafka pull request #3906: KAFKA-5735: KIP-190: Handle client-ids consistentl...

GitHub user mimaison opened a pull request: https://github.com/apache/kafka/pull/3906 KAFKA-5735: KIP-190: Handle client-ids consistently Developed with @edoardocomar You can merge this pull request into a Git repository by running: $ git pull

Kafka-1641

We are running into KAFKA-1641 where the log cleaner thread dies with the below INFO. Is there a work around for this issue? We are running kafka-0.9.0. 2017-09-18 16:12:41,621 INFO kafka.log.LogCleaner: Cleaner 0: Building offset map for log __consumer_offsets-16 for 2149 segments in offset

[GitHub] kafka pull request #3905: MINOR: change task initialization logging levels

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/3905 MINOR: change task initialization logging levels In `AssignedTasks` log at debug all task ids that are yet to be initialized. In `StreamsTask` log at trace when the task is initialized. You can

[GitHub] kafka pull request #3904: [MINOR] Added equals() method to Stamped

GitHub user KoenDG opened a pull request: https://github.com/apache/kafka/pull/3904 [MINOR] Added equals() method to Stamped Please don't let analyzing this PR take away from actual working time. I did this in my spare time, it's not intended to take away from your working hours.

Re: [VOTE] KIP-190: Handle client-ids consistently between clients and brokers

Thanks to everybody who voted and reviewed the KIP ! The vote passed with 5 binding +1s (Ismael, Rajini, Jason, Gwen, Jun) and 1 non-binding +1s (Edoardo) On Thu, Sep 14, 2017 at 7:57 PM, Jun Rao wrote: > Hi, Mickael, > > Thanks for the KIP. +1 from me. > > Jun > > On Thu,

Re: [VOTE] KIP-202

Kip has been changed to suit 1.0.0 release. On Tue, Sep 19, 2017 at 6:24 AM, Damian Guy wrote: > +1 > > On Tue, 19 Sep 2017 at 14:15 Bill Bejeck wrote: > > > +1 > > > > -Bill > > > > On Tue, Sep 19, 2017 at 4:41 AM, Guozhang Wang >

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

See

[jira] [Created] (KAFKA-5932) Avoid call fetchPrevious in FlushListeners

Guozhang Wang created KAFKA-5932: Summary: Avoid call fetchPrevious in FlushListeners Key: KAFKA-5932 URL: https://issues.apache.org/jira/browse/KAFKA-5932 Project: Kafka Issue Type:

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

See

Re: [VOTE] KIP-202

+1 On Tue, 19 Sep 2017 at 14:15 Bill Bejeck wrote: > +1 > > -Bill > > On Tue, Sep 19, 2017 at 4:41 AM, Guozhang Wang wrote: > > > Thanks for the KIP, +1. > > > > If we can make it in 1.0.0, I think we can just remove the merge() in > > StreamsBuilder as

Re: [VOTE] KIP-202

+1 -Bill On Tue, Sep 19, 2017 at 4:41 AM, Guozhang Wang wrote: > Thanks for the KIP, +1. > > If we can make it in 1.0.0, I think we can just remove the merge() in > StreamsBuilder as it will only be introduced in 1.0.0; if we will add it in > 1.1.0, then we indeed need to

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

See Changes: [damian.guy] MINOR: use StoreBuilder in KStreamImpl rather than StateStoreSupplier -- [...truncated 942.20 KB...] kafka.server.ReplicaManagerTest >

[GitHub] kafka pull request #3901: MINOR: Fix unresolvable address in `testUnresolvab...

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

[jira] [Created] (KAFKA-5931) Deprecate KTable#to and KTable#through

Damian Guy created KAFKA-5931: - Summary: Deprecate KTable#to and KTable#through Key: KAFKA-5931 URL: https://issues.apache.org/jira/browse/KAFKA-5931 Project: Kafka Issue Type: Sub-task

[GitHub] kafka pull request #3903: KAFKA-5931: deprecate KTable#through and KTable#to

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/3903 KAFKA-5931: deprecate KTable#through and KTable#to You can merge this pull request into a Git repository by running: $ git pull https://github.com/dguy/kafka deprectate-to-through Alternatively

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

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

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

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H18 (ubuntu xenial) in workspace

[GitHub] kafka pull request #3902: KAFKA-5922: Add SessionWindowedKStream

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/3902 KAFKA-5922: Add SessionWindowedKStream Add `SessionWindowedKStream` and implementation. Deprecate existing `SessionWindow` `aggregate` methods on `KGroupedStream` You can merge this pull request into

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

See

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

See Changes: [damian.guy] KAFKA-5921; add Materialized overloads to windowed kstream -- [...truncated 2.10 MB...] public KTable outerJoin(final

[jira] [Created] (KAFKA-5930) Decide on consistent method for determining elapsed time.

Koen De Groote created KAFKA-5930: - Summary: Decide on consistent method for determining elapsed time. Key: KAFKA-5930 URL: https://issues.apache.org/jira/browse/KAFKA-5930 Project: Kafka

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

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

[GitHub] kafka pull request #3901: MINOR: Fix unresolvable address in `testUnresolvab...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/3901 MINOR: Fix unresolvable address in `testUnresolvableConnectString` Before this change, the test always failed on my MacBook Pro. You can merge this pull request into a Git repository by running:

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

Thanks for the reviews. @Ted Updated the KIP. @Tom I think we can interpret usernames as locale independent strings. I am planning to use Locale.ENGLISH for case conversion. Updated the KIP. Let me know If you have any concerns. On Tue, Sep 19, 2017 at 12:58 AM, Tom Bentley

[GitHub] kafka pull request #3898: KAFKA-4320: Log cleaner is enabled by default

GitHub user scholzj opened a pull request: https://github.com/apache/kafka/pull/3898 KAFKA-4320: Log cleaner is enabled by default The log cleaner is enabled by default since 0.9.0.1. But the 0.9.0 docs are not updated. This PR updates the docs to say that it is enabled by default.

[GitHub] kafka pull request #3900: KAFKA-4320: Clarify the log compaction config prop...

GitHub user scholzj opened a pull request: https://github.com/apache/kafka/pull/3900 KAFKA-4320: Clarify the log compaction config property per-topic and per-broker The per-topic config property is different from the per-broker. This PR makes it a bit more clear. You can merge

[GitHub] kafka pull request #3899: KAFKA-4320: Log cleaner is enabled by default

GitHub user scholzj opened a pull request: https://github.com/apache/kafka/pull/3899 KAFKA-4320: Log cleaner is enabled by default The log cleaner is enabled by default since 0.9.0.1. But the 0.10.0 docs are not updated. This PR updates the docs to say that it is enabled by

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

Hi Paolo, Thanks for the KIP. What errors can be anticipated for the API method (See https://issues.apache.org/jira/browse/KAFKA-5445)? It's not mentioned in KIP-107, but maybe now is a good time to consider whether there should be some kind of DeleteRecordsPolicy, like there is for creating

Re: [VOTE] KIP-202

Thanks for the KIP, +1. If we can make it in 1.0.0, I think we can just remove the merge() in StreamsBuilder as it will only be introduced in 1.0.0; if we will add it in 1.1.0, then we indeed need to deprecate it. Guozhang On Tue, Sep 19, 2017 at 7:29 AM, Richard Yu

[GitHub] kafka pull request #3897: KAFKA-5929: Save pre-assignment to file to avoid t...

GitHub user uncleGen opened a pull request: https://github.com/apache/kafka/pull/3897 KAFKA-5929: Save pre-assignment to file to avoid too long text to display when do topic partition reassign You can merge this pull request into a Git repository by running: $ git pull

[jira] [Created] (KAFKA-5929) Save pre-assignment to file to avoid too long text to display when do topic partition reassign

Genmao Yu created KAFKA-5929: Summary: Save pre-assignment to file to avoid too long text to display when do topic partition reassign Key: KAFKA-5929 URL: https://issues.apache.org/jira/browse/KAFKA-5929

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

Hi Richard, Thanks for the KIP. Looks good, just one thing: we don't need to deprecate StreamBuilder#merge as it has been added during this release cycle. It can just be removed. Thanks, Damian On Mon, 18 Sep 2017 at 23:22 Richard Yu wrote: > The discussion should

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

See

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

See Changes: [ismael] MINOR: Refer consistently to server.properties in security docs -- [...truncated 949.51 KB...] at

[GitHub] kafka pull request #3896: KAFKA-5914 add message format version and message ...

GitHub user apurvam opened a pull request: https://github.com/apache/kafka/pull/3896 KAFKA-5914 add message format version and message max bytes to metadata response Updated the `TopicResponse` part of the `MetadataResponse` to include the message format version and the message