[jira] [Updated] (KAFKA-686) 0.8 Kafka broker should give a better error message when running against 0.7 zookeeper

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-686: Fix Version/s: (was: 0.8.2) 0.8.3 > 0.8 Kafka broker should give a better error messag

[jira] [Updated] (KAFKA-438) Code cleanup in MessageTest

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-438: Fix Version/s: (was: 0.8.2) 0.8.3 > Code cleanup in MessageTest >

[jira] [Updated] (KAFKA-1351) String.format is very expensive in Scala

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1351: - Fix Version/s: (was: 0.8.2) 0.8.3 > String.format is very expensive in Scala >

[jira] [Updated] (KAFKA-1420) Replace AdminUtils.createOrUpdateTopicPartitionAssignmentPathInZK with TestUtils.createTopic in unit tests

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1420: - Fix Version/s: (was: 0.8.2) 0.8.3 > Replace AdminUtils.createOrUpdateTopicPartition

[jira] [Updated] (KAFKA-1561) Data Loss for Incremented Replica Factor and Leader Election

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1561: - Fix Version/s: (was: 0.8.2) 0.8.3 > Data Loss for Incremented Replica Factor and Le

[jira] [Updated] (KAFKA-1374) LogCleaner (compaction) does not support compressed topics

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1374: - Fix Version/s: (was: 0.8.2) 0.8.3 > LogCleaner (compaction) does not support compre

[jira] [Updated] (KAFKA-795) Improvements to PreferredReplicaLeaderElection tool

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-795: Fix Version/s: (was: 0.8.2) 0.8.3 > Improvements to PreferredReplicaLeaderElection too

[jira] [Updated] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1660: - Fix Version/s: (was: 0.8.2) 0.8.3 > Ability to call close() with a timeout on the J

[jira] [Updated] (KAFKA-1659) Ability to cleanly abort the KafkaProducer

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1659: - Fix Version/s: (was: 0.8.2) 0.8.3 > Ability to cleanly abort the KafkaProducer > --

[jira] [Updated] (KAFKA-1499) Broker-side compression configuration

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1499: - Fix Version/s: (was: 0.8.2) 0.8.3 > Broker-side compression configuration > ---

[jira] [Updated] (KAFKA-934) kafka hadoop consumer and producer use older 0.19.2 hadoop api's

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-934: Fix Version/s: (was: 0.8.2) 0.8.3 > kafka hadoop consumer and producer use older 0.19.

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

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-313: Fix Version/s: (was: 0.8.2) 0.8.3 > Add JSON output and looping options to ConsumerOff

[jira] [Updated] (KAFKA-1230) shell script files under bin don't work with cygwin (bash on windows)

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1230: - Fix Version/s: (was: 0.8.2) 0.8.3 > shell script files under bin don't work with cy

[jira] [Updated] (KAFKA-1675) bootstrapping tidy-up

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1675: - Fix Version/s: (was: 0.8.2) 0.8.3 > bootstrapping tidy-up > - >

[jira] [Updated] (KAFKA-1661) Move MockConsumer and MockProducer from src/main to src/test

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1661: - Fix Version/s: (was: 0.8.2) 0.8.3 > Move MockConsumer and MockProducer from src/mai

[jira] [Updated] (KAFKA-1651) Removed some extra whitespace in KafkaServer.scala

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1651: - Fix Version/s: (was: 0.8.2) 0.8.3 > Removed some extra whitespace in KafkaServer.sc

[jira] [Updated] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1481: - Fix Version/s: (was: 0.8.2) 0.8.3 > Stop using dashes AND underscores as separators

[jira] [Commented] (KAFKA-1678) add new options for reassign partition to better manager dead brokers

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14178630#comment-14178630 ] Joe Stein commented on KAFKA-1678: -- Agreed, can this ticket be an update for those two it

[jira] [Created] (KAFKA-1722) static analysis code coverage for pci audit needs

2014-10-21 Thread Joe Stein (JIRA)
Joe Stein created KAFKA-1722: Summary: static analysis code coverage for pci audit needs Key: KAFKA-1722 URL: https://issues.apache.org/jira/browse/KAFKA-1722 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-1722) static analysis code coverage for pci audit needs

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1722: - Component/s: security > static analysis code coverage for pci audit needs > --

