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

2018-04-01 Thread Apache Jenkins Server
See

[jira] [Created] (KAFKA-6737) Is Kafka imapcted by critical vulnerqbilty CVE-2018-7489

2018-04-01 Thread Akansh Shandilya (JIRA)
Akansh Shandilya created KAFKA-6737: --- Summary: Is Kafka imapcted by critical vulnerqbilty CVE-2018-7489 Key: KAFKA-6737 URL: https://issues.apache.org/jira/browse/KAFKA-6737 Project: Kafka

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

2018-04-01 Thread Apache Jenkins Server
See Changes: [wangguoz] KAFKA-6732: Fix Streams doc ref link (#4806) -- [...truncated 1.48 MB...] kafka.server.epoch.LeaderEpochFileCacheTest > shouldNotResetEpochHistoryT

[jira] [Resolved] (KAFKA-6731) waitOnState waits for the wrong state instead of the target one

2018-04-01 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6731. -- Resolution: Fixed Fix Version/s: 1.2.0 > waitOnState waits for the wrong state instead of

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

2018-04-01 Thread Apache Jenkins Server
See Changes: [github] MINOR: refactor error message of task migration (#4803) [wangguoz] KAFKA-6732: Fix Streams doc ref link (#4806) -- [...truncated 422.61 KB...] kafk

Re: [DISCUSSION] KIP-266: Add TimeoutException to KafkaConsumer#position()

2018-04-01 Thread Richard Yu
Hi Guozhang, I have clarified the KIP a bit to account for Becket's suggestion on ClientTimeoutException. About adding an extra config, you were right about my intentions. I am just wondering if the config should be included, since Ismael seems to favor an extra configuration, Thanks, Richard On

[jira] [Created] (KAFKA-6735) Document how to skip findbugs / checkstyle when running unit test

2018-04-01 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6735: - Summary: Document how to skip findbugs / checkstyle when running unit test Key: KAFKA-6735 URL: https://issues.apache.org/jira/browse/KAFKA-6735 Project: Kafka Issue Type

[jira] [Created] (KAFKA-6734) TopicMetadataTest is flaky

2018-04-01 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6734: - Summary: TopicMetadataTest is flaky Key: KAFKA-6734 URL: https://issues.apache.org/jira/browse/KAFKA-6734 Project: Kafka Issue Type: Test Reporter: Ted Yu I

[jira] [Resolved] (KAFKA-6732) 404 on streams/developer-guide/write-streams.html for processor topology

2018-04-01 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6732. -- Resolution: Fixed Fix Version/s: 1.1.0 > 404 on streams/developer-guide/write-streams.htm

Re: [DISCUSS] KIP-276: Add StreamsConfig prefix for different consumers

2018-04-01 Thread Guozhang Wang
Thanks for the KIP Boyang, the KIP looks good to me. For config values, we use underscore for keeping a single word; for config keys, though, we do not use underscores or dashes. I'd suggest using dots to be consistent with others. Otherwise I'm +1 on the KIP. Guozhang On Sun, Apr 1, 2018 at

Re: [DISCUSSION] KIP-266: Add TimeoutException to KafkaConsumer#position()

2018-04-01 Thread Guozhang Wang
Hi Richard, Regarding the streams side changes, we plan to incorporate with the new APIs once the KIP is done, which is only internal code changes and hence do not need to include in the KIP. Could you update the KIP because it has been quite obsoleted from the discussed topics, and I'm a bit loo

[jira] [Created] (KAFKA-6733) Support of printing additional ConsumerRecord fields in DefaultMessageFormatter

2018-04-01 Thread Mateusz Zakarczemny (JIRA)
Mateusz Zakarczemny created KAFKA-6733: -- Summary: Support of printing additional ConsumerRecord fields in DefaultMessageFormatter Key: KAFKA-6733 URL: https://issues.apache.org/jira/browse/KAFKA-6733

Re: [DISCUSS] KIP-276: Add StreamsConfig prefix for different consumers

2018-04-01 Thread Ted Yu
Looks good overall. public static final String RESTORE_CONSUMER_PREFIX = "restore-consumer."; For other constants in StreamsConfig, underscore is used instead of dash. Cheers On Sun, Apr 1, 2018 at 9:38 AM, Boyang Chen wrote: > Hey friends, > > > I would like to start a discussion thread for

[DISCUSS] KIP-276: Add StreamsConfig prefix for different consumers

2018-04-01 Thread Boyang Chen
Hey friends, I would like to start a discussion thread for KIP 276: https://cwiki.apache.org/confluence/display/KAFKA/KIP-276+Add+StreamsConfig+prefix+for+different+consumers And pull request is here: https://github.com/apache/kafka/pull/4805 [https://avatars3.githubusercontent.com/u/5845561

[jira] [Created] (KAFKA-6732) 404 on streams/developer-guide/write-streams.html for processor topology

2018-04-01 Thread robin m (JIRA)
robin m created KAFKA-6732: -- Summary: 404 on streams/developer-guide/write-streams.html for processor topology Key: KAFKA-6732 URL: https://issues.apache.org/jira/browse/KAFKA-6732 Project: Kafka I

[jira] [Created] (KAFKA-6731) waitOnState waits for the wrong state instead of the target one

2018-04-01 Thread huxihx (JIRA)
huxihx created KAFKA-6731: - Summary: waitOnState waits for the wrong state instead of the target one Key: KAFKA-6731 URL: https://issues.apache.org/jira/browse/KAFKA-6731 Project: Kafka Issue Type: