[jira] [Commented] (KAFKA-1930) Move server over to new metrics library

2015-02-07 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311151#comment-14311151 ] Manikumar Reddy commented on KAFKA-1930: Are we supporting self-documentation in n

[jira] [Commented] (KAFKA-1794) Make config and config defaults accessible to clients

2015-02-07 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311142#comment-14311142 ] Guozhang Wang commented on KAFKA-1794: -- Makes sense. > Make config and config defaul

[jira] [Commented] (KAFKA-1718) "Message Size Too Large" error when only small messages produced with Snappy

2015-02-07 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311141#comment-14311141 ] Guozhang Wang commented on KAFKA-1718: -- [~jkreps] I think the conclusion is that this

[jira] [Commented] (KAFKA-1856) Add PreCommit Patch Testing

2015-02-07 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311140#comment-14311140 ] Gwen Shapira commented on KAFKA-1856: - Looks good! [~joestein] or [~nehanarkhede] - p

[jira] [Commented] (KAFKA-936) Kafka Metrics Memory Leak

2015-02-07 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311139#comment-14311139 ] Manikumar Reddy commented on KAFKA-936: --- After KAFKA-1481, I am observing one issue.

[jira] [Commented] (KAFKA-1805) Kafka ProducerRecord should implement equals

2015-02-07 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311136#comment-14311136 ] Guozhang Wang commented on KAFKA-1805: -- Thanks for the patch [~parth.brahmbhatt], som

[jira] [Resolved] (KAFKA-620) UnknownHostError looking for a ZK node crashes the broker

2015-02-07 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-620. - Resolution: Duplicate > UnknownHostError looking for a ZK node crashes the broker > ---

[jira] [Resolved] (KAFKA-797) Cannot start Kafka 0.8 per Quick Start instructions

2015-02-07 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-797. --- Resolution: Invalid > Cannot start Kafka 0.8 per Quick Start instructions > ---

[jira] [Commented] (KAFKA-1908) Split brain

2015-02-07 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311109#comment-14311109 ] Gwen Shapira commented on KAFKA-1908: - I think its a multi-lan scenario. The broker c

[jira] [Commented] (KAFKA-313) Add JSON/CSV output and looping options to ConsumerOffsetChecker

2015-02-07 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311107#comment-14311107 ] Gwen Shapira commented on KAFKA-313: ConsumerCommand in KAFKA-1476 does not allow loopi

[jira] [Commented] (KAFKA-1898) compatibility testing framework

2015-02-07 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311098#comment-14311098 ] Joe Stein commented on KAFKA-1898: -- Updated the description. The part that the client lib

[jira] [Updated] (KAFKA-1898) compatibility testing framework

2015-02-07 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1898: - Description: There are a few different scenarios where you want/need to know the status/state of a client

[jira] [Updated] (KAFKA-1898) compatibility testing framework

2015-02-07 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1898: - Attachment: cctk.png > compatibility testing framework > > >

[jira] [Updated] (KAFKA-1758) corrupt recovery file prevents startup

2015-02-07 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1758: - Labels: newbie (was: ) > corrupt recovery file prevents startup > ---

[jira] [Updated] (KAFKA-1758) corrupt recovery file prevents startup

2015-02-07 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1758: - Fix Version/s: 0.9.0 > corrupt recovery file prevents startup > --

[jira] [Created] (KAFKA-1931) Refactor server to use code in org.apache.kafka.common

2015-02-07 Thread Jay Kreps (JIRA)
Jay Kreps created KAFKA-1931: Summary: Refactor server to use code in org.apache.kafka.common Key: KAFKA-1931 URL: https://issues.apache.org/jira/browse/KAFKA-1931 Project: Kafka Issue Type: Impr

[jira] [Created] (KAFKA-1930) Move server over to new metrics library

2015-02-07 Thread Jay Kreps (JIRA)
Jay Kreps created KAFKA-1930: Summary: Move server over to new metrics library Key: KAFKA-1930 URL: https://issues.apache.org/jira/browse/KAFKA-1930 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-1929) Convert core kafka module to use the errors in org.apache.kafka.common.errors

2015-02-07 Thread Jay Kreps (JIRA)
Jay Kreps created KAFKA-1929: Summary: Convert core kafka module to use the errors in org.apache.kafka.common.errors Key: KAFKA-1929 URL: https://issues.apache.org/jira/browse/KAFKA-1929 Project: Kafka

[jira] [Created] (KAFKA-1928) Move kafka.network over to using the network classes in org.apache.kafka.common.network

2015-02-07 Thread Jay Kreps (JIRA)
Jay Kreps created KAFKA-1928: Summary: Move kafka.network over to using the network classes in org.apache.kafka.common.network Key: KAFKA-1928 URL: https://issues.apache.org/jira/browse/KAFKA-1928 Project

[jira] [Updated] (KAFKA-1927) Replace requests in kafka.api with requests in org.apache.kafka.common.requests

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1927: - Description: The common package introduced a better way of defining requests using a new protocol definit

[jira] [Created] (KAFKA-1927) Replace requests in kafka.api with requests in org.apache.kafka.common.requests

2015-02-07 Thread Jay Kreps (JIRA)
Jay Kreps created KAFKA-1927: Summary: Replace requests in kafka.api with requests in org.apache.kafka.common.requests Key: KAFKA-1927 URL: https://issues.apache.org/jira/browse/KAFKA-1927 Project: Kafka

[jira] [Commented] (KAFKA-1925) Coordinator Node Id set to INT_MAX breaks coordinator metadata updates

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311044#comment-14311044 ] Jay Kreps commented on KAFKA-1925: -- Ha ha, that is terrible! :-) +1 We'll figure out some

[jira] [Resolved] (KAFKA-1831) Producer does not provide any information about which host the data was sent to

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1831. -- Resolution: Fixed I think the new producer fixes this, reopen if you disagree. > Producer does not prov

[jira] [Commented] (KAFKA-1831) Producer does not provide any information about which host the data was sent to

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311042#comment-14311042 ] Jay Kreps commented on KAFKA-1831: -- The new producer returns RecordMetadata on each reque

[jira] [Commented] (KAFKA-1897) Enhance MockProducer for more sophisticated tests

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311041#comment-14311041 ] Jay Kreps commented on KAFKA-1897: -- [~navina] WRT your suggestions: 1. Isn't this what th

[jira] [Resolved] (KAFKA-1655) Allow high performance SimpleConsumer use cases to still work with new Kafka 0.9 consumer APIs

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1655. -- Resolution: Invalid > Allow high performance SimpleConsumer use cases to still work with new Kafka > 0.

[jira] [Commented] (KAFKA-1898) compatibility testing framework

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311039#comment-14311039 ] Jay Kreps commented on KAFKA-1898: -- [~charmalloc] Can you expand on this ticket, there is

[jira] [Commented] (KAFKA-1794) Make config and config defaults accessible to clients

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311038#comment-14311038 ] Jay Kreps commented on KAFKA-1794: -- [~navina] This is intentional. The whole config def s

[jira] [Commented] (KAFKA-493) High CPU usage on inactive server

2015-02-07 Thread Olson,Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311032#comment-14311032 ] Olson,Andrew commented on KAFKA-493: I will be out of the office until Monday, 3/2/2015

[jira] [Resolved] (KAFKA-260) Add audit trail to kafka

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-260. - Resolution: Won't Fix > Add audit trail to kafka > > > Key: KAFKA-

[jira] [Resolved] (KAFKA-1827) Optimistic Locking when Producing Messages

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1827. -- Resolution: Won't Fix Yeah this is interesting but currently out of scope. > Optimistic Locking when Pr

[jira] [Resolved] (KAFKA-493) High CPU usage on inactive server

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-493. - Resolution: Incomplete > High CPU usage on inactive server > - > >

[jira] [Resolved] (KAFKA-478) Move start_consumer & start_producer inside "start_entity_in_background"

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-478. - Resolution: Won't Fix > Move start_consumer & start_producer inside "start_entity_in_background" >

[jira] [Resolved] (KAFKA-558) KafkaETLContext should use getTopicMetadata before sending offset requests

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-558. - Resolution: Won't Fix > KafkaETLContext should use getTopicMetadata before sending offset requests > --

[jira] [Resolved] (KAFKA-1790) Remote controlled shutdown was removed

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1790. -- Resolution: Won't Fix > Remote controlled shutdown was removed > --

[jira] [Resolved] (KAFKA-760) building a version other than 2.8.0 with package breaks scripts when running them

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-760. - Resolution: Fixed > building a version other than 2.8.0 with package breaks scripts when running > them >

[jira] [Resolved] (KAFKA-1239) New producer checklist

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1239. -- Resolution: Fixed > New producer checklist > -- > > Key: KAFKA-1239

[jira] [Resolved] (KAFKA-266) Kafka web console

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-266. - Resolution: Won't Fix > Kafka web console > - > > Key: KAFKA-266 >

[jira] [Resolved] (KAFKA-1820) Kafka Leader not found for Topic and Partition

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1820. -- Resolution: Invalid > Kafka Leader not found for Topic and Partition > -

[jira] [Resolved] (KAFKA-282) Currently iterated chunk is not cleared during consumer shutdown

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-282. - Resolution: Fixed > Currently iterated chunk is not cleared during consumer shutdown >

[jira] [Resolved] (KAFKA-280) change on-disk log layout to {log.dir}/topicname/partitionid

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-280. - Resolution: Won't Fix > change on-disk log layout to {log.dir}/topicname/partitionid >

[jira] [Resolved] (KAFKA-289) reuse topicdata when sending producerrequest

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-289. - Resolution: Won't Fix > reuse topicdata when sending producerrequest >

[jira] [Resolved] (KAFKA-288) java impacted changes from new producer and consumer request format

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-288. - Resolution: Won't Fix > java impacted changes from new producer and consumer request format > -

[jira] [Resolved] (KAFKA-293) Allow to configure all broker ids at once similar to how zookeeper handles server ids

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-293. - Resolution: Won't Fix > Allow to configure all broker ids at once similar to how zookeeper handles > serve

[jira] [Resolved] (KAFKA-287) Running a consumer client using scala 2.8 fails

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-287. - Resolution: Fixed > Running a consumer client using scala 2.8 fails > -

[jira] [Resolved] (KAFKA-291) Add builder to create configs for consumer and broker

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-291. - Resolution: Fixed > Add builder to create configs for consumer and broker > ---

[jira] [Resolved] (KAFKA-321) Remove dead brokers from ProducerPool

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-321. - Resolution: Fixed > Remove dead brokers from ProducerPool > - > >

[jira] [Resolved] (KAFKA-299) Change broker request and response to use Seqs rather than Array

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-299. - Resolution: Fixed > Change broker request and response to use Seqs rather than Array >

[jira] [Resolved] (KAFKA-57) Add an optional acknowledgement in the producer

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-57?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-57. Resolution: Fixed (was: Unresolved) > Add an optional acknowledgement in the producer > -

[jira] [Resolved] (KAFKA-331) recurrent produce errors

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-331. - Resolution: Incomplete > recurrent produce errors > > > Key: KAFKA

[jira] [Resolved] (KAFKA-333) mirroring - enable non-random partitioning in embedded producer

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-333. - Resolution: Invalid > mirroring - enable non-random partitioning in embedded producer > ---

[jira] [Resolved] (KAFKA-58) Combine fetch/multifetch and send/multisend

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-58?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-58. Resolution: Fixed (was: Unresolved) > Combine fetch/multifetch and send/multisend > -

[jira] [Resolved] (KAFKA-157) Message may be delivered to incorrect partition incase of semantic partitioning

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-157. - Resolution: Fixed > Message may be delivered to incorrect partition incase of semantic > partitioning > --

[jira] [Resolved] (KAFKA-1) The log4j appender still uses the SyncProducer API

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1. --- Resolution: Invalid (was: Unresolved) > The log4j appender still uses the SyncProducer API > ---

[jira] [Resolved] (KAFKA-5) Continuous log flusher

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-5. --- Resolution: Invalid (was: Unresolved) > Continuous log flusher > -- > > Key:

[jira] [Resolved] (KAFKA-168) Support locality in consumer partition assignment algorithm

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-168. - Resolution: Won't Fix > Support locality in consumer partition assignment algorithm > -

[jira] [Resolved] (KAFKA-178) Simplify the brokerinfo argument to the producer-perf-test.sh

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-178. - Resolution: Invalid > Simplify the brokerinfo argument to the producer-perf-test.sh > -

[jira] [Resolved] (KAFKA-185) The files in the kafka\clients\csharp\src\Kafka\Kafka.Client\cfg folder of the csharp client are out of date.

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-185. - Resolution: Invalid > The files in the kafka\clients\csharp\src\Kafka\Kafka.Client\cfg folder of > the csh

