[jira] [Commented] (KAFKA-1207) Launch Kafka from within Apache Mesos

2017-01-20 Thread postmas...@inn.ru (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832867#comment-15832867 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipients or groups:

[jira] [Commented] (KAFKA-1207) Launch Kafka from within Apache Mesos

2017-01-20 Thread postmas...@inn.ru (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832868#comment-15832868 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipients or groups:

Re: [VOTE] KIP-74: Add FetchResponse size limit in bytes

2017-01-20 Thread Apurva Mehta
+1 On Fri, Jan 20, 2017 at 5:19 PM, Jason Gustafson wrote: > +1 > > On Fri, Jan 20, 2017 at 4:51 PM, Ismael Juma wrote: > > > Good catch, Colin. +1 to editing the wiki to match the desired behaviour > > and what was implemented in 0.10.1. > > > > Ismael >

[GitHub] kafka pull request #2416: MINOR: Refactor partition lag metric for cleaner e...

2017-01-20 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2416 MINOR: Refactor partition lag metric for cleaner encapsulation You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[GitHub] kafka pull request #2415: KAFKA-4547 (0.10.1 hotfix): Avoid unnecessary offs...

2017-01-20 Thread vahidhashemian
GitHub user vahidhashemian opened a pull request: https://github.com/apache/kafka/pull/2415 KAFKA-4547 (0.10.1 hotfix): Avoid unnecessary offset commit that could lead to an invalid offset position if partition is paused You can merge this pull request into a Git repository by

[jira] [Commented] (KAFKA-4547) Consumer.position returns incorrect results for Kafka 0.10.1.0 client

2017-01-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832806#comment-15832806 ] ASF GitHub Bot commented on KAFKA-4547: --- Github user vahidhashemian closed the pull request at:

[GitHub] kafka pull request #2415: KAFKA-4547 (0.10.1 hotfix): Avoid unnecessary offs...

2017-01-20 Thread vahidhashemian
Github user vahidhashemian closed the pull request at: https://github.com/apache/kafka/pull/2415 --- 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

[jira] [Commented] (KAFKA-4547) Consumer.position returns incorrect results for Kafka 0.10.1.0 client

2017-01-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832805#comment-15832805 ] ASF GitHub Bot commented on KAFKA-4547: --- GitHub user vahidhashemian opened a pull request:

[jira] [Commented] (KAFKA-1207) Launch Kafka from within Apache Mesos

2017-01-20 Thread postmas...@inn.ru (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832783#comment-15832783 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipients or groups:

[jira] [Commented] (KAFKA-1207) Launch Kafka from within Apache Mesos

2017-01-20 Thread postmas...@inn.ru (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832784#comment-15832784 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipients or groups:

[jira] [Commented] (KAFKA-4680) min.insync.replicas can be set higher than replication factor

2017-01-20 Thread huxi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832729#comment-15832729 ] huxi commented on KAFKA-4680: - If sending records to a topic with a larger 'min.insync.replicas' than

Re: Kafka 10 Stability Issue

2017-01-20 Thread Jason Gustafson
Hi there, This sounds similar to https://issues.apache.org/jira/browse/KAFKA-4477. Have you tried 0.10.1.1? -Jason On Fri, Jan 20, 2017 at 5:27 PM, Hui Yang wrote: > Hi, Kafka Team > > This is Hui Yang from Expedia engineer team and want to ask a question > about Kafka 10

Kafka 10 Stability Issue

2017-01-20 Thread Hui Yang
Hi, Kafka Team This is Hui Yang from Expedia engineer team and want to ask a question about Kafka 10 issue. Our team use Kafka as our core infrastructure and recently upgrade from Kafka 0.8.2.2 to Kafka 0.10.1.0 but get a issue after the upgrade. The issue is as below: Kafka 10 works well

[jira] [Created] (KAFKA-4683) Mismatch between Stream windowed store and broker log retention logic

2017-01-20 Thread Elias Levy (JIRA)
Elias Levy created KAFKA-4683: - Summary: Mismatch between Stream windowed store and broker log retention logic Key: KAFKA-4683 URL: https://issues.apache.org/jira/browse/KAFKA-4683 Project: Kafka

Re: [VOTE] KIP-74: Add FetchResponse size limit in bytes

2017-01-20 Thread Jason Gustafson
+1 On Fri, Jan 20, 2017 at 4:51 PM, Ismael Juma wrote: > Good catch, Colin. +1 to editing the wiki to match the desired behaviour > and what was implemented in 0.10.1. > > Ismael > > On Sat, Jan 21, 2017 at 12:19 AM, Colin McCabe wrote: > > > Hi all, > >

[jira] [Comment Edited] (KAFKA-4682) Committed offsets should not be deleted if a consumer is still active

2017-01-20 Thread Jeff Widman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832697#comment-15832697 ] Jeff Widman edited comment on KAFKA-4682 at 1/21/17 1:08 AM: - Now that

[jira] [Commented] (KAFKA-4682) Committed offsets should not be deleted if a consumer is still active

2017-01-20 Thread Jeff Widman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832697#comment-15832697 ] Jeff Widman commented on KAFKA-4682: Now that consumers have background heartbeat thread, it should be

[jira] [Created] (KAFKA-4682) Committed offsets should not be deleted if a consumer is still active

2017-01-20 Thread James Cheng (JIRA)
James Cheng created KAFKA-4682: -- Summary: Committed offsets should not be deleted if a consumer is still active Key: KAFKA-4682 URL: https://issues.apache.org/jira/browse/KAFKA-4682 Project: Kafka

Re: [VOTE] KIP-74: Add FetchResponse size limit in bytes

2017-01-20 Thread Ismael Juma
Good catch, Colin. +1 to editing the wiki to match the desired behaviour and what was implemented in 0.10.1. Ismael On Sat, Jan 21, 2017 at 12:19 AM, Colin McCabe wrote: > Hi all, > > While looking at some code related to KIP-74, I noticed a slight > discrepancy between the

[jira] [Created] (KAFKA-4681) Disallow reassign-partitions script to assign partitions to non-existent brokers

2017-01-20 Thread Nick Travers (JIRA)
Nick Travers created KAFKA-4681: --- Summary: Disallow reassign-partitions script to assign partitions to non-existent brokers Key: KAFKA-4681 URL: https://issues.apache.org/jira/browse/KAFKA-4681

[VOTE] KIP-74: Add FetchResponse size limit in bytes

2017-01-20 Thread Colin McCabe
Hi all, While looking at some code related to KIP-74, I noticed a slight discrepancy between the text on the wiki and the implementation. The wiki says that "If max_bytes is Int.MAX_INT, new request behaves exactly like old one." This would mean that if there was a single message that was

[jira] [Resolved] (KAFKA-3209) Support single message transforms in Kafka Connect

2017-01-20 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3209. -- Resolution: Fixed Fixed in https://github.com/apache/kafka/pull/2374 > Support

[jira] [Commented] (KAFKA-3209) Support single message transforms in Kafka Connect

2017-01-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832655#comment-15832655 ] ASF GitHub Bot commented on KAFKA-3209: --- Github user asfgit closed the pull request at:

[GitHub] kafka pull request #2374: KAFKA-3209: KIP-66: more single message transforms

2017-01-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2374 --- 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-111 : Kafka should preserve the Principal generated by the PrincipalBuilder while processing the request received on socket channel, on the broker.

2017-01-20 Thread Mayuresh Gharat
Hi, Just wanted to see if anyone had any concerns with this KIP. I would like to put this to vote soon, if there are no concerns. Thanks, Mayuresh On Thu, Jan 12, 2017 at 11:21 AM, Mayuresh Gharat < gharatmayures...@gmail.com> wrote: > Hi Ismael, > > Fair point. I will update it. > > Thanks,

[jira] [Commented] (KAFKA-4680) min.insync.replicas can be set higher than replication factor

2017-01-20 Thread James Cheng (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832645#comment-15832645 ] James Cheng commented on KAFKA-4680: I would like to work on this, but I will need some guidance from

[jira] [Created] (KAFKA-4680) min.insync.replicas can be set higher than replication factor

2017-01-20 Thread James Cheng (JIRA)
James Cheng created KAFKA-4680: -- Summary: min.insync.replicas can be set higher than replication factor Key: KAFKA-4680 URL: https://issues.apache.org/jira/browse/KAFKA-4680 Project: Kafka

[jira] [Updated] (KAFKA-4635) Client Compatibility follow-up

2017-01-20 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-4635: --- Status: Patch Available (was: Open) > Client Compatibility follow-up >

[jira] [Commented] (KAFKA-4635) Client Compatibility follow-up

2017-01-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832608#comment-15832608 ] ASF GitHub Bot commented on KAFKA-4635: --- GitHub user cmccabe opened a pull request:

[GitHub] kafka pull request #2414: KAFKA-4635: Client Compatibility follow-ups

2017-01-20 Thread cmccabe
GitHub user cmccabe opened a pull request: https://github.com/apache/kafka/pull/2414 KAFKA-4635: Client Compatibility follow-ups You can merge this pull request into a Git repository by running: $ git pull https://github.com/cmccabe/kafka KAFKA-4635 Alternatively you can

[jira] [Commented] (KAFKA-1207) Launch Kafka from within Apache Mesos

2017-01-20 Thread postmas...@inn.ru (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832606#comment-15832606 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipients or groups:

[jira] [Commented] (KAFKA-1207) Launch Kafka from within Apache Mesos

2017-01-20 Thread postmas...@inn.ru (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832605#comment-15832605 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipients or groups:

[GitHub] kafka-site pull request #42: fix typos on powered by page

2017-01-20 Thread derrickdoo
GitHub user derrickdoo opened a pull request: https://github.com/apache/kafka-site/pull/42 fix typos on powered by page - Fix typos in markup for Tumblr, Etsy, Paypal descriptions You can merge this pull request into a Git repository by running: $ git pull

[GitHub] kafka-site pull request #41: New design for the "powered by" page

2017-01-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka-site/pull/41 --- 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-site issue #41: New design for the "powered by" page

2017-01-20 Thread ewencp
Github user ewencp commented on the issue: https://github.com/apache/kafka-site/pull/41 LGTM --- 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

[GitHub] kafka-site issue #39: New europe meetup links

2017-01-20 Thread ewencp
Github user ewencp commented on the issue: https://github.com/apache/kafka-site/pull/39 LGTM --- 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

[GitHub] kafka-site pull request #39: New europe meetup links

2017-01-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka-site/pull/39 --- 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

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

2017-01-20 Thread Apache Jenkins Server
See

Jenkins build is back to normal : kafka-0.10.2-jdk7 #18

2017-01-20 Thread Apache Jenkins Server
See

[jira] [Updated] (KAFKA-3450) Producer blocks on send to topic that doesn't exist if auto create is disabled

2017-01-20 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-3450: --- Assignee: (was: Jun Rao) > Producer blocks on send to topic that doesn't exist if auto create is disabled

[jira] [Commented] (KAFKA-2000) Delete consumer offsets from kafka once the topic is deleted

2017-01-20 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832410#comment-15832410 ] Sriharsha Chintalapani commented on KAFKA-2000: --- [~jeffwidman] [~omkreddy] working on it.

[jira] [Commented] (KAFKA-2000) Delete consumer offsets from kafka once the topic is deleted

2017-01-20 Thread Jeff Widman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832378#comment-15832378 ] Jeff Widman commented on KAFKA-2000: If neither of them is interested, I'm happy to cleanup the

[jira] [Comment Edited] (KAFKA-2000) Delete consumer offsets from kafka once the topic is deleted

2017-01-20 Thread Jeff Widman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832378#comment-15832378 ] Jeff Widman edited comment on KAFKA-2000 at 1/20/17 8:45 PM: - If neither of

[jira] [Updated] (KAFKA-2000) Delete consumer offsets from kafka once the topic is deleted

2017-01-20 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-2000: -- Assignee: Manikumar Reddy (was: Sriharsha Chintalapani) > Delete consumer

[jira] [Created] (KAFKA-4679) Remove unstable markers from Connect APIs

2017-01-20 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-4679: Summary: Remove unstable markers from Connect APIs Key: KAFKA-4679 URL: https://issues.apache.org/jira/browse/KAFKA-4679 Project: Kafka

[jira] [Commented] (KAFKA-2000) Delete consumer offsets from kafka once the topic is deleted

2017-01-20 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832295#comment-15832295 ] Jason Gustafson commented on KAFKA-2000: It would be nice to get this fixed. The patch from

[GitHub] kafka pull request #2413: MINOR: update JavaDoc for DSL PAPI-API

2017-01-20 Thread mjsax
GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2413 MINOR: update JavaDoc for DSL PAPI-API You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka javaDocImprovements6 Alternatively you can

[jira] [Commented] (KAFKA-1207) Launch Kafka from within Apache Mesos

2017-01-20 Thread postmas...@inn.ru (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832279#comment-15832279 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipients or groups:

[jira] [Commented] (KAFKA-1207) Launch Kafka from within Apache Mesos

2017-01-20 Thread postmas...@inn.ru (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832280#comment-15832280 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipients or groups:

[GitHub] kafka pull request #2412: MINOR: reduce verbosity of cache flushes

2017-01-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2412 --- 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-1641) Log cleaner exits if last cleaned offset is lower than earliest offset

2017-01-20 Thread Peter Davis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832266#comment-15832266 ] Peter Davis commented on KAFKA-1641: "Me too" on 0.10.0.1 - does this issue need to be reopened?

[jira] [Commented] (KAFKA-4676) Kafka consumers gets stuck for some partitions

2017-01-20 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832255#comment-15832255 ] Jason Gustafson commented on KAFKA-4676: Logs from the consumer would also be helpful. Thanks. >

[jira] [Commented] (KAFKA-4675) Subsequent CreateTopic command could be lost after a DeleteTopic command

2017-01-20 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832248#comment-15832248 ] Guozhang Wang commented on KAFKA-4675: -- Actually no, I did not see the exception from broker side. >

[jira] [Resolved] (KAFKA-1776) Re-factor out existing tools that have been implemented behind the CLI

2017-01-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-1776. - Resolution: Duplicate > Re-factor out existing tools that have been implemented behind the CLI >

[GitHub] kafka pull request #2412: MINOR: reduce verbosity of cache flushes

2017-01-20 Thread xvrl
GitHub user xvrl opened a pull request: https://github.com/apache/kafka/pull/2412 MINOR: reduce verbosity of cache flushes This log message tends to be extremely verbose when state stores are being restored You can merge this pull request into a Git repository by running: $

[jira] [Created] (KAFKA-4678) Create separate page for Connect docs

2017-01-20 Thread Shikhar Bhushan (JIRA)
Shikhar Bhushan created KAFKA-4678: -- Summary: Create separate page for Connect docs Key: KAFKA-4678 URL: https://issues.apache.org/jira/browse/KAFKA-4678 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-1379) Partition reassignment resets clock for time-based retention

2017-01-20 Thread Andrew Olson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832155#comment-15832155 ] Andrew Olson commented on KAFKA-1379: - [~jjkoshy] / [~becket_qin] should this Jira now be closed as a

Improve License Header Check

2017-01-20 Thread Matthias J. Sax
Hi, I opened an PR to improve the check for file license header (the check is currently quite weak and it's possible to have files with an invalid header). https://github.com/apache/kafka/pull/2303/ As some people do have IDE setting for adding a header automatically, we wanted to give a heads

[jira] [Commented] (KAFKA-4677) Avoid unnecessary task movement across threads of the same process during rebalance

2017-01-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832090#comment-15832090 ] ASF GitHub Bot commented on KAFKA-4677: --- GitHub user dguy opened a pull request:

[GitHub] kafka pull request #2411: [WIP] KAFKA-4677: Avoid unnecessary task movement ...

2017-01-20 Thread dguy
GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/2411 [WIP] KAFKA-4677: Avoid unnecessary task movement across threads of the same process during rebalance You can merge this pull request into a Git repository by running: $ git pull

[jira] [Updated] (KAFKA-4677) Avoid unnecessary task movement across threads of the same process during rebalance

2017-01-20 Thread Damian Guy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4677: -- Summary: Avoid unnecessary task movement across threads of the same process during rebalance (was:

[GitHub] kafka pull request #2410: MINOR: Fix typo in WordCountProcessorDemo

2017-01-20 Thread wmarshall484
Github user wmarshall484 closed the pull request at: https://github.com/apache/kafka/pull/2410 --- 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

[GitHub] kafka pull request #2410: MINOR: Fix typo in WordCountProcessorDemo

2017-01-20 Thread wmarshall484
GitHub user wmarshall484 reopened a pull request: https://github.com/apache/kafka/pull/2410 MINOR: Fix typo in WordCountProcessorDemo `bin-kafka-console-producer.sh` should be `bin/kafka-console-producer.sh`. You can merge this pull request into a Git repository by running: $

[jira] [Commented] (KAFKA-3450) Producer blocks on send to topic that doesn't exist if auto create is disabled

2017-01-20 Thread Esoga Simmons (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832030#comment-15832030 ] Esoga Simmons commented on KAFKA-3450: -- This issue is a dup of [KAFKA-3539] reported by

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

2017-01-20 Thread Christos Trochalakis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831955#comment-15831955 ] Christos Trochalakis commented on KAFKA-4477: - We also experienced the same issue today. The

[jira] [Commented] (KAFKA-4675) Subsequent CreateTopic command could be lost after a DeleteTopic command

2017-01-20 Thread huxi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831945#comment-15831945 ] huxi commented on KAFKA-4675: - Seems deleting '/brokers/topics/' comes fourth from the bottom during the

[jira] [Commented] (KAFKA-1207) Launch Kafka from within Apache Mesos

2017-01-20 Thread postmas...@inn.ru (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831908#comment-15831908 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipients or groups:

[jira] [Commented] (KAFKA-1207) Launch Kafka from within Apache Mesos

2017-01-20 Thread postmas...@inn.ru (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831909#comment-15831909 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipients or groups:

[jira] [Created] (KAFKA-4677) Make StreamPartitionAssigner more sticky when assigning to threads

2017-01-20 Thread Damian Guy (JIRA)
Damian Guy created KAFKA-4677: - Summary: Make StreamPartitionAssigner more sticky when assigning to threads Key: KAFKA-4677 URL: https://issues.apache.org/jira/browse/KAFKA-4677 Project: Kafka

[jira] [Comment Edited] (KAFKA-4676) Kafka consumers gets stuck for some partitions

2017-01-20 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831639#comment-15831639 ] Ismael Juma edited comment on KAFKA-4676 at 1/20/17 12:25 PM: -- Thanks for the

[jira] [Commented] (KAFKA-4676) Kafka consumers gets stuck for some partitions

2017-01-20 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831639#comment-15831639 ] Ismael Juma commented on KAFKA-4676: Thanks for the report. Do the broker logs show any issue? Also,

[jira] [Updated] (KAFKA-4676) Kafka consumers gets stuck for some partitions

2017-01-20 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4676: --- Labels: consumer reliability (was: consumer) > Kafka consumers gets stuck for some partitions >

[jira] [Created] (KAFKA-4676) Kafka consumers gets stuck for some partitions

2017-01-20 Thread Vishal Shukla (JIRA)
Vishal Shukla created KAFKA-4676: Summary: Kafka consumers gets stuck for some partitions Key: KAFKA-4676 URL: https://issues.apache.org/jira/browse/KAFKA-4676 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-1207) Launch Kafka from within Apache Mesos

2017-01-20 Thread postmas...@inn.ru (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831549#comment-15831549 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipients or groups:

[jira] [Commented] (KAFKA-1207) Launch Kafka from within Apache Mesos

2017-01-20 Thread postmas...@inn.ru (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831544#comment-15831544 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipients or groups:

RE: MirrorMaker across Kafka Clusters with different versions

2017-01-20 Thread david.franklin
Thanks for confirming that Gwen. Best wishes, David -Original Message- From: Gwen Shapira [mailto:g...@confluent.io] Sent: 19 January 2017 20:41 To: dev@kafka.apache.org Subject: Re: MirrorMaker across Kafka Clusters with different versions As you figured out - 0.10 clients (including

[jira] [Commented] (KAFKA-4566) Can't Symlink to Kafka bins

2017-01-20 Thread Akhilesh Naidu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831447#comment-15831447 ] Akhilesh Naidu commented on KAFKA-4566: --- If the above suggestion seems ok can someone assign this

[jira] [Comment Edited] (KAFKA-4566) Can't Symlink to Kafka bins

2017-01-20 Thread Akhilesh Naidu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831442#comment-15831442 ] Akhilesh Naidu edited comment on KAFKA-4566 at 1/20/17 9:20 AM: One

[jira] [Comment Edited] (KAFKA-4566) Can't Symlink to Kafka bins

2017-01-20 Thread Akhilesh Naidu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831442#comment-15831442 ] Akhilesh Naidu edited comment on KAFKA-4566 at 1/20/17 9:16 AM: One

[jira] [Commented] (KAFKA-4566) Can't Symlink to Kafka bins

2017-01-20 Thread Akhilesh Naidu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831442#comment-15831442 ] Akhilesh Naidu commented on KAFKA-4566: --- One approach could be to simulate the working of the

[jira] [Created] (KAFKA-4675) Subsequent CreateTopic command could be lost after a DeleteTopic command

2017-01-20 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-4675: Summary: Subsequent CreateTopic command could be lost after a DeleteTopic command Key: KAFKA-4675 URL: https://issues.apache.org/jira/browse/KAFKA-4675 Project:

[GitHub] kafka pull request #2410: MINOR: Fix typo in WordCountProcessorDemo

2017-01-20 Thread wmarshall484
GitHub user wmarshall484 opened a pull request: https://github.com/apache/kafka/pull/2410 MINOR: Fix typo in WordCountProcessorDemo `bin-kafka-console-producer.sh` should be `bin/kafka-console-producer.sh`. You can merge this pull request into a Git repository by running: $