[jira] [Assigned] (KAFKA-1684) Implement TLS/SSL authentication

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein reassigned KAFKA-1684: Assignee: Ivan Lyutov > Implement TLS/SSL authentication > > >

[jira] [Updated] (KAFKA-1647) Replication offset checkpoints (high water marks) can be lost on hard kills and restarts

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1647: - Fix Version/s: 0.8.2 > Replication offset checkpoints (high water marks) can be lost on hard kills > and

[jira] [Assigned] (KAFKA-1678) add new options for reassign partition to better manager dead brokers

2014-10-22 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein reassigned KAFKA-1678: Assignee: Dmitry Pekar (was: Gwen Shapira) > add new options for reassign partition to better mana

[jira] [Updated] (KAFKA-1678) add new options for reassign partition to better manager dead brokers

2014-10-22 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1678: - Component/s: tools > add new options for reassign partition to better manager dead brokers > -

[jira] [Updated] (KAFKA-1678) add new options for reassign partition to better manager dead brokers

2014-10-22 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1678: - Description: Four changes here each requiring system test, unit test, code to-do the actual work and we s

[jira] [Updated] (KAFKA-1678) add new options for reassign partition to better manager dead brokers

2014-10-22 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1678: - Description: Four changes here each requiring a) system tests b) unit test c) code to-do the actual work

[jira] [Commented] (KAFKA-1683) Implement a "session" concept in the socket server

2014-10-23 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14181323#comment-14181323 ] Joe Stein commented on KAFKA-1683: -- [~gwenshap] We need to be careful with auth once only

[jira] [Updated] (KAFKA-1732) DumpLogSegments tool fails when path has a '.'

2014-10-27 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1732: - Fix Version/s: 0.8.2 > DumpLogSegments tool fails when path has a '.' > --

[jira] [Updated] (KAFKA-1743) ConsumerConnector.commitOffsets in 0.8.2 is not backward compatible

2014-11-04 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1743: - Fix Version/s: 0.8.2 > ConsumerConnector.commitOffsets in 0.8.2 is not backward compatible > -

[jira] [Updated] (KAFKA-1070) Auto-assign node id

2014-11-04 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1070: - Fix Version/s: 0.8.3 > Auto-assign node id > --- > > Key: KAFKA-1070 >

[jira] [Created] (KAFKA-1756) never allow the replica fetch size to be less than the max message size

2014-11-05 Thread Joe Stein (JIRA)
Joe Stein created KAFKA-1756: Summary: never allow the replica fetch size to be less than the max message size Key: KAFKA-1756 URL: https://issues.apache.org/jira/browse/KAFKA-1756 Project: Kafka

[jira] [Commented] (KAFKA-1753) add --decommission-broker option

2014-11-05 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14199564#comment-14199564 ] Joe Stein commented on KAFKA-1753: -- +1 naming the option --decomission-broker > add --de

[jira] [Commented] (KAFKA-1753) add --decommission-broker option

2014-11-05 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14199675#comment-14199675 ] Joe Stein commented on KAFKA-1753: -- yes > add --decommission-broker option > ---

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

2014-11-10 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204807#comment-14204807 ] Joe Stein commented on KAFKA-1173: -- I should have a chance to give the script a spin up/d

[jira] [Commented] (KAFKA-1761) num.partitions documented default is 1 while actual default is 2

2014-11-10 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204840#comment-14204840 ] Joe Stein commented on KAFKA-1761: -- [~sslavic] There are a handful of cases (e.g. https:

[jira] [Updated] (KAFKA-1756) never allow the replica fetch size to be less than the max message size

2014-11-10 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1756: - Fix Version/s: (was: 0.8.2) 0.8.3 > never allow the replica fetch size to be less t

[jira] [Assigned] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

2014-11-10 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein reassigned KAFKA-1173: Assignee: Joe Stein > Using Vagrant to get up and running with Apache Kafka > -

[jira] [Updated] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

2014-11-10 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1173: - Assignee: Ewen Cheslack-Postava (was: Joe Stein) > Using Vagrant to get up and running with Apache Kafka

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

2014-11-10 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14205952#comment-14205952 ] Joe Stein commented on KAFKA-1173: -- This looks really great, so far only minor things (st

[jira] [Commented] (KAFKA-1752) add --replace-broker option