[jira] [Commented] (KAFKA-841) Merge the partition and replica state machines into a single unified state machine in the controller

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311021#comment-14311021 ] Jay Kreps commented on KAFKA-841: - [~nehanarkhede] is this still a consideration? > Merge

[jira] [Resolved] (KAFKA-182) Set a TCP connection timeout for the SimpleConsumer

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-182. - Resolution: Fixed > Set a TCP connection timeout for the SimpleConsumer > -

[jira] [Resolved] (KAFKA-839) Race condition between flushInterval and flushSchedulerInterval

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-839. - Resolution: Won't Fix > Race condition between flushInterval and flushSchedulerInterval > -

[jira] [Resolved] (KAFKA-875) System test cleanup

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-875. - Resolution: Won't Fix > System test cleanup > --- > > Key: KAFKA-875 >

[jira] [Resolved] (KAFKA-874) Migration tool's system tests should use separate server.properties files for 0.7 and 0.8 brokers

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-874. - Resolution: Won't Fix > Migration tool's system tests should use separate server.properties files for > 0.

[jira] [Resolved] (KAFKA-398) Enhance SocketServer to Enable Sending Requests

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-398. - Resolution: Won't Fix > Enhance SocketServer to Enable Sending Requests > -

[jira] [Resolved] (KAFKA-462) ZK thread crashing doesn't bring down the broker (and doesn't come back up).

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-462. - Resolution: Won't Fix > ZK thread crashing doesn't bring down the broker (and doesn't come back up). >

[jira] [Resolved] (KAFKA-402) Adding handling various kind of exception support at server side

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-402. - Resolution: Won't Fix > Adding handling various kind of exception support at server side >

[jira] [Resolved] (KAFKA-410) after been killed, one broker fail to re-join the cluster after restarted

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-410. - Resolution: Cannot Reproduce > after been killed, one broker fail to re-join the cluster after restarted >

[jira] [Resolved] (KAFKA-406) Gzipped payload is a fully wrapped Message (with headers), not just payload

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-406. - Resolution: Won't Fix > Gzipped payload is a fully wrapped Message (with headers), not just payload > -

[jira] [Resolved] (KAFKA-430) Improve the "waitUntilLeaderIsElectedOrChanged" function in TestUtils class

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-430. - Resolution: Won't Fix > Improve the "waitUntilLeaderIsElectedOrChanged" function in TestUtils class > -

[jira] [Resolved] (KAFKA-436) Multifetch response size overflow

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-436. - Resolution: Fixed This should be fixed as part of the response size issues being done for the new consumer

[jira] [Resolved] (KAFKA-650) Create a testcase for Migration Tool with hundreds of topics

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-650. - Resolution: Fixed > Create a testcase for Migration Tool with hundreds of topics >

[jira] [Resolved] (KAFKA-476) change Pool to use Option

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-476. - Resolution: Fixed > change Pool to use Option > -- > > Key: KAFKA-

[jira] [Resolved] (KAFKA-652) Create testcases for clean shut-down

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-652. - Resolution: Fixed > Create testcases for clean shut-down > > >

[jira] [Resolved] (KAFKA-660) Change (topic, partition) tuples to TopicAndPartition

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-660. - Resolution: Fixed > Change (topic, partition) tuples to TopicAndPartition > ---

[jira] [Resolved] (KAFKA-662) Create testcases for unclean shut down

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-662. - Resolution: Fixed > Create testcases for unclean shut down > -- > >

[jira] [Resolved] (KAFKA-663) Add "deploy" feature to System Test

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-663. - Resolution: Won't Fix Not under active development. > Add "deploy" feature to System Test > --

[jira] [Resolved] (KAFKA-715) NumberFormatException in PartitionStateInfo

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-715. - Resolution: Duplicate > NumberFormatException in PartitionStateInfo > -

[jira] [Resolved] (KAFKA-711) NPE in TRUNK broker

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-711. - Resolution: Invalid > NPE in TRUNK broker > --- > > Key: KAFKA-711 >

[jira] [Resolved] (KAFKA-744) Bad response time for fetch request

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-744. - Resolution: Invalid Ancient. > Bad response time for fetch request > --- >

[jira] [Commented] (KAFKA-724) Allow automatic socket.send.buffer from operating system

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311008#comment-14311008 ] Jay Kreps commented on KAFKA-724: - This is fixed on the old scala clients, but not on the n

[jira] [Updated] (KAFKA-724) Allow automatic socket.send.buffer from operating system

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-724: Labels: newbie (was: ) > Allow automatic socket.send.buffer from operating system >

[jira] [Resolved] (KAFKA-761) Fetch request randomly returns 0 bytes when there's still data in the log

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-761. - Resolution: Invalid Super ancient now. > Fetch request randomly returns 0 bytes when there's still data in

[jira] [Resolved] (KAFKA-735) Add looping and JSON output for ConsumerOffsetChecker

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-735. - Resolution: Incomplete No follow-up. > Add looping and JSON output for ConsumerOffsetChecker > ---

[jira] [Resolved] (KAFKA-754) Disable log4j logging in command line tools

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-754. - Resolution: Fixed > Disable log4j logging in command line tools > -

[jira] [Resolved] (KAFKA-778) Fix unclear exceptions when the producer detects 0 partitions for a topic

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-778. - Resolution: Won't Fix New producer probably has new problems :-) > Fix unclear exceptions when the produce

[jira] [Commented] (KAFKA-783) Preferred replica assignment on leader failure may not be correct

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311002#comment-14311002 ] Jay Kreps commented on KAFKA-783: - [~nehanarkhede] Still a problem? > Preferred replica as

[jira] [Resolved] (KAFKA-867) producer transaction issue when metrics lib not correct

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-867. - Resolution: Incomplete No follow-up. > producer transaction issue when metrics lib not correct > -

[jira] [Resolved] (KAFKA-865) Mavenize and separate the client.

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-865. - Resolution: Duplicate > Mavenize and separate the client. > - > >

[jira] [Resolved] (KAFKA-881) Kafka broker not respecting log.roll.hours

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-881. - Resolution: Won't Fix Closing due to ancientness. > Kafka broker not respecting log.roll.hours > -

[jira] [Resolved] (KAFKA-864) bin/kafka-gen-reassignment.sh

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-864. - Resolution: Duplicate I think this is being pursued on another ticket. > bin/kafka-gen-reassignment.sh > -

[jira] [Resolved] (KAFKA-1050) Support for "no data loss" mode

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1050. -- Resolution: Fixed I think both of these are done on other tickets. > Support for "no data loss" mode >

[jira] [Commented] (KAFKA-1044) change log4j to slf4j

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14310994#comment-14310994 ] Jay Kreps commented on KAFKA-1044: -- This would be nice to do. If anyone wants to take it

[jira] [Updated] (KAFKA-1044) change log4j to slf4j

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1044: - Assignee: (was: Jay Kreps) > change log4j to slf4j > -- > > Key:

[jira] [Resolved] (KAFKA-1072) Allow mulitple topics selected with a TopicFilter to be balanced among consumers

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1072. -- Resolution: Fixed I think this is solved with the partition.assignment.strategy option in 0.8.2 > Allow

[jira] [Comment Edited] (KAFKA-1758) corrupt recovery file prevents startup

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14310991#comment-14310991 ] Jay Kreps edited comment on KAFKA-1758 at 2/7/15 11:13 PM: --- This

[jira] [Commented] (KAFKA-1758) corrupt recovery file prevents startup

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14310991#comment-14310991 ] Jay Kreps commented on KAFKA-1758: -- This is actually not a very difficult change--in LogM

[jira] [Resolved] (KAFKA-1767) /admin/reassign_partitions deleted before reassignment completes

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1767. -- Resolution: Incomplete No follow-up. > /admin/reassign_partitions deleted before reassignment completes

[jira] [Resolved] (KAFKA-1808) SimpleConsumer not working as expected

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1808. -- Resolution: Invalid > SimpleConsumer not working as expected > -- >

[jira] [Resolved] (KAFKA-904) ClientUtils throws SocketTimeOut in client side at high load

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-904. - Resolution: Duplicate > ClientUtils throws SocketTimeOut in client side at high load >

[jira] [Commented] (KAFKA-948) ISR list in LeaderAndISR path not updated for partitions when Broker (which is not leader) is down

2015-02-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14310986#comment-14310986 ] Jay Kreps commented on KAFKA-948: - [~junrao] Can this be closed? > ISR list in LeaderAndIS

  1   2   >