[GitHub] kafka pull request #2347: Initial commit of partition assignment check in co...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2347 --- 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

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

See -- [...truncated 8 lines...] at org.jenkinsci.plugins.gitclient.CliGitAPIImpl.launchCommandIn(CliGitAPIImpl.java:1695) at

[GitHub] kafka pull request #2504: KAFKA-4735; Fix deadlock issue during MM shutdown

GitHub user lindong28 opened a pull request: https://github.com/apache/kafka/pull/2504 KAFKA-4735; Fix deadlock issue during MM shutdown You can merge this pull request into a Git repository by running: $ git pull https://github.com/lindong28/kafka KAFKA-4735 Alternatively

Re: [DISCUSS] KIP-117: Add a public AdministrativeClient API for Kafka admin operations

Hi Colin, I was thinking about the API and the fact that the AdminClient will be used by a variety of somewhat unrelated things (unlike the Consumer and Producer), so I think we should consider an approach where not all the methods are at the top-level. One idea is that you could perform

[jira] [Created] (KAFKA-4735) Fix deadlock issue during MM shutdown

Dong Lin created KAFKA-4735: --- Summary: Fix deadlock issue during MM shutdown Key: KAFKA-4735 URL: https://issues.apache.org/jira/browse/KAFKA-4735 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-4558) throttling_test fails if the producer starts too fast.

[ https://issues.apache.org/jira/browse/KAFKA-4558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4558. Resolution: Fixed Fix Version/s: 0.10.2.0 Issue resolved by pull request 2347

Re: [VOTE] KIP-48 Support for delegation tokens as an authentication mechanism

Hi Jun, Please see the replies inline. > > > > Only one broker does the deletion. Broker updates the expiration in its > > local cache > > and on zookeeper so other brokers also get notified and their cache > > statuses are updated as well. > > > > > Which broker does the deletion? > Any

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

See Changes: [ismael] KAFKA-4558; throttling_test fails if the producer starts too fast -- [...truncated 32030 lines...] kafka.api.RackAwareAutoTopicCreationTest > testAutoCreateTopic STARTED

[jira] [Created] (KAFKA-4736) producer failed too slow when meta request failed

Jun Yao created KAFKA-4736: -- Summary: producer failed too slow when meta request failed Key: KAFKA-4736 URL: https://issues.apache.org/jira/browse/KAFKA-4736 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-4385) producer is sending too many unnecessary meta data request if the meta data for a topic is not available and "auto.create.topics.enable" =false

[ https://issues.apache.org/jira/browse/KAFKA-4385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15853324#comment-15853324 ] Jun Yao commented on KAFKA-4385: [~ewencp] is it possible to have some server side support to have better

[jira] [Updated] (KAFKA-4276) REST configuration not visible in connector properties config files

[ https://issues.apache.org/jira/browse/KAFKA-4276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Akhilesh Naidu updated KAFKA-4276: -- Reviewer: Ewen Cheslack-Postava Status: Patch Available (was: Open) > REST configuration

Re: [DISCUSS] KIP-117: Add a public AdministrativeClient API for Kafka admin operations

+1 for ismael's suggestion. grouping of methods by the relevant resource will simply the API. In future, we will be adding delegation token related operations to admin client. I can imagine methods like adminClient.token().create(...), adminClient.token().renew(...), etc.. Thanks, Manikumar On

[jira] [Commented] (KAFKA-4722) Add application.id to StreamThread name

[ https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15853260#comment-15853260 ] Sharad commented on KAFKA-4722: --- PR submitted: https://github.com/apache/kafka/pull/2487 > Add

[jira] [Commented] (KAFKA-4737) Streams apps hang if started when brokers are not available

[ https://issues.apache.org/jira/browse/KAFKA-4737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15853422#comment-15853422 ] Umesh Chaudhary commented on KAFKA-4737: Hi [~gwenshap], does the intent is similar to KAFKA-4564?

[jira] [Resolved] (KAFKA-4737) Streams apps hang if started when brokers are not available

[ https://issues.apache.org/jira/browse/KAFKA-4737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-4737. - Resolution: Duplicate > Streams apps hang if started when brokers are not available >

[jira] [Commented] (KAFKA-4737) Streams apps hang if started when brokers are not available

[ https://issues.apache.org/jira/browse/KAFKA-4737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15853423#comment-15853423 ] Gwen Shapira commented on KAFKA-4737: - It is! Sorry for the duplicate. I'll close this. > Streams

[jira] [Commented] (KAFKA-4737) Streams apps hang if started when brokers are not available

[ https://issues.apache.org/jira/browse/KAFKA-4737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15853424#comment-15853424 ] Umesh Chaudhary commented on KAFKA-4737: No worries. Thanks [~gwenshap] ! > Streams apps hang if

[jira] [Created] (KAFKA-4737) Streams apps hang if started when brokers are not available

Gwen Shapira created KAFKA-4737: --- Summary: Streams apps hang if started when brokers are not available Key: KAFKA-4737 URL: https://issues.apache.org/jira/browse/KAFKA-4737 Project: Kafka

[GitHub] kafka pull request #2505: KAFKA-4276: Add REST configuration in connector pr...

GitHub user akhilesh1194 opened a pull request: https://github.com/apache/kafka/pull/2505 KAFKA-4276: Add REST configuration in connector properties Addition of REST configuration in connect-distributed.properties config file @gwenshap @ewencp - Please review. You can merge

[jira] [Commented] (KAFKA-4276) REST configuration not visible in connector properties config files

[ https://issues.apache.org/jira/browse/KAFKA-4276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15853573#comment-15853573 ] ASF GitHub Bot commented on KAFKA-4276: --- GitHub user akhilesh1194 opened a pull request: