[GitHub] kafka pull request #4108: KAFKA-6101 Reconnecting to broker does not exponen...

2017-10-20 Thread tedyu
GitHub user tedyu opened a pull request: https://github.com/apache/kafka/pull/4108 KAFKA-6101 Reconnecting to broker does not exponentially backoff You can merge this pull request into a Git repository by running: $ git pull https://github.com/tedyu/kafka trunk Alternatively

Jenkins build is back to normal : kafka-1.0-jdk7 #48

2017-10-20 Thread Apache Jenkins Server
See

Re: [DISCUSS] KIP-210: Provide for custom error handling when Kafka Streams fails to produce

2017-10-20 Thread Matt Farmer
I did some more digging tonight. @Ted: It looks like the deserialization handler uses "default.deserialization.exception.handler" for the config name. No ".class" on the end. I'm inclined to think this should use "default.production.exception.handler". On Fri, Oct 20, 2017 at 8:22 PM Matt Farmer

Re: [DISCUSS] KIP-210: Provide for custom error handling when Kafka Streams fails to produce

2017-10-20 Thread Matt Farmer
Okay, I've dug into this a little bit. I think getting access to the serialized record is possible, and changing the naming and return type is certainly doable. However, because we're hooking into the onCompletion callback we have no guarantee that the ProcessorContext state hasn't changed by the

[GitHub] kafka pull request #4100: KAFKA-6093; log.close() should not prevent log fro...

2017-10-20 Thread lindong28
Github user lindong28 closed the pull request at: https://github.com/apache/kafka/pull/4100 ---

[GitHub] kafka pull request #4107: JDK 9 no longer contains JAXB API's as default

2017-10-20 Thread narcisoguillen
GitHub user narcisoguillen opened a pull request: https://github.com/apache/kafka/pull/4107 JDK 9 no longer contains JAXB API's as default You can merge this pull request into a Git repository by running: $ git pull https://github.com/narcisoguillen/kafka trunk Alternatively

[GitHub] kafka pull request #4106: Kafka 5849

2017-10-20 Thread cmccabe
GitHub user cmccabe opened a pull request: https://github.com/apache/kafka/pull/4106 Kafka 5849 You can merge this pull request into a Git repository by running: $ git pull https://github.com/cmccabe/kafka KAFKA-5849 Alternatively you can review and apply these changes as the

[GitHub] kafka pull request #4105: KAFKA-6102: Consolidate MockTime implementations b...

2017-10-20 Thread cmccabe
GitHub user cmccabe opened a pull request: https://github.com/apache/kafka/pull/4105 KAFKA-6102: Consolidate MockTime implementations between connect and … …clients You can merge this pull request into a Git repository by running: $ git pull https://github.com/cmccabe/kafka

[jira] [Created] (KAFKA-6102) Consolidate MockTime implementations between connect and clients

2017-10-20 Thread Colin P. McCabe (JIRA)
Colin P. McCabe created KAFKA-6102: -- Summary: Consolidate MockTime implementations between connect and clients Key: KAFKA-6102 URL: https://issues.apache.org/jira/browse/KAFKA-6102 Project: Kafka

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

