[GitHub] kafka pull request #3750: KafkaConsumer was hung when bootstrap servers was ...

GitHub user kyleabcha opened a pull request: https://github.com/apache/kafka/pull/3750 KafkaConsumer was hung when bootstrap servers was not existed Could anyone help me on this? We have an issue if we entered an non-existed host:port for bootstrap.servers property on

[GitHub] kafka pull request #3749: [KAFKA-4793] Restart tasks for connector endpoint

GitHub user holdenk opened a pull request: https://github.com/apache/kafka/pull/3749 [KAFKA-4793] Restart tasks for connector endpoint As suggested in KAFKA-4793 users may sometimes want to restart all of the tasks associated with a given connection. This proposed change adds a new

Re: [DISCUSS] KIP-91 Provide Intuitive User Timeouts in The Producer

Hi, Jiangjie, If we want to enforce delivery.timeout.ms, we need to take the min right? Also, if a user sets a large delivery.timeout.ms, we probably don't want to wait for an inflight request longer than request.timeout.ms. Thanks, Jun On Fri, Aug 25, 2017 at 5:19 PM, Becket Qin

[GitHub] kafka pull request #3748: KAFKA-5797: Delay checking of partition existence ...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/3748 KAFKA-5797: Delay checking of partition existence in StoreChangelogReader 1. Remove timeout-based validatePartitionExists from StoreChangelogReader; instead only try to refresh metadata once

Permission to create KIP for discussions and the max.in.flight.requests.per.connection config doc

Hi , I would like to have have some permissions to create a KIP and start a discussion. I think I was able to create a JIRA but cant do anything more beyond that. I guess the process is to first create a KIP and get it discussed and voted. https://issues.apache.org/jira/browse/KAFKA-5761 Can

[GitHub] kafka pull request #3747: KAFKA-5787: StoreChangelogReader needs to restore ...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/3747 KAFKA-5787: StoreChangelogReader needs to restore partitions that were added post initialization If a task fails during initialization due to a LockException, its changelog partitions are not

Jenkins build is back to normal : kafka-0.11.0-jdk7 #287

See

[GitHub] kafka pull request #3731: KAFKA-5720: Fix AdminClientIntegrationTest#testCal...

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

[jira] [Resolved] (KAFKA-4380) Update the usage description of clean shutdown file.

[ https://issues.apache.org/jira/browse/KAFKA-4380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4380. Resolution: Fixed Fix Version/s: 1.0.0 > Update the usage description of clean shutdown

[GitHub] kafka pull request #3742: [KAFKA-4380] Document the purpose of clean shutdow...

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