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

See Changes: [wangguoz] KAFKA-4607: Validate the names of auto-generated internal topics -- [...truncated 709.28 KB...] org.apache.kafka.streams.KafkaStreamsTest >

[jira] [Commented] (KAFKA-4917) Our built-in file connector can't work with our built-in SMT

[ https://issues.apache.org/jira/browse/KAFKA-4917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15930957#comment-15930957 ] Gwen Shapira commented on KAFKA-4917: - I guess I could use HOIST transformation to create a struct :)

[jira] [Updated] (KAFKA-4917) Our built-in file connector can't work with our built-in SMT

[ https://issues.apache.org/jira/browse/KAFKA-4917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-4917: Labels: newbie (was: ) > Our built-in file connector can't work with our built-in SMT >

[jira] [Created] (KAFKA-4917) Our built-in file connector can't work with our built-in SMT

Gwen Shapira created KAFKA-4917: --- Summary: Our built-in file connector can't work with our built-in SMT Key: KAFKA-4917 URL: https://issues.apache.org/jira/browse/KAFKA-4917 Project: Kafka

[jira] [Updated] (KAFKA-4750) KeyValueIterator returns null values

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4750: - Labels: newbie (was: ) > KeyValueIterator returns null values >

Jenkins build is back to normal : kafka-trunk-jdk7 #2023

See

[jira] [Commented] (KAFKA-4878) Kafka Connect does not log connector configuration errors

[ https://issues.apache.org/jira/browse/KAFKA-4878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15930895#comment-15930895 ] Armin Braun commented on KAFKA-4878: Looking into this tomorrow :) > Kafka Connect does not log

[jira] [Assigned] (KAFKA-4878) Kafka Connect does not log connector configuration errors

[ https://issues.apache.org/jira/browse/KAFKA-4878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Armin Braun reassigned KAFKA-4878: -- Assignee: Armin Braun > Kafka Connect does not log connector configuration errors >

[jira] [Resolved] (KAFKA-4464) Clean shutdown of broker fails due to controller error

[ https://issues.apache.org/jira/browse/KAFKA-4464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xavier Lange resolved KAFKA-4464. - Resolution: Cannot Reproduce Fix Version/s: 0.10.1.0 I am no longer running this build of

[GitHub] kafka pull request #2696: MINOR: Guard against NPE when throwing StreamsExce...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2696 --- 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] [Commented] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15930823#comment-15930823 ] Guozhang Wang commented on KAFKA-4890: -- Thanks [~yunolgun] that is super useful, will circle back

[jira] [Comment Edited] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15930749#comment-15930749 ] Yunus Olgun edited comment on KAFKA-4890 at 3/17/17 9:26 PM: - Following test

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

See Changes: [ismael] MINOR: Fix non-null check in the constructor of ListenerName [ismael] KAFKA-4895; Fix findbugs "format string should use %n rather than \n" in --

[jira] [Commented] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15930749#comment-15930749 ] Yunus Olgun commented on KAFKA-4890: Following test passes at Windows but fails at Ubuntu 16.04.1 LTS.

Build failed in Jenkins: kafka-trunk-jdk7 #2022

See Changes: [wangguoz] KAFKA-4607: Validate the names of auto-generated internal topics -- [...truncated 620.12 KB...] org.apache.kafka.clients.NodeApiVersionsTest >

[GitHub] kafka pull request #2702: MINOR: improvements on log4j of StreamThread

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/2702 MINOR: improvements on log4j of StreamThread You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka

[jira] [Commented] (KAFKA-4887) Enabling caching on a persistent window store breaks support for duplicate insertion

[ https://issues.apache.org/jira/browse/KAFKA-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15930727#comment-15930727 ] Guozhang Wang commented on KAFKA-4887: -- Got it. Thanks. As for the fix, we should probably consider

[jira] [Commented] (KAFKA-4607) Kafka Streams allows you to provide strings with illegal characters for internal topic names

[ https://issues.apache.org/jira/browse/KAFKA-4607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15930509#comment-15930509 ] ASF GitHub Bot commented on KAFKA-4607: --- Github user asfgit closed the pull request at:

[GitHub] kafka pull request #2331: KAFKA-4607: Validate the names of auto-generated i...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2331 --- 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-4607) Kafka Streams allows you to provide strings with illegal characters for internal topic names

[ https://issues.apache.org/jira/browse/KAFKA-4607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4607. -- Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 2331

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15930379#comment-15930379 ] Dmitry Minkovsky commented on KAFKA-4750: - Can confirm I experienced this on 0.10.1 as well. >

Re: [VOTE] KIP-117: Add a public AdminClient API for Kafka admin operations

Hi, Colin, Thanks for the KIP. Looks good overall. A few comments below. 1. Sometimes we return CompletableFuture> and some other times we return Map , which doesn't seem consistent. Is that intentional? 2. We support batching in

[jira] [Updated] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunus Olgun updated KAFKA-4890: --- Attachment: logs3.tar.gz > State directory being deleted when another thread holds the lock >

[jira] [Commented] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15930312#comment-15930312 ] Yunus Olgun commented on KAFKA-4890: It was harder to reproduce with trunk but it is still there.

[jira] [Updated] (KAFKA-4916) Add streams tests with brokers failing

[ https://issues.apache.org/jira/browse/KAFKA-4916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4916: Priority: Critical (was: Major) > Add streams tests with brokers failing >

[jira] [Created] (KAFKA-4916) Add streams tests with brokers failing

Eno Thereska created KAFKA-4916: --- Summary: Add streams tests with brokers failing Key: KAFKA-4916 URL: https://issues.apache.org/jira/browse/KAFKA-4916 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-4842) Streams integration tests occasionally fail with connection error

[ https://issues.apache.org/jira/browse/KAFKA-4842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska resolved KAFKA-4842. - Resolution: Won't Fix Auto-fixed now that KAFKA-4841 is fixed. > Streams integration tests

[jira] [Created] (KAFKA-4915) Make logging consistent

Andrey created KAFKA-4915: - Summary: Make logging consistent Key: KAFKA-4915 URL: https://issues.apache.org/jira/browse/KAFKA-4915 Project: Kafka Issue Type: Bug Affects Versions: 0.10.1.1

Jenkins build is back to normal : kafka-trunk-jdk7 #2020

See

[jira] [Commented] (KAFKA-3594) Kafka new producer retries doesn't work in 0.9.0.1

[ https://issues.apache.org/jira/browse/KAFKA-3594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15930084#comment-15930084 ] Phil Adams commented on KAFKA-3594: --- I found out via the kafka users mailing list that this fix is in

[jira] [Commented] (KAFKA-4895) Fix findbugs "format string should use %n rather than \n" in tools

[ https://issues.apache.org/jira/browse/KAFKA-4895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15930005#comment-15930005 ] ASF GitHub Bot commented on KAFKA-4895: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-4895) Fix findbugs "format string should use %n rather than \n" in tools

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

[GitHub] kafka pull request #2684: KAFKA-4895: Fix findbugs "format string should use...

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

[GitHub] kafka pull request #2700: MINOR: Precondition check corrected

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

Re: [DISCUSS] KIP-82 - Add Record Headers

Jun, the message format you proposed seems reasonable to me. I have a few minor comments with regards to the user facing API: 1. Do we want to expose the `close()` method in the Headers interface? It seems that this method should only be called by the producer after the headers have been passed

[GitHub] kafka pull request #2701: MINOR: Update compatibility system tests to includ...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/2701 MINOR: Update compatibility system tests to include 0.10.2.0 You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka

[GitHub] kafka pull request #2700: MINOR: Precondition check corrected

GitHub user Kamal15 opened a pull request: https://github.com/apache/kafka/pull/2700 MINOR: Precondition check corrected You can merge this pull request into a Git repository by running: $ git pull https://github.com/Kamal15/kafka precondition Alternatively you can review

[GitHub] kafka pull request #2698: MINOR: Increase Throttle lower bound assertion in ...

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

See Changes: [ismael] MINOR: Log error if offsets topic creation fails -- [...truncated 158.41 KB...] kafka.log.LogTest > testParseTopicPartitionName STARTED

[GitHub] kafka pull request #2652: MINOR: add warning when offset topic is not replic...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2652 --- 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] [Updated] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunus Olgun updated KAFKA-4890: --- Attachment: logs2.tar.gz > State directory being deleted when another thread holds the lock >

[jira] [Commented] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929695#comment-15929695 ] Yunus Olgun commented on KAFKA-4890: I applied the pull request to confluentinc/kafka 3.2.0-post

[jira] [Commented] (KAFKA-4569) Transient failure in org.apache.kafka.clients.consumer.KafkaConsumerTest.testWakeupWithFetchDataAvailable

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

[GitHub] kafka pull request #2699: KAFKA-4569: Make KafkaConsumer Trigger Wakeup befo...

GitHub user original-brownbear opened a pull request: https://github.com/apache/kafka/pull/2699 KAFKA-4569: Make KafkaConsumer Trigger Wakeup before Updating Offsets An attempt at resolving https://issues.apache.org/jira/browse/KAFKA-4569 using the @hachikuji suggestions from

Jenkins build is back to normal : kafka-trunk-jdk8 #1355

See

Re: [VOTE] KIP-117: Add a public AdminClient API for Kafka admin operations

Hi all, It seems like people agree with the basic direction of the proposal and the API, including the operations that are included, the async and batching support, and the mechanisms for extending it in the future. If there's no more votes, I'd like to close the vote and start progress on this.

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

On Tue, Mar 14, 2017, at 18:43, Becket Qin wrote: > Hi Colin, > Thanks for the reply. Please see comments inline. > > On Tue, Mar 14, 2017 at 5:30 PM, Colin McCabe wrote: > > I'm not sure if there is a benefit to removing createTopic and > > deleteTopic. It seems like users