2017-10-20 Thread Colin McCabe
> /** Describe records to delete */ > public class DeleteRecords { > private Long offset; "DeleteRecords" doesn't really explain what the class is, though. How about "DeletionTarget"? Also, why do we need a Long object rather than a long primitive? > > /** > * Delete all

[jira] [Created] (KAFKA-6101) Reconnecting to broker does not exponentially backoff

2017-10-20 Thread Sean Rohead (JIRA)
Sean Rohead created KAFKA-6101: -- Summary: Reconnecting to broker does not exponentially backoff Key: KAFKA-6101 URL: https://issues.apache.org/jira/browse/KAFKA-6101 Project: Kafka Issue Type: B

Re: [VOTE] 1.0.0 RC2

2017-10-20 Thread Vahid S Hashemian
Guozhang, I created KAFKA-6100 for the issue: https://issues.apache.org/jira/browse/KAFKA-6100 An interim fix could be downgrading the version of RocksDB to 5.7.3. Thanks. --Vahid From: Guozhang Wang To: "dev@kafka.apache.org" Date: 10/19/2017 08:59 PM Subject:Re: [VOTE] 1.

[jira] [Created] (KAFKA-6100) Streams quick start crashes Java on Windows

2017-10-20 Thread Vahid Hashemian (JIRA)
Vahid Hashemian created KAFKA-6100: -- Summary: Streams quick start crashes Java on Windows Key: KAFKA-6100 URL: https://issues.apache.org/jira/browse/KAFKA-6100 Project: Kafka Issue Type: Bu

[GitHub] kafka pull request #4104: MINOR: add hint for setting an uncaught exception ...

2017-10-20 Thread mjsax
GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/4104 MINOR: add hint for setting an uncaught exception handler to JavaDocs You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka minor-uncaught-e

[jira] [Created] (KAFKA-6099) Seeking consumer to evicted offset resets the offset

2017-10-20 Thread Viliam Durina (JIRA)
Viliam Durina created KAFKA-6099: Summary: Seeking consumer to evicted offset resets the offset Key: KAFKA-6099 URL: https://issues.apache.org/jira/browse/KAFKA-6099 Project: Kafka Issue Type

[jira] [Created] (KAFKA-6098) Delete and Re-create topic operation could result in race condition

2017-10-20 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6098: Summary: Delete and Re-create topic operation could result in race condition Key: KAFKA-6098 URL: https://issues.apache.org/jira/browse/KAFKA-6098 Project: Kafka

[jira] [Created] (KAFKA-6097) Kafka ssl.endpoint.identification.algorithm=HTTPS not working

2017-10-20 Thread Damyan Petev Manev (JIRA)
Damyan Petev Manev created KAFKA-6097: - Summary: Kafka ssl.endpoint.identification.algorithm=HTTPS not working Key: KAFKA-6097 URL: https://issues.apache.org/jira/browse/KAFKA-6097 Project: Kafka

[jira] [Created] (KAFKA-6096) Add concurrent tests to exercise all paths in group/transaction managers

2017-10-20 Thread Rajini Sivaram (JIRA)
Rajini Sivaram created KAFKA-6096: - Summary: Add concurrent tests to exercise all paths in group/transaction managers Key: KAFKA-6096 URL: https://issues.apache.org/jira/browse/KAFKA-6096 Project: Kaf

[GitHub] kafka pull request #4103: KAFKA-6042: Avoid deadlock between two groups with...

2017-10-20 Thread rajinisivaram
GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/4103 KAFKA-6042: Avoid deadlock between two groups with delayed operations You can merge this pull request into a Git repository by running: $ git pull https://github.com/rajinisivaram/kafka

[jira] [Created] (KAFKA-6095) Error when displaying LAG information consumer partitions that use zookeeper

2017-10-20 Thread Jorge (JIRA)
Jorge created KAFKA-6095: Summary: Error when displaying LAG information consumer partitions that use zookeeper Key: KAFKA-6095 URL: https://issues.apache.org/jira/browse/KAFKA-6095 Project: Kafka I

[jira] [Resolved] (KAFKA-5970) Deadlock due to locking of DelayedProduce and group

2017-10-20 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-5970. --- Resolution: Fixed The new deadlock will be fixed under KAFKA-6042 > Deadlock due to locking o

Before creating KIP : Kafka Connect / Add a configuration provider class

2017-10-20 Thread Florian Hussonnois
Hi Team Before submitting a new KIP I would like to open the discussion regarding an enhancement of Kafka Connect. Currently, the only way to configure a connector (in distributed mode) is through REST endpoints while creating or updating a connector. It would be nice to have the possibility to

[GitHub] kafka pull request #4102: MINOR: Update Scala to 2.12.4

2017-10-20 Thread ijuma
GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/4102 MINOR: Update Scala to 2.12.4 Mainly for Java 9 fixes and improved compilation times (5-10% reduction). You can merge this pull request into a Git repository by running: $ git pull https://github

[jira] [Reopened] (KAFKA-5970) Deadlock due to locking of DelayedProduce and group

2017-10-20 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reopened KAFKA-5970: --- [~corlettb] Thank you for reporting this. Looks like there is another potential deadlock as well

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

2017-10-20 Thread Paolo Patierno
Hi all, I have just updated the KIP with your suggestion. I'm going to continue implementation and tests with these changes, waiting for further discussion. Thanks, Paolo Patierno Senior Software Engineer (IoT) @ Red Hat Microsoft MVP on Azure & IoT Microsoft Azure Advisor Twitter : @ppati

[jira] [Resolved] (KAFKA-5574) kafka-consumer-perf-test.sh report header has one less column in show-detailed-stats mode

2017-10-20 Thread Yuexin Zhang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuexin Zhang resolved KAFKA-5574. - Resolution: Duplicate Resolved in KAFKA-5358 https://github.com/apache/kafka/blame/trunk/core/src

Re: [DISCUSS] KIP-179: Change ReassignPartitionsCommand to use AdminClient

2017-10-20 Thread Tom Bentley
Hi, I've made a fairly major update to KIP-179 to propose APIs for setting throttled rates and throttled replicas with the ability to remove these automatically at the end of reassignment. I'd be grateful for your feedback: https://cwiki.apache.org/confluence/display/KAFKA/KIP-179+-+Change+Reass

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

2017-10-20 Thread Apache Jenkins Server
See Changes: [me] MINOR: Use ObjectName.quote instead of URL-encoding for JMX metric tags -- [...truncated 3.79 MB...] org.apache.kafka.connect.runtime.distributed.Distri