2014-11-11 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14206524#comment-14206524 ] Joe Stein commented on KAFKA-1752: -- I like the approach --replace-broker 1 --broker-list

[jira] [Commented] (KAFKA-1753) add --decommission-broker option

2014-11-11 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14206525#comment-14206525 ] Joe Stein commented on KAFKA-1753: -- I like the approach being taken in KAFKA-1752 --repl

[jira] [Commented] (KAFKA-1753) add --decommission-broker option

2014-11-11 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14206705#comment-14206705 ] Joe Stein commented on KAFKA-1753: -- << A broker list with 29 brokers is pretty annoying

[jira] [Commented] (KAFKA-1752) add --replace-broker option

2014-11-11 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14206915#comment-14206915 ] Joe Stein commented on KAFKA-1752: -- [~nehanarkhede] Yes, there are two (similar) cases th

[jira] [Commented] (KAFKA-1752) add --replace-broker option

2014-11-11 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14207546#comment-14207546 ] Joe Stein commented on KAFKA-1752: -- [~nehanarkhede] I think you make a great point. If KA

[jira] [Updated] (KAFKA-1694) kafka command line shell

2014-11-11 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1694: - Description: https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Command+Line+and+Related+Improvemen

[jira] [Updated] (KAFKA-1694) kafka command line and centralized operations

2014-11-11 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1694: - Summary: kafka command line and centralized operations (was: kafka command line shell) > kafka command l

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

2014-11-12 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14208281#comment-14208281 ] Joe Stein commented on KAFKA-1173: -- [~ewencp] I am +1 on the virtual box parts to the pat

[jira] [Resolved] (KAFKA-1555) provide strong consistency with reasonable availability

2014-11-12 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein resolved KAFKA-1555. -- Resolution: Fixed > provide strong consistency with reasonable availability > --

[jira] [Updated] (KAFKA-1721) Snappy compressor is not thread safe

2014-11-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1721: - Fix Version/s: 0.8.2 > Snappy compressor is not thread safe > > >

[jira] [Updated] (KAFKA-1642) [Java New Producer Kafka Trunk] CPU Usage Spike to 100% when network connection is lost

2014-11-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1642: - Fix Version/s: 0.8.2 > [Java New Producer Kafka Trunk] CPU Usage Spike to 100% when network > connection

[jira] [Updated] (KAFKA-1764) ZookeeperConsumerConnector could put multiple shutdownCommand to the same data chunk queue.

2014-11-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1764: - Fix Version/s: 0.8.2 > ZookeeperConsumerConnector could put multiple shutdownCommand to the same > data c

[jira] [Updated] (KAFKA-1762) Update max-inflight-request doc string

2014-11-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1762: - Fix Version/s: 0.8.3 > Update max-inflight-request doc string > -- > >

[jira] [Updated] (KAFKA-1692) [Java New Producer] IO Thread Name Must include Client ID

2014-11-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1692: - Fix Version/s: 0.8.2 > [Java New Producer] IO Thread Name Must include Client ID > -

[jira] [Updated] (KAFKA-1719) Make mirror maker exit when one consumer/producer thread exits.

2014-11-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1719: - Fix Version/s: 0.8.2 > Make mirror maker exit when one consumer/producer thread exits. > -

[jira] [Updated] (KAFKA-1706) Adding a byte bounded blocking queue to util.

2014-11-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1706: - Fix Version/s: 0.8.2 > Adding a byte bounded blocking queue to util. > ---

[jira] [Updated] (KAFKA-1668) TopicCommand doesn't warn if --topic argument doesn't match any topics

2014-11-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1668: - Fix Version/s: 0.8.3 > TopicCommand doesn't warn if --topic argument doesn't match any topics > --

[jira] [Updated] (KAFKA-1648) Round robin consumer balance throws an NPE when there are no topics

2014-11-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1648: - Fix Version/s: 0.8.3 > Round robin consumer balance throws an NPE when there are no topics > -

[jira] [Updated] (KAFKA-1641) Log cleaner exits if last cleaned offset is lower than earliest offset

2014-11-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1641: - Fix Version/s: 0.8.3 > Log cleaner exits if last cleaned offset is lower than earliest offset > --

[jira] [Updated] (KAFKA-1637) SimpleConsumer.fetchOffset returns wrong error code when no offset exists for topic/partition/consumer group

