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

Gwen, Just to be clear, the alternative would be: *jaas.conf:* GssapiKafkaServer { com.ibm.security.auth.module.Krb5LoginModule required credsType=both useKeytab="file:/kafka/key.tab" principal="kafka/localh...@example.com "; }; SmartcardKafkaServer { example.Smartcard

[GitHub] kafka pull request: MINOR: update compression design doc to includ...

GitHub user omkreddy opened a pull request: https://github.com/apache/kafka/pull/1040 MINOR: update compression design doc to include lz4 protocol You can merge this pull request into a Git repository by running: $ git pull https://github.com/omkreddy/kafka MINOR-DOC Alternat

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

See Changes: [cshapi] MINOR: KAFKA-3361 follow up -- [...truncated 1510 lines...] kafka.api.AdminClientTest > testListGroups PASSED kafka.api.AdminClientTest > testDescribeConsumerGroupForNonEx

[jira] [Created] (KAFKA-3371) ClientCompatibilityTest system test failing since KIP-31/KIP-32

Ismael Juma created KAFKA-3371: -- Summary: ClientCompatibilityTest system test failing since KIP-31/KIP-32 Key: KAFKA-3371 URL: https://issues.apache.org/jira/browse/KAFKA-3371 Project: Kafka Is

[jira] [Updated] (KAFKA-3371) ClientCompatibilityTest system test failing since KIP-31/KIP-32 was merged

[ https://issues.apache.org/jira/browse/KAFKA-3371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3371: --- Summary: ClientCompatibilityTest system test failing since KIP-31/KIP-32 was merged (was: ClientCompa

[jira] [Created] (KAFKA-3372) Trailing space in Kafka ConsumerConfig

Kundan created KAFKA-3372: - Summary: Trailing space in Kafka ConsumerConfig Key: KAFKA-3372 URL: https://issues.apache.org/jira/browse/KAFKA-3372 Project: Kafka Issue Type: Bug Components:

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

See Changes: [me] KAFKA-3344: Remove previous system test's leftover test-log4j.properties -- [...truncated 110 lines...] :kafka-trunk-jdk7:clients:classes UP-TO-DATE :kafka-trunk-jdk7:clients:d

[jira] [Updated] (KAFKA-3248) AdminClient Blocks Forever in send Method

[ https://issues.apache.org/jira/browse/KAFKA-3248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3248: --- Fix Version/s: 0.10.0.0 > AdminClient Blocks Forever in send Method >

[jira] [Updated] (KAFKA-3248) AdminClient Blocks Forever in send Method

[ https://issues.apache.org/jira/browse/KAFKA-3248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3248: --- Priority: Critical (was: Minor) > AdminClient Blocks Forever in send Method > ---

[jira] [Commented] (KAFKA-3248) AdminClient Blocks Forever in send Method

[ https://issues.apache.org/jira/browse/KAFKA-3248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15188979#comment-15188979 ] Ismael Juma commented on KAFKA-3248: I bumped the priority as blocking forever is not

[jira] [Created] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

Ismael Juma created KAFKA-3373: -- Summary: Add `log` prefix to KIP-31/32 configs Key: KAFKA-3373 URL: https://issues.apache.org/jira/browse/KAFKA-3373 Project: Kafka Issue Type: Test

[jira] [Updated] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

[ https://issues.apache.org/jira/browse/KAFKA-3373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3373: --- Priority: Blocker (was: Major) > Add `log` prefix to KIP-31/32 configs >

[jira] [Commented] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

[ https://issues.apache.org/jira/browse/KAFKA-3373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15188982#comment-15188982 ] Ismael Juma commented on KAFKA-3373: cc [~becket_qin] [~junrao] > Add `log` prefix to

[jira] [Updated] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

[ https://issues.apache.org/jira/browse/KAFKA-3373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3373: --- Issue Type: Bug (was: Test) > Add `log` prefix to KIP-31/32 configs > ---

[jira] [Created] (KAFKA-3374) Failure in security rolling upgrade phase 2 system test

Ismael Juma created KAFKA-3374: -- Summary: Failure in security rolling upgrade phase 2 system test Key: KAFKA-3374 URL: https://issues.apache.org/jira/browse/KAFKA-3374 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189024#comment-15189024 ] Flavio Junqueira commented on KAFKA-3173: - I have investigated the two races furth

[jira] [Updated] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-3173: Attachment: KAFKA-3173-race-repo.patch > Error while moving some partitions to OnlinePartiti

[jira] [Updated] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-3173: Attachment: (was: KAFKA-3173-race-repo.patch) > Error while moving some partitions to On

[jira] [Updated] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-3173: Attachment: KAFKA-3173-race-repro.patch > Error while moving some partitions to OnlinePartit

[GitHub] kafka pull request: Kafka 3173

GitHub user fpj opened a pull request: https://github.com/apache/kafka/pull/1041 Kafka 3173 You can merge this pull request into a Git repository by running: $ git pull https://github.com/fpj/kafka KAFKA-3173 Alternatively you can review and apply these changes as the patch a

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

See

[jira] [Created] (KAFKA-3375) Suppress deprecated warnings where reasonable and tweak compiler settings

Ismael Juma created KAFKA-3375: -- Summary: Suppress deprecated warnings where reasonable and tweak compiler settings Key: KAFKA-3375 URL: https://issues.apache.org/jira/browse/KAFKA-3375 Project: Kafka

[GitHub] kafka pull request: KAFKA-3375; Suppress deprecated warnings where...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/1042 KAFKA-3375; Suppress deprecated warnings where reasonable and tweak compiler settings * Fix and suppress number of unchecked warnings (except for Kafka Streams) * Add `@SafeVarargs` annotation to

[jira] [Commented] (KAFKA-3375) Suppress deprecated warnings where reasonable and tweak compiler settings

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

[jira] [Updated] (KAFKA-3375) Suppress deprecated warnings where reasonable and tweak compiler settings

[ https://issues.apache.org/jira/browse/KAFKA-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3375: --- Status: Patch Available (was: Open) > Suppress deprecated warnings where reasonable and tweak compile

[jira] [Updated] (KAFKA-3375) Suppress and fix compiler warnings where reasonable and tweak compiler settings

[ https://issues.apache.org/jira/browse/KAFKA-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3375: --- Summary: Suppress and fix compiler warnings where reasonable and tweak compiler settings (was: Suppre

[jira] [Updated] (KAFKA-3359) Parallel log-recovery of un-flushed segments on startup

[ https://issues.apache.org/jira/browse/KAFKA-3359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vamsi Subhash Achanta updated KAFKA-3359: - Reviewer: Grant Henke Fix Version/s: 0.10.0.0 Status: Patch Ava

[jira] [Updated] (KAFKA-3376) have sensible defaults for the command-line tools to facilitate local development

[ https://issues.apache.org/jira/browse/KAFKA-3376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christian Posta updated KAFKA-3376: --- Affects Version/s: 0.9.0.1 > have sensible defaults for the command-line tools to facilitate l

[jira] [Created] (KAFKA-3376) have sensible defaults for the command-line tools to facilitate local development

Christian Posta created KAFKA-3376: -- Summary: have sensible defaults for the command-line tools to facilitate local development Key: KAFKA-3376 URL: https://issues.apache.org/jira/browse/KAFKA-3376 P

[jira] [Updated] (KAFKA-3376) have sensible defaults for the command-line tools to facilitate local development

[ https://issues.apache.org/jira/browse/KAFKA-3376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christian Posta updated KAFKA-3376: --- Component/s: packaging admin > have sensible defaults for the command-line to

[jira] [Created] (KAFKA-3377) add REST interface to JMX

Christian Posta created KAFKA-3377: -- Summary: add REST interface to JMX Key: KAFKA-3377 URL: https://issues.apache.org/jira/browse/KAFKA-3377 Project: Kafka Issue Type: Improvement

Re: [jira] [Created] (KAFKA-3377) add REST interface to JMX

I would like to know why you want/need it to be integrated into Kafka? For our current project we tried out zabbix, https://www.zabbix.com/documentation/3.0/manual/config/items/itemtypes/jmx_monitoring, it takes some configuration, but then you can fetch all the jmx you want and put them into graph

[jira] [Assigned] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

[ https://issues.apache.org/jira/browse/KAFKA-3373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-3373: --- Assignee: Jiangjie Qin > Add `log` prefix to KIP-31/32 configs >

Re: [VOTE] Release plan - Kafka 0.10.0

Thanks all the Kafka contributors for voting! The vote passes with 6 binding +1, 5 non-binding +1 and no -1. We are now 11 days before the first planned release candidate. We have 12 open blockers, 17 open critical issues and a grand total of 108 issues for the release. I added a widget showing

[jira] [Resolved] (KAFKA-3118) Fail test at: ProducerBounceTest. testBrokerFailure

[ https://issues.apache.org/jira/browse/KAFKA-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aarti gupta resolved KAFKA-3118. Resolution: Cannot Reproduce > Fail test at: ProducerBounceTest. testBrokerFailure > --

[GitHub] kafka pull request: MINOR: Add header and footer to protocol docs

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/1043 MINOR: Add header and footer to protocol docs Because protocol.html is going to be in its own page it needs the header and footer included. You can merge this pull request into a Git repository

[GitHub] kafka-site pull request: Add protocol guide

GitHub user granthenke opened a pull request: https://github.com/apache/kafka-site/pull/9 Add protocol guide You can merge this pull request into a Git repository by running: $ git pull https://github.com/granthenke/kafka-site protocol Alternatively you can review and apply t

[jira] [Commented] (KAFKA-3361) Initial protocol documentation page and generation

[ https://issues.apache.org/jira/browse/KAFKA-3361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189646#comment-15189646 ] Jiangjie Qin commented on KAFKA-3361: - [~gwenshap] [~granthenke] It seems docs/protoco

[GitHub] kafka-site pull request: Add protocol guide

Github user granthenke commented on the pull request: https://github.com/apache/kafka-site/pull/9#issuecomment-194980267 cc @gwenshap --- 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 fea

[GitHub] kafka-site pull request: Add protocol guide

Github user granthenke commented on the pull request: https://github.com/apache/kafka-site/pull/9#issuecomment-194980209 This was briefly tested locally with an Apache web server. It includes https://github.com/apache/kafka/pull/1043 --- If your project is set up for it, you can repl

[jira] [Commented] (KAFKA-3361) Initial protocol documentation page and generation

[ https://issues.apache.org/jira/browse/KAFKA-3361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189661#comment-15189661 ] Grant Henke commented on KAFKA-3361: [~becket_qin] I have that included in this PR: h

[jira] [Commented] (KAFKA-3367) Delete topic dont delete the complete log from kafka

[ https://issues.apache.org/jira/browse/KAFKA-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189676#comment-15189676 ] Mayuresh Gharat commented on KAFKA-3367: It takes time to delete the logs, dependi

[jira] [Updated] (KAFKA-3202) Add system test for KIP-31 and KIP-32 - Change message format version on the fly

[ https://issues.apache.org/jira/browse/KAFKA-3202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-3202: Description: The system test should cover the case that message format changes are made when client

Re: [GitHub] kafka pull request: Parallel log-recovery of un-flushed segments o...

Hi, I would like to make this into 0.0.10.0 so can someone look into this and review? On Wed, Mar 9, 2016 at 10:29 PM, Achanta Vamsi Subhash < achanta.va...@flipkart.com> wrote: > Hi all, > > https://github.com/apache/kafka/pull/1035 > This pull request will make the log-segment load parallel wit

[jira] [Commented] (KAFKA-3202) Add system test for KIP-31 and KIP-32 - Change message format version on the fly

[ https://issues.apache.org/jira/browse/KAFKA-3202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189692#comment-15189692 ] Eno Thereska commented on KAFKA-3202: - [~becket_qin]: I've updated the JIRA descriptio

[GitHub] kafka pull request: MINOR: Add header and footer to protocol docs

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1043 --- 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-3361) Initial protocol documentation page and generation

[ https://issues.apache.org/jira/browse/KAFKA-3361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189720#comment-15189720 ] Gwen Shapira commented on KAFKA-3361: - merged. Sorry for accidentally breaking the bui

Re: [DISCUSS] KIP-35 - Retrieve protocol version

@Magnus, Does the latest suggestion sound OK to you. I am planning to update PR based on latest suggestion. On Mon, Mar 7, 2016 at 10:58 AM, Ashish Singh wrote: > > > On Fri, Mar 4, 2016 at 5:46 PM, Jay Kreps wrote: > >> Hey Ashish, >> >> Both good points. >> >> I think the issue with the gene

[jira] [Commented] (KAFKA-3345) ProducerResponse could gracefully handle no throttle time provided

[ https://issues.apache.org/jira/browse/KAFKA-3345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189757#comment-15189757 ] Bryan Baugher commented on KAFKA-3345: -- Looks like this is no longer as easy with the

[GitHub] kafka-site pull request: Add protocol guide

Github user asfgit closed the pull request at: https://github.com/apache/kafka-site/pull/9 --- 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: Minor: Fix system test broken by change of con...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1039 --- 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] [Created] (KAFKA-3378) Client blocks forever if SocketChannel connects instantly

Larkin Lowrey created KAFKA-3378: Summary: Client blocks forever if SocketChannel connects instantly Key: KAFKA-3378 URL: https://issues.apache.org/jira/browse/KAFKA-3378 Project: Kafka Issue

[GitHub] kafka pull request: KAFKA-3318: clean up consumer logging and erro...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1036 --- 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-3318) Improve consumer rebalance error messaging

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

[jira] [Resolved] (KAFKA-3318) Improve consumer rebalance error messaging

[ https://issues.apache.org/jira/browse/KAFKA-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-3318. - Resolution: Fixed Fix Version/s: 0.10.0.0 Issue resolved by pull request 1036 [https://gith

[GitHub] kafka pull request: KAFKA-3378 Fix for instantly connecting Socket...

GitHub user llowrey opened a pull request: https://github.com/apache/kafka/pull/1044 KAFKA-3378 Fix for instantly connecting SocketChannels. Added OP_WRITE interestOp when channel connects instantly (socketChannel.connect(address) returns true... even in non-blocking mode). This al

[jira] [Commented] (KAFKA-3378) Client blocks forever if SocketChannel connects instantly

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

[jira] [Updated] (KAFKA-3378) Client blocks forever if SocketChannel connects instantly

[ https://issues.apache.org/jira/browse/KAFKA-3378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3378: --- Fix Version/s: 0.10.0.0 > Client blocks forever if SocketChannel connects instantly >

[jira] [Updated] (KAFKA-3378) Client blocks forever if SocketChannel connects instantly

[ https://issues.apache.org/jira/browse/KAFKA-3378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3378: --- Priority: Critical (was: Major) > Client blocks forever if SocketChannel connects instantly > ---

[GitHub] kafka pull request: MINOR: Increase AWS instance size

GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/1045 MINOR: Increase AWS instance size AWS instance size increased to m3.xlarge to allow all system tests to pass. You can merge this pull request into a Git repository by running: $ git pull ht

[jira] [Commented] (KAFKA-3296) All consumer reads hang indefinately

[ https://issues.apache.org/jira/browse/KAFKA-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189851#comment-15189851 ] Jason Gustafson commented on KAFKA-3296: [~thecoop1984] Sorry, haven't had any tim

[GitHub] kafka pull request: MINOR: Increase AWS instance size

Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/1045 --- 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: Increased default EC2 instance size

GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/1046 MINOR: Increased default EC2 instance size AWS instance size increased to m3.xlarge to allow all system tests to pass. @ijuma @ewencp have a look please. You can merge this pull request into a

[GitHub] kafka pull request: MINOR: Increased default EC2 instance size

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

[GitHub] kafka pull request: MINOR: Add unit test for internal topics

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/1047 MINOR: Add unit test for internal topics You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KInternal Alternatively you ca

[jira] [Commented] (KAFKA-3367) Delete topic dont delete the complete log from kafka

[ https://issues.apache.org/jira/browse/KAFKA-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189874#comment-15189874 ] Akshath Patkar commented on KAFKA-3367: --- [~mgharat] thanks. i am using confluent pac

[jira] [Commented] (KAFKA-3202) Add system test for KIP-31 and KIP-32 - Change message format version on the fly

[ https://issues.apache.org/jira/browse/KAFKA-3202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189917#comment-15189917 ] Anna Povzner commented on KAFKA-3202: - [~enothereska] I think you meant to post the te

[jira] [Commented] (KAFKA-3367) Delete topic dont delete the complete log from kafka

[ https://issues.apache.org/jira/browse/KAFKA-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189933#comment-15189933 ] Mayuresh Gharat commented on KAFKA-3367: Is automatic topic creation turned ON in

Build failed in Jenkins: kafka_0.9.0_jdk7 #128

See Changes: [cshapi] MINOR: Add header and footer to protocol docs -- [...truncated 3018 lines...] kafka.message.MessageTest > testChecksum PASSED kafka.message.MessageTest > testIsHashable PAS

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

See

[jira] [Updated] (KAFKA-3188) Add system test for KIP-31 and KIP-32 - Compatibility Test

[ https://issues.apache.org/jira/browse/KAFKA-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-3188: Description: The integration test should test the compatibility between 0.10.0 broker with clients

[jira] [Updated] (KAFKA-3202) Add system test for KIP-31 and KIP-32 - Change message format version on the fly

[ https://issues.apache.org/jira/browse/KAFKA-3202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-3202: Description: The system test should cover the case that message format changes are made when client

[jira] [Created] (KAFKA-3379) Update tools relying on old producer to use new producer.

Ashish K Singh created KAFKA-3379: - Summary: Update tools relying on old producer to use new producer. Key: KAFKA-3379 URL: https://issues.apache.org/jira/browse/KAFKA-3379 Project: Kafka Iss

[jira] [Commented] (KAFKA-3202) Add system test for KIP-31 and KIP-32 - Change message format version on the fly

[ https://issues.apache.org/jira/browse/KAFKA-3202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1519#comment-1519 ] Eno Thereska commented on KAFKA-3202: - [~apovzner] Moved test description to Compatibi

[jira] [Updated] (KAFKA-3379) Update tools relying on old producer to use new producer.

[ https://issues.apache.org/jira/browse/KAFKA-3379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3379: -- Description: Following tools are using old producer. * ReplicationVerificationTool * SimpleCons

[jira] [Created] (KAFKA-3380) Add system test for GetOffsetShell tool

Ashish K Singh created KAFKA-3380: - Summary: Add system test for GetOffsetShell tool Key: KAFKA-3380 URL: https://issues.apache.org/jira/browse/KAFKA-3380 Project: Kafka Issue Type: Sub-task

[GitHub] kafka pull request: KAFKA-3380: Add system test for GetOffsetShell...

GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/1048 KAFKA-3380: Add system test for GetOffsetShell tool You can merge this pull request into a Git repository by running: $ git pull https://github.com/SinghAsDev/kafka KAFKA-3380 Alternativel

[jira] [Commented] (KAFKA-3380) Add system test for GetOffsetShell tool

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

Re: [DISCUSS] KIP-35 - Retrieve protocol version

Hi all, sorry for joining late in the game, the carribean got in the way. My thoughts: There is no way around the chicken&egg problem, so the sooner we can add protocol versioning functionality the better and we'll add heuristics in clients to handle the migration period (e.g, what Dana has done

[GitHub] kafka pull request: KAFKA-3373 add 'log' prefix to configurations ...

GitHub user becketqin opened a pull request: https://github.com/apache/kafka/pull/1049 KAFKA-3373 add 'log' prefix to configurations in KIP-31/32 You can merge this pull request into a Git repository by running: $ git pull https://github.com/becketqin/kafka KAFKA-3373 Alterna

[jira] [Updated] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

[ https://issues.apache.org/jira/browse/KAFKA-3373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3373: Status: Patch Available (was: Open) > Add `log` prefix to KIP-31/32 configs > -

[jira] [Commented] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

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

[jira] [Updated] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

[ https://issues.apache.org/jira/browse/KAFKA-3373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3373: Reviewer: Jun Rao > Add `log` prefix to KIP-31/32 configs > - >

Re: [DISCUSS] KIP-35 - Retrieve protocol version

Hey Jay, some thoughts in-line: 2016-03-04 18:52 GMT+01:00 Jay Kreps : > Yeah here is my summary of my take: > > 1. Negotiating a per-connection protocol actually does add a lot of > complexity to clients (many more failure states to get right). > I'm not sure about this. A client that needs t

[GitHub] kafka pull request: MINOR: Add unit test for internal topics

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1047 --- 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] [Created] (KAFKA-3381) Add system test for SimpleConsumerShell

Ashish K Singh created KAFKA-3381: - Summary: Add system test for SimpleConsumerShell Key: KAFKA-3381 URL: https://issues.apache.org/jira/browse/KAFKA-3381 Project: Kafka Issue Type: Sub-task

[jira] [Assigned] (KAFKA-3381) Add system test for SimpleConsumerShell

[ https://issues.apache.org/jira/browse/KAFKA-3381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh reassigned KAFKA-3381: - Assignee: Ashish K Singh > Add system test for SimpleConsumerShell >

[jira] [Assigned] (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 reassigned KAFKA-3382: - Assignee: Ashish K Singh > Add system test for ReplicationVerificationTool >

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

Ashish K Singh created KAFKA-3382: - Summary: Add system test for ReplicationVerificationTool Key: KAFKA-3382 URL: https://issues.apache.org/jira/browse/KAFKA-3382 Project: Kafka Issue Type: S

[jira] [Created] (KAFKA-3383) Producer should not remove an in flight requests before successfully parsing the response.

Jiangjie Qin created KAFKA-3383: --- Summary: Producer should not remove an in flight requests before successfully parsing the response. Key: KAFKA-3383 URL: https://issues.apache.org/jira/browse/KAFKA-3383

[jira] [Commented] (KAFKA-3367) Delete topic dont delete the complete log from kafka

[ https://issues.apache.org/jira/browse/KAFKA-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15190185#comment-15190185 ] Akshath Patkar commented on KAFKA-3367: --- Yes, Automatic topic creation is turned on.

[jira] [Commented] (KAFKA-3367) Delete topic dont delete the complete log from kafka

[ https://issues.apache.org/jira/browse/KAFKA-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15190206#comment-15190206 ] Mayuresh Gharat commented on KAFKA-3367: The client that are producing to the kafk

[jira] [Assigned] (KAFKA-3383) Producer should not remove an in flight requests before successfully parsing the response.

[ https://issues.apache.org/jira/browse/KAFKA-3383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chen zhu reassigned KAFKA-3383: --- Assignee: chen zhu (was: Jiangjie Qin) > Producer should not remove an in flight requests before suc

[jira] [Updated] (KAFKA-3383) Producer should not remove an in flight request before successfully parsing the response.

[ https://issues.apache.org/jira/browse/KAFKA-3383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chen zhu updated KAFKA-3383: Summary: Producer should not remove an in flight request before successfully parsing the response. (was: Pr

[GitHub] kafka pull request: KAFKA-3383: remove in flight request only afte...

GitHub user zhuchen1018 opened a pull request: https://github.com/apache/kafka/pull/1050 KAFKA-3383: remove in flight request only after response parsing succeeds @becketqin, could you take a look at the patch? You can merge this pull request into a Git repository by running: $

[jira] [Commented] (KAFKA-3383) Producer should not remove an in flight request before successfully parsing the response.

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

[jira] [Work started] (KAFKA-3383) Producer should not remove an in flight request before successfully parsing the response.

[ https://issues.apache.org/jira/browse/KAFKA-3383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3383 started by chen zhu. --- > Producer should not remove an in flight request before successfully parsing > the respon

[jira] [Created] (KAFKA-3384) bin scripts may not be portable/POSIX compliant

Ewen Cheslack-Postava created KAFKA-3384: Summary: bin scripts may not be portable/POSIX compliant Key: KAFKA-3384 URL: https://issues.apache.org/jira/browse/KAFKA-3384 Project: Kafka