[GitHub] kafka pull request: MINOR: Fix typo and tweak wording in `RecordAc...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/1152 MINOR: Fix typo and tweak wording in `RecordAccumulator` comments This was recently introduced in: https://github.com/apache/kafka/commit/1fbe445dde71df0023a978c5e54dd229d3d23e1b You can merge th

[GitHub] kafka pull request: MINOR: Remove a couple of redundant `CoreUtils...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/1153 MINOR: Remove a couple of redundant `CoreUtils.rm` methods Also: * Rename remaining `CoreUtils.rm` to `delete` for consistency * Use `try with resources` in `Utils` to simplify code * Silen

[GitHub] kafka pull request: Update Sender.java

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

[GitHub] kafka pull request: Automatically expire RecordBatches before drai...

GitHub user SoyeeDst opened a pull request: https://github.com/apache/kafka/pull/1154 Automatically expire RecordBatches before draining Check expiration of RecordBatches prior to draining, this behavior could avoid time out message to be sent. You can merge this pull request into

[jira] [Commented] (KAFKA-3472) Allow MirrorMaker to copy selected partitions and choose target topic name

[ https://issues.apache.org/jira/browse/KAFKA-3472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214208#comment-15214208 ] Grant Henke commented on KAFKA-3472: I think the goal of sampling topic data could be

Re: Metadata and ACLs wire protocol review (KIP-4)

Anyone have any feedback on these protocol schemas or patches? I may call a vote in the next day or two on these to help keep moving KIP-4 forward. Thanks, Grant On Mon, Mar 21, 2016 at 10:29 PM, Grant Henke wrote: > I have 2 patches available for KIP-4 that implement some of the new > message

Re: KIP-4 Wiki Update

I am hoping to get more discussion and feedback around the blocking vs async discussion so I can start to get KIP-4 patches reviewed. In order to facilitate a faster discussion I will hold an open discussion on Tuesday March 29th at 12pm PST (right after the usual KIP call, if we have one). Please

[jira] [Created] (KAFKA-3475) Introduce our own `MiniKdc`

Ismael Juma created KAFKA-3475: -- Summary: Introduce our own `MiniKdc` Key: KAFKA-3475 URL: https://issues.apache.org/jira/browse/KAFKA-3475 Project: Kafka Issue Type: Improvement Compo

[GitHub] kafka pull request: KAFKA-3475; Introduce our own `MiniKdc`

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/1155 KAFKA-3475; Introduce our own `MiniKdc` This also fixes KAFKA-3453 and KAFKA-2866. You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka kafk

[jira] [Commented] (KAFKA-3475) Introduce our own `MiniKdc`

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

[jira] [Commented] (KAFKA-3475) Introduce our own `MiniKdc`

[ https://issues.apache.org/jira/browse/KAFKA-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214260#comment-15214260 ] Grant Henke commented on KAFKA-3475: Are these bugs not easily fixed in the existing M

[jira] [Commented] (KAFKA-3475) Introduce our own `MiniKdc`

[ https://issues.apache.org/jira/browse/KAFKA-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214266#comment-15214266 ] Ismael Juma commented on KAFKA-3475: The issue is pace of development, it doesn't make

[jira] [Commented] (KAFKA-3475) Introduce our own `MiniKdc`

[ https://issues.apache.org/jira/browse/KAFKA-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214270#comment-15214270 ] Grant Henke commented on KAFKA-3475: I have not looked at the code in detail yet. Just

[jira] [Commented] (KAFKA-3475) Introduce our own `MiniKdc`

[ https://issues.apache.org/jira/browse/KAFKA-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214281#comment-15214281 ] Ismael Juma commented on KAFKA-3475: That's a fair question. I think it's helpful to l

[GitHub] kafka pull request: MINOR: Fix transient SimpleACLAuthorizerTest f...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/1156 MINOR: Fix transient SimpleACLAuthorizerTest failures The SimpleACLAuthorizer will fail a request if it takes more than 10 retries. This should not happen is real world scenarios, but during the

[jira] [Commented] (KAFKA-3177) Kafka consumer can hang when position() is called on a non-existing partition.

[ https://issues.apache.org/jira/browse/KAFKA-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214321#comment-15214321 ] Erik Helleren commented on KAFKA-3177: -- Is there a ticket for that "no broker up and

[GitHub] kafka pull request: MINOR: Fix typo and tweak wording in `RecordAc...

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

[jira] [Commented] (KAFKA-3475) Introduce our own `MiniKdc`

[ https://issues.apache.org/jira/browse/KAFKA-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214440#comment-15214440 ] Gwen Shapira commented on KAFKA-3475: - Its a very simple wrapper class for testing. It

[jira] [Commented] (KAFKA-3177) Kafka consumer can hang when position() is called on a non-existing partition.

[ https://issues.apache.org/jira/browse/KAFKA-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214479#comment-15214479 ] Jason Gustafson commented on KAFKA-3177: [~becket_qin] Got sidetracked, but workin

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

See Changes: [junrao] MINOR: Fix typo and tweak wording in `RecordAccumulator` comments -- [...truncated 3454 lines...] kafka.log.LogCleanerIntegrationTest > cleanerTest[0] PASSED kafka.log.Log

[jira] [Commented] (KAFKA-3177) Kafka consumer can hang when position() is called on a non-existing partition.

[ https://issues.apache.org/jira/browse/KAFKA-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214488#comment-15214488 ] Jiangjie Qin commented on KAFKA-3177: - [~hachikuji] Yes, I agree that we need a genera

Re: [VOTE] KIP-43: Kafka SASL enhancements

Hi, Rajini, Sorry for the late response. The revised KIP looks good overall. Just a few minor comments below. 1. Since the broker can also act as a client too (for inter broker communication), sasl.mechanism can also be specified in the broker configuration, right? 2. Since we enable GSSAPI by de

[GitHub] kafka pull request: KAFKA-3177: log warning when topic/partition d...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1157 KAFKA-3177: log warning when topic/partition doesn't exist You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-3177 Alterna

[jira] [Commented] (KAFKA-3177) Kafka consumer can hang when position() is called on a non-existing partition.

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

[jira] [Commented] (KAFKA-3388) Producer should only timeout a batch in the accumulator when metadata is missing.

[ https://issues.apache.org/jira/browse/KAFKA-3388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214529#comment-15214529 ] Jiangjie Qin commented on KAFKA-3388: - Thanks [~junrao]! > Producer should only timeo

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

See

Jenkins build is back to normal : kafka-0.10.0-jdk7 #19

See

[jira] [Updated] (KAFKA-3436) Speed up controlled shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-3436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3436: Reviewer: Joel Koshy > Speed up controlled shutdown. > - > >

[jira] [Created] (KAFKA-3476) -Xloggc is not recognised by IBM java

Khirod Patra created KAFKA-3476: --- Summary: -Xloggc is not recognised by IBM java Key: KAFKA-3476 URL: https://issues.apache.org/jira/browse/KAFKA-3476 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-3471) min.insync.replicas isn't respected when there's a delaying follower who still in ISR

[ https://issues.apache.org/jira/browse/KAFKA-3471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214698#comment-15214698 ] Jiangjie Qin commented on KAFKA-3471: - [~kawamuray] In your example, if we return the

[jira] [Commented] (KAFKA-3419) New consumer javadoc unclear on topic subscription vs partition assignment

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

[GitHub] kafka pull request: KAFKA-3419: clarify difference between topic s...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1158 KAFKA-3419: clarify difference between topic subscription and partition assignment You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/

[jira] [Commented] (KAFKA-3425) Add missing notes to upgrade docs

[ https://issues.apache.org/jira/browse/KAFKA-3425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214770#comment-15214770 ] Jason Gustafson commented on KAFKA-3425: [~ijuma] Sounds good to me. I'll update t

[jira] [Updated] (KAFKA-3425) Add missing notes to upgrade docs

[ https://issues.apache.org/jira/browse/KAFKA-3425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3425: --- Description: We're missing a few notes from the upgrade documentation: - KIP-45 introduced an

[jira] [Updated] (KAFKA-3425) Add missing notes to upgrade docs

[ https://issues.apache.org/jira/browse/KAFKA-3425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3425: --- Description: We're missing a few notes from the upgrade documentation: - KIP-45 introduced an

[GitHub] kafka-site pull request: update docs for 0.10.0-rc1

GitHub user gwenshap opened a pull request: https://github.com/apache/kafka-site/pull/10 update docs for 0.10.0-rc1 You can merge this pull request into a Git repository by running: $ git pull https://github.com/gwenshap/kafka-site 0.10.0.0-rc1 Alternatively you can review an

[GitHub] kafka-site pull request: update docs for 0.10.0-rc1

Github user granthenke commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/10#discussion_r57626588 --- Diff: 0100/api.html --- @@ -24,12 +24,12 @@ org.apache.kafka kafka-client

[GitHub] kafka-site pull request: update docs for 0.10.0-rc1

Github user gwenshap commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/10#discussion_r57626861 --- Diff: 0100/api.html --- @@ -24,12 +24,12 @@ org.apache.kafka kafka-clients<

[jira] [Commented] (KAFKA-3400) Topic stop working / can't describe topic

[ https://issues.apache.org/jira/browse/KAFKA-3400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214810#comment-15214810 ] Ashish K Singh commented on KAFKA-3400: --- I tried reproducing the issue with the step

[GitHub] kafka-site pull request: update docs for 0.10.0-rc1

Github user gwenshap commented on the pull request: https://github.com/apache/kafka-site/pull/10#issuecomment-202566739 Haha, change just went from 13 files to 786 :) Thats the javadocs... --- If your project is set up for it, you can reply to this email and have your reply a

[jira] [Commented] (KAFKA-3425) Add missing notes to upgrade docs

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

[GitHub] kafka pull request: KAFKA-3425: add missing upgrade notes

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1159 KAFKA-3425: add missing upgrade notes You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-3425 Alternatively you can review

Re: [DISCUSS] KIP-50 - Enhance Authorizer interface to be aware of supported Principal Types

Hello Harsha, Pinging again. This is a minor KIP and it has been lying around for quite some time. If providing supported principal types via a config is what you suggest, I am fine with it. On Wed, Mar 9, 2016 at 12:32 PM, Ashish Singh wrote: > Hi Harsha, > > On Wed, Mar 9, 2016 at 12:04 PM, H

[jira] [Commented] (KAFKA-3334) First message on new topic not actually being sent, no exception thrown

[ https://issues.apache.org/jira/browse/KAFKA-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214832#comment-15214832 ] Ashish K Singh commented on KAFKA-3334: --- [~ijuma] I don't think it fails silently. T

[jira] [Updated] (KAFKA-3338) Add print and writeAsText functions to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3338: - Labels: newbie++ (was: ) > Add print and writeAsText functions to the Streams DSL > -

[jira] [Updated] (KAFKA-3338) Add print and writeAsText functions to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3338: - Summary: Add print and writeAsText functions to the Streams DSL (was: Add print / writeAsTex / et

[jira] [Commented] (KAFKA-3472) Allow MirrorMaker to copy selected partitions and choose target topic name

[ https://issues.apache.org/jira/browse/KAFKA-3472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214859#comment-15214859 ] Jiangjie Qin commented on KAFKA-3472: - [~granthenke] I think we can either use consume

[jira] [Updated] (KAFKA-3338) Add print and writeAsText functions to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3338: - Description: We want to provide some REPL-like pattern for users for better debuggability. More c

[jira] [Updated] (KAFKA-3337) Extract selector as a separate groupBy operator for KTable aggregations

[ https://issues.apache.org/jira/browse/KAFKA-3337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3337: - Labels: newbie++ (was: ) > Extract selector as a separate groupBy operator for KTable aggregation

[jira] [Updated] (KAFKA-3337) Extract selector as a separate groupBy operator for KTable aggregations

[ https://issues.apache.org/jira/browse/KAFKA-3337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3337: - Description: Currently KTable aggregation takes a selector used for selecting the aggregate key.a

[GitHub] kafka pull request: KAFKA-3382: Add system test for ReplicationVer...

GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/1160 KAFKA-3382: Add system test for ReplicationVerificationTool You can merge this pull request into a Git repository by running: $ git pull https://github.com/SinghAsDev/kafka KAFKA-3382 Alte

[jira] [Updated] (KAFKA-3382) Add system test for ReplicationVerificationTool

[ https://issues.apache.org/jira/browse/KAFKA-3382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3382: -- Fix Version/s: 0.10.1.0 > Add system test for ReplicationVerificationTool >

[jira] [Updated] (KAFKA-3382) Add system test for ReplicationVerificationTool

[ https://issues.apache.org/jira/browse/KAFKA-3382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3382: -- Status: Patch Available (was: Open) > Add system test for ReplicationVerificationTool > ---

[jira] [Commented] (KAFKA-3382) Add system test for ReplicationVerificationTool

[ https://issues.apache.org/jira/browse/KAFKA-3382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214909#comment-15214909 ] ASF GitHub Bot commented on KAFKA-3382: --- GitHub user SinghAsDev opened a pull reques

[jira] [Updated] (KAFKA-3382) Add system test for ReplicationVerificationTool

[ https://issues.apache.org/jira/browse/KAFKA-3382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3382: -- Affects Version/s: 0.10.1.0 > Add system test for ReplicationVerificationTool >

[jira] [Updated] (KAFKA-3429) Remove Serdes needed for repartitioning in KTable stateful operations

[ https://issues.apache.org/jira/browse/KAFKA-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3429: - Labels: newbie++ (was: ) > Remove Serdes needed for repartitioning in KTable stateful operations

[jira] [Updated] (KAFKA-3429) Remove Serdes needed for repartitioning in KTable stateful operations

[ https://issues.apache.org/jira/browse/KAFKA-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3429: - Description: Currently in KTable aggregate operations where a repartition is possibly needed sinc

[jira] [Updated] (KAFKA-3430) Allow users to set key in KTable.toStream() and KStream

[ https://issues.apache.org/jira/browse/KAFKA-3430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3430: - Description: Currently KTable.toStream does not take any parameters and hence users who wants to

[jira] [Commented] (KAFKA-3334) First message on new topic not actually being sent, no exception thrown

[ https://issues.apache.org/jira/browse/KAFKA-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214916#comment-15214916 ] Jiangjie Qin commented on KAFKA-3334: - Not sure if I understand the issue. When sendin

[jira] [Created] (KAFKA-3477) Add customizable StreamPartition into #to functions of Streams DSL

Guozhang Wang created KAFKA-3477: Summary: Add customizable StreamPartition into #to functions of Streams DSL Key: KAFKA-3477 URL: https://issues.apache.org/jira/browse/KAFKA-3477 Project: Kafka

[jira] [Commented] (KAFKA-3334) First message on new topic not actually being sent, no exception thrown

[ https://issues.apache.org/jira/browse/KAFKA-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214927#comment-15214927 ] Ismael Juma commented on KAFKA-3334: [~singhashish], my comment was in relation to the

Re: [VOTE] 0.10.0.0 RC0

Since Dana and few others found critical issues for the release, I've rolled out another RC. I'll send the vote thread in a second. Simon, since KAFKA-3296 doesn't have a solution yet, I could not include it in the release candidate. We can roll out another RC if we find a solution, or we can def

[GitHub] kafka-site pull request: update docs for 0.10.0-rc1

Github user ijuma commented on the pull request: https://github.com/apache/kafka-site/pull/10#issuecomment-202587870 It seems fine to me, but I only had a chance to look at the diff (i.e. I didn't test it). --- If your project is set up for it, you can reply to this email and have yo

[jira] [Created] (KAFKA-3478) Finer Stream Flow Control

Guozhang Wang created KAFKA-3478: Summary: Finer Stream Flow Control Key: KAFKA-3478 URL: https://issues.apache.org/jira/browse/KAFKA-3478 Project: Kafka Issue Type: Sub-task Repo

[VOTE] 0.10.0.0 RC1

Hello Kafka users, developers and client-developers, This is the second candidate for release of Apache Kafka 0.10.0.0. This is a major release that includes: (1) New message format including timestamps (2) client interceptor API (3) Kafka Streams. Since this is a major release, we will give

[GitHub] kafka pull request: MINOR: Remove a couple of redundant `CoreUtils...

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

[jira] [Commented] (KAFKA-3334) First message on new topic not actually being sent, no exception thrown

[ https://issues.apache.org/jira/browse/KAFKA-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214943#comment-15214943 ] Ashish K Singh commented on KAFKA-3334: --- [~ijuma] got it, in that case I guess [~bec

[GitHub] kafka pull request: HOTFIX: stop using batch write to rocksdb

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/1161 HOTFIX: stop using batch write to rocksdb @guozhangwang Removing batch write to RocksDB because I observed segmentation faults in RocksDB's batch write. You can merge this pull request i

[jira] [Updated] (KAFKA-3425) Add missing notes to upgrade docs

[ https://issues.apache.org/jira/browse/KAFKA-3425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3425: --- Status: Patch Available (was: Open) > Add missing notes to upgrade docs > ---

[jira] [Updated] (KAFKA-3419) New consumer javadoc unclear on topic subscription vs partition assignment

[ https://issues.apache.org/jira/browse/KAFKA-3419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3419: --- Reviewer: Guozhang Wang Status: Patch Available (was: Open) > New consumer javadoc unclear on t

[jira] [Commented] (KAFKA-3135) Unexpected delay before fetch response transmission

[ https://issues.apache.org/jira/browse/KAFKA-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214993#comment-15214993 ] Jason Gustafson commented on KAFKA-3135: I made a little progress understanding th

[jira] [Commented] (KAFKA-3436) Speed up controlled shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-3436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214999#comment-15214999 ] Ismael Juma commented on KAFKA-3436: [~becket_qin], with regards to async ZK, [~enothe

[GitHub] kafka-site pull request: update docs for 0.10.0-rc1

Github user gwenshap closed the pull request at: https://github.com/apache/kafka-site/pull/10 --- 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 #1156

See Changes: [wangguoz] MINOR: Remove a couple of redundant `CoreUtils.rm` methods -- [...truncated 1591 lines...] kafka.log.LogTest > testParseTopicPartitionName PASSED kafka.log.LogTest > te

[jira] [Commented] (KAFKA-3334) First message on new topic not actually being sent, no exception thrown

[ https://issues.apache.org/jira/browse/KAFKA-3334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215017#comment-15215017 ] Jiangjie Qin commented on KAFKA-3334: - [~singhashish] I left a comment on the PR. I am

[jira] [Created] (KAFKA-3479) Add new consumer metrics documentation

Jason Gustafson created KAFKA-3479: -- Summary: Add new consumer metrics documentation Key: KAFKA-3479 URL: https://issues.apache.org/jira/browse/KAFKA-3479 Project: Kafka Issue Type: Improvem

[jira] [Created] (KAFKA-3480) Autogenerate metrics documentation

Jason Gustafson created KAFKA-3480: -- Summary: Autogenerate metrics documentation Key: KAFKA-3480 URL: https://issues.apache.org/jira/browse/KAFKA-3480 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-3436) Speed up controlled shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-3436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215054#comment-15215054 ] Jiangjie Qin commented on KAFKA-3436: - Thanks Ismael. I took brief look at KAFKA-3028

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

See Changes: [wangguoz] MINOR: Remove a couple of redundant `CoreUtils.rm` methods -- [...truncated 2959 lines...] kafka.admin.DeleteTopicTest > testResumeDeleteTopicWithRecoveredFollower PASSED

[GitHub] kafka pull request: HOTFIX: stop using batch write to rocksdb

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

[jira] [Commented] (KAFKA-3472) Allow MirrorMaker to copy selected partitions and choose target topic name

[ https://issues.apache.org/jira/browse/KAFKA-3472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215143#comment-15215143 ] Hang Sun commented on KAFKA-3472: - If we still need to do sampling/filtering after consume

[jira] [Assigned] (KAFKA-3338) Add print and writeAsText functions to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-3338: -- Assignee: Bill Bejeck > Add print and writeAsText functions to the Streams DSL > --

[jira] [Commented] (KAFKA-3338) Add print and writeAsText functions to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215160#comment-15215160 ] Bill Bejeck commented on KAFKA-3338: Picking this one up. I Searched pull requests an

[jira] [Commented] (KAFKA-3338) Add print and writeAsText functions to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215161#comment-15215161 ] Guozhang Wang commented on KAFKA-3338: -- [~bbejeck] It's yours :) > Add print and wri

[jira] [Commented] (KAFKA-3476) -Xloggc is not recognised by IBM java

[ https://issues.apache.org/jira/browse/KAFKA-3476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215244#comment-15215244 ] Manikumar Reddy commented on KAFKA-3476: We need to use "-Xverbosegclog" option fo

[jira] [Commented] (KAFKA-3480) Autogenerate metrics documentation

[ https://issues.apache.org/jira/browse/KAFKA-3480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215294#comment-15215294 ] James Cheng commented on KAFKA-3480: I think I'd like to work on this, but I'm not wha

[jira] [Created] (KAFKA-3481) Transient failure in TestVerifiableProducer

Ewen Cheslack-Postava created KAFKA-3481: Summary: Transient failure in TestVerifiableProducer Key: KAFKA-3481 URL: https://issues.apache.org/jira/browse/KAFKA-3481 Project: Kafka Iss

[jira] [Commented] (KAFKA-3471) min.insync.replicas isn't respected when there's a delaying follower who still in ISR

[ https://issues.apache.org/jira/browse/KAFKA-3471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215406#comment-15215406 ] Yuto Kawamura commented on KAFKA-3471: -- [~becket_qin] Ah.. I wasn't aware of the lead

Re: [VOTE] 0.10.0.0 RC1

+1 -- verified that all kafka-python integration tests now pass On Mon, Mar 28, 2016 at 2:34 PM, Gwen Shapira wrote: > Hello Kafka users, developers and client-developers, > > This is the second candidate for release of Apache Kafka 0.10.0.0. > > This is a major release that includes: > > (1) Ne

[jira] [Created] (KAFKA-3482) [DOC] - Remove the part about LinkedIn running ZK 3.3.X

Gwen Shapira created KAFKA-3482: --- Summary: [DOC] - Remove the part about LinkedIn running ZK 3.3.X Key: KAFKA-3482 URL: https://issues.apache.org/jira/browse/KAFKA-3482 Project: Kafka Issue Typ