2014-11-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1637: - Fix Version/s: 0.8.2 > SimpleConsumer.fetchOffset returns wrong error code when no offset exists for > to

[jira] [Updated] (KAFKA-1597) New metrics: ResponseQueueSize and BeingSentResponses

2014-11-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1597: - Fix Version/s: 0.8.2 > New metrics: ResponseQueueSize and BeingSentResponses > ---

[jira] [Updated] (KAFKA-1580) Reject producer requests to internal topics

2014-11-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1580: - Fix Version/s: 0.8.2 > Reject producer requests to internal topics > -

[jira] [Reopened] (KAFKA-1751) handle "broker not exists" and "topic not exists" scenarios

2014-11-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein reopened KAFKA-1751: -- > handle "broker not exists" and "topic not exists" scenarios >

[jira] [Updated] (KAFKA-1751) handle "broker not exists" and "topic not exists" scenarios

2014-11-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1751: - Status: Patch Available (was: Reopened) > handle "broker not exists" and "topic not exists" scenarios > -

[jira] [Created] (KAFKA-1772) Add an Admin message type for request response

2014-11-14 Thread Joe Stein (JIRA)
Joe Stein created KAFKA-1772: Summary: Add an Admin message type for request response Key: KAFKA-1772 URL: https://issues.apache.org/jira/browse/KAFKA-1772 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-1515) Wake-up Sender upon blocked on fetching leader metadata

2014-11-15 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1515: - Fix Version/s: (was: 0.9.0) 0.8.2 P > Wake-up Sender upon blocked on fetching lead

[jira] [Issue Comment Deleted] (KAFKA-1515) Wake-up Sender upon blocked on fetching leader metadata

2014-11-15 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1515: - Comment: was deleted (was: P) > Wake-up Sender upon blocked on fetching leader metadata > ---

[jira] [Created] (KAFKA-1774) REPL and Shell Client for Admin Message RQ/RP

2014-11-15 Thread Joe Stein (JIRA)
Joe Stein created KAFKA-1774: Summary: REPL and Shell Client for Admin Message RQ/RP Key: KAFKA-1774 URL: https://issues.apache.org/jira/browse/KAFKA-1774 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-1775) Re-factor TopicCommand into thew handerAdminMessage call

2014-11-15 Thread Joe Stein (JIRA)
Joe Stein created KAFKA-1775: Summary: Re-factor TopicCommand into thew handerAdminMessage call Key: KAFKA-1775 URL: https://issues.apache.org/jira/browse/KAFKA-1775 Project: Kafka Issue Type: S

[jira] [Updated] (KAFKA-1775) Re-factor TopicCommand into thew handerAdminMessage call

2014-11-15 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1775: - Description: kafka-topic.sh should become kafka --topic --everything else the same from the CLI perspecti

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

2014-11-15 Thread Joe Stein (JIRA)
Joe Stein created KAFKA-1776: Summary: re-factor out existing tools that have been implemented behind the CLI Key: KAFKA-1776 URL: https://issues.apache.org/jira/browse/KAFKA-1776 Project: Kafka

[jira] [Updated] (KAFKA-1775) Re-factor TopicCommand into thew handerAdminMessage call

2014-11-15 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1775: - Description: kafka-topic.sh should become kafka --topic --everything else the same from the CLI perspecti

[jira] [Updated] (KAFKA-1775) Re-factor TopicCommand into thew handerAdminMessage call

2014-11-15 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1775: - Description: kafka-topic.sh should become kafka --topic --everything else the same from the CLI perspecti

[jira] [Created] (KAFKA-1777) Re-factor reasign-partitions into CLI

2014-11-15 Thread Joe Stein (JIRA)
Joe Stein created KAFKA-1777: Summary: Re-factor reasign-partitions into CLI Key: KAFKA-1777 URL: https://issues.apache.org/jira/browse/KAFKA-1777 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-1778) Create new re-elect controller admin function

2014-11-15 Thread Joe Stein (JIRA)
Joe Stein created KAFKA-1778: Summary: Create new re-elect controller admin function Key: KAFKA-1778 URL: https://issues.apache.org/jira/browse/KAFKA-1778 Project: Kafka Issue Type: Sub-task

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

2014-11-15 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1776: - Summary: Re-factor out existing tools that have been implemented behind the CLI (was: re-factor out exist

[jira] [Updated] (KAFKA-1774) REPL and Shell Client for Admin Message RQ/RP

2014-11-16 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1774: - Description: We should have a REPL we can work in and execute the commands with the arguments. With this

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214748#comment-14214748 ] Joe Stein commented on KAFKA-1173: -- I haven't had a chance to review the last changes for

[jira] [Assigned] (KAFKA-1772) Add an Admin message type for request response

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein reassigned KAFKA-1772: Assignee: Joe Stein > Add an Admin message type for request response >

[jira] [Updated] (KAFKA-1772) Add an Admin message type for request response

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1772: - Assignee: (was: Joe Stein) > Add an Admin message type for request response >

[jira] [Updated] (KAFKA-1772) Add an Admin message type for request response

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1772: - Assignee: Andrii Biletskyi > Add an Admin message type for request response >

[jira] [Updated] (KAFKA-1772) Add an Admin message type for request response

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1772: - Reviewer: Joe Stein > Add an Admin message type for request response > ---

[jira] [Updated] (KAFKA-1772) Add an Admin message type for request response

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1772: - Description: - utility int8 - command int8 - format int8 - args variable length bytes utility 0 - Broker

[jira] [Updated] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1781: - Fix Version/s: 0.8.2 > Readme should specify that Gradle 2.0 is required for initial bootstrap > -

[jira] [Updated] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1781: - Priority: Blocker (was: Trivial) > Readme should specify that Gradle 2.0 is required for initial bootstra

[jira] [Commented] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214951#comment-14214951 ] Joe Stein commented on KAFKA-1781: -- [~jean-francois.l...@teximus.com] I have this working

[jira] [Updated] (KAFKA-1624) building on JDK 8 fails

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1624: - Fix Version/s: (was: 0.9.0) 0.8.2 > building on JDK 8 fails > -

[jira] [Reopened] (KAFKA-1624) building on JDK 8 fails

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein reopened KAFKA-1624: -- > building on JDK 8 fails > --- > > Key: KAFKA-1624 > UR

[jira] [Commented] (KAFKA-1624) building on JDK 8 fails

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214956#comment-14214956 ] Joe Stein commented on KAFKA-1624: -- << I did some tests locally with various Scala versio

[jira] [Comment Edited] (KAFKA-1624) building on JDK 8 fails

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214956#comment-14214956 ] Joe Stein edited comment on KAFKA-1624 at 11/17/14 6:30 PM: <<

[jira] [Comment Edited] (KAFKA-1624) building on JDK 8 fails

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214956#comment-14214956 ] Joe Stein edited comment on KAFKA-1624 at 11/17/14 6:30 PM: <<

[jira] [Commented] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14214978#comment-14214978 ] Joe Stein commented on KAFKA-1781: -- That is weird, I tried from a fresh clone just now {

[jira] [Commented] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215030#comment-14215030 ] Joe Stein commented on KAFKA-1781: -- I think your issue is related to your JVM being 8 ins

[jira] [Commented] (KAFKA-1781) Readme should specify that Gradle 2.0 is required for initial bootstrap

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215040#comment-14215040 ] Joe Stein commented on KAFKA-1781: -- JDK 8 related support information is captured here KA

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215515#comment-14215515 ] Joe Stein commented on KAFKA-1173: -- FYI - trying a new AWS secret key but got error becau

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215523#comment-14215523 ] Joe Stein commented on KAFKA-1173: -- ignore last issue I quoted everything and spinni

[jira] [Updated] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1173: - Fix Version/s: 0.8.3 > Using Vagrant to get up and running with Apache Kafka > ---

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215589#comment-14215589 ] Joe Stein commented on KAFKA-1173: -- [~ewencp] The aws parts are further along and servers

[jira] [Comment Edited] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215589#comment-14215589 ] Joe Stein edited comment on KAFKA-1173 at 11/18/14 1:47 AM: [~

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215653#comment-14215653 ] Joe Stein commented on KAFKA-1173: -- [~ewencp] I agree no more toggles unless required. I

[jira] [Commented] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

2014-11-17 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14215675#comment-14215675 ] Joe Stein commented on KAFKA-1173: -- [~ewencp] changing override.hostmanager.ignore_privat

<    1   2   3   4   5   6   7   8   9   10   >