Re??[VOTE] KIP-148: Add a connect timeout for client

2017-07-09 Thread ????????
Hi All, No one voted for this KIP yet, do we need more discussions? Does anyone have any idea about this KIP? Looking forward to your reply. Thanks, David -- -- ??: "";<254479...@qq.com>; : 2017??6??10??(??) 11:48 ???

Re: [DISCUSS] Streams DSL/StateStore Refactoring

2017-07-09 Thread Matthias J. Sax
I think we do have a very good discussion and people openly share their ideas. So I am not sure why your are frustrated (at least I get this impression). Maybe it might be best if you propose an API change by yourself similar to what Damian and Guozhang did (to whatever extend your time constraint

[GitHub] kafka pull request #3509: [DO NOT MERGE] Upgrade to 5.4.5

2017-07-09 Thread guozhangwang
GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/3509 [DO NOT MERGE] Upgrade to 5.4.5 This is for testing. You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KMinor-rocksdb-5.4.5

[GitHub] kafka pull request #3494: MINOR: Move quickstart under streams

2017-07-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3494 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[GitHub] kafka pull request #3510: HOTFIX: fix a few typos on streams quickstart

2017-07-09 Thread guozhangwang
GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/3510 HOTFIX: fix a few typos on streams quickstart You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KHotfix-streams-quickstart

[jira] [Created] (KAFKA-5575) SchemaBuilder should have a method to clone an existing Schema.

2017-07-09 Thread Jeremy Custenborder (JIRA)
Jeremy Custenborder created KAFKA-5575: -- Summary: SchemaBuilder should have a method to clone an existing Schema. Key: KAFKA-5575 URL: https://issues.apache.org/jira/browse/KAFKA-5575 Project: Ka

[GitHub] kafka pull request #3511: KAFKA-5575 - Add SchemaBuilder.from

2017-07-09 Thread jcustenborder
GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/3511 KAFKA-5575 - Add SchemaBuilder.from Added `SchemaBuilder.from` method which allows creating a schema builder prepopulated with the details from the schema. Added tests for structs, maps, arra

[GitHub] kafka pull request #3512: KAFKA-5574: add thread.id header in show-detailed-...

2017-07-09 Thread cnZach
GitHub user cnZach opened a pull request: https://github.com/apache/kafka/pull/3512 KAFKA-5574: add thread.id header in show-detailed-stats report kafka-consumer-perf-test.sh report missing one header column: time, data.consumed.in.MB, MB.sec, data.consumed.in.nMsg, nMsg.se