[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

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

[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=15215406#comment-15215406 ] Yuto Kawamura commented on KAFKA-3471: -- [~becket_qin] Ah.. I wasn't aware of the leader election

[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

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

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

[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=15215244#comment-15215244 ] Manikumar Reddy commented on KAFKA-3476: We need to use "-Xverbosegclog" option for IBM java. not

[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=15215161#comment-15215161 ] Guozhang Wang commented on KAFKA-3338: -- [~bbejeck] It's yours :) > Add print and writeAsText

[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=15215160#comment-15215160 ] Bill Bejeck commented on KAFKA-3338: Picking this one up. I Searched pull requests and looks like no

[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-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=15215143#comment-15215143 ] Hang Sun commented on KAFKA-3472: - If we still need to do sampling/filtering after consume the messages,

[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

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

[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=15215054#comment-15215054 ] Jiangjie Qin commented on KAFKA-3436: - Thanks Ismael. I took brief look at KAFKA-3028 patch. It seems

[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] [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:

[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=15215017#comment-15215017 ] Jiangjie Qin commented on KAFKA-3334: - [~singhashish] I left a comment on the PR. I am not sure if we

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 >

[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

[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=15214999#comment-15214999 ] Ismael Juma commented on KAFKA-3436: [~becket_qin], with regards to async ZK, [~enothereska] provided

[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=15214993#comment-15214993 ] Jason Gustafson commented on KAFKA-3135: I made a little progress understanding this problem. The

[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

[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 >

[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

[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=15214943#comment-15214943 ] Ashish K Singh commented on KAFKA-3334: --- [~ijuma] got it, in that case I guess [~becket_qin], you

[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

[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

[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

[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

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

[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=15214927#comment-15214927 ] Ismael Juma commented on KAFKA-3334: [~singhashish], my comment was in relation to the following in

[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=15214916#comment-15214916 ] Jiangjie Qin commented on KAFKA-3334: - Not sure if I understand the issue. When sending message to a

[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] [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

[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-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] [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 >

[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

[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

[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

[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

[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=15214859#comment-15214859 ] Jiangjie Qin commented on KAFKA-3472: - [~granthenke] I think we can either use consumer interceptor or

[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 /

[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=15214832#comment-15214832 ] Ashish K Singh commented on KAFKA-3334: --- [~ijuma] I don't think it fails silently. The producer gets

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

[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

[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=15214815#comment-15214815 ] ASF GitHub Bot commented on KAFKA-3425: --- GitHub user hachikuji opened a pull request:

[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

[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=15214810#comment-15214810 ] Ashish K Singh commented on KAFKA-3400: --- I tried reproducing the issue with the steps you mentioned,

[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 @@ dependency groupIdorg.apache.kafka/groupId

[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 @@ dependency groupIdorg.apache.kafka/groupId

[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

[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

[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

[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=15214770#comment-15214770 ] Jason Gustafson commented on KAFKA-3425: [~ijuma] Sounds good to me. I'll update the description.

[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

[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=15214755#comment-15214755 ] ASF GitHub Bot commented on KAFKA-3419: --- GitHub user hachikuji opened a pull request:

[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=15214698#comment-15214698 ] Jiangjie Qin commented on KAFKA-3471: - [~kawamuray] In your example, if we return the produce response

[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] [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. > - > >

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

See

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

See

[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=15214529#comment-15214529 ] Jiangjie Qin commented on KAFKA-3388: - Thanks [~junrao]! > Producer should only timeout a batch in

[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=15214497#comment-15214497 ] ASF GitHub Bot commented on KAFKA-3177: --- GitHub user hachikuji opened a pull request:

[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

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

[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=15214488#comment-15214488 ] Jiangjie Qin commented on KAFKA-3177: - [~hachikuji] Yes, I agree that we need a general solution to

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

[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=15214440#comment-15214440 ] Gwen Shapira commented on KAFKA-3475: - Its a very simple wrapper class for testing. It really has

[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

[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=15214321#comment-15214321 ] Erik Helleren commented on KAFKA-3177: -- Is there a ticket for that "no broker up and running"

[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-3475) Introduce our own `MiniKdc`

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

[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=15214270#comment-15214270 ] Grant Henke commented on KAFKA-3475: I have not looked at the code in detail yet. Just posing the

[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=15214266#comment-15214266 ] Ismael Juma commented on KAFKA-3475: The issue is pace of development, it doesn't make sense to wait

[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=15214260#comment-15214260 ] Grant Henke commented on KAFKA-3475: Are these bugs not easily fixed in the existing MiniKdc? It would

[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=15214254#comment-15214254 ] ASF GitHub Bot commented on KAFKA-3475: --- GitHub user ijuma opened a pull request:

[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

[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

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).

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

[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=15214208#comment-15214208 ] Grant Henke commented on KAFKA-3472: I think the goal of sampling topic data could be done without

[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

[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

[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 *

[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