[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-tabpanelfocusedCommentId=14215675#comment-14215675 ] Joe Stein commented on KAFKA-1173: -- [~ewencp] changing

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

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

[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

[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

[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

[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

[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

[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

[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] [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-tabpanelfocusedCommentId=14208281#comment-14208281 ] Joe Stein commented on KAFKA-1173: -- [~ewencp] I am +1 on the virtual box parts to the

[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] [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-tabpanelfocusedCommentId=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-tabpanelfocusedCommentId=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-tabpanelfocusedCommentId=14206915#comment-14206915 ] Joe Stein commented on KAFKA-1752: -- [~nehanarkhede] Yes, there are two (similar) cases

[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-tabpanelfocusedCommentId=14207546#comment-14207546 ] Joe Stein commented on KAFKA-1752: -- [~nehanarkhede] I think you make a great point. If

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

[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

[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-tabpanelfocusedCommentId=14204807#comment-14204807 ] Joe Stein commented on KAFKA-1173: -- I should have a chance to give the script a spin

[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-tabpanelfocusedCommentId=14204840#comment-14204840 ] Joe Stein commented on KAFKA-1761: -- [~sslavic] There are a handful of cases (e.g.

[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

[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-tabpanelfocusedCommentId=14205952#comment-14205952 ] Joe Stein commented on KAFKA-1173: -- This looks really great, so far only minor things

[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-tabpanelfocusedCommentId=14199564#comment-14199564 ] Joe Stein commented on KAFKA-1753: -- +1 naming the option --decomission-broker add

[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-tabpanelfocusedCommentId=14199675#comment-14199675 ] Joe Stein commented on KAFKA-1753: -- yes add --decommission-broker option

[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] [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] [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-tabpanelfocusedCommentId=14181323#comment-14181323 ] Joe Stein commented on KAFKA-1683: -- [~gwenshap] We need to be careful with auth once only

[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

[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

[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] [Updated] (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:all-tabpanel ] Joe Stein updated KAFKA-1678: - Hey [~gwenshap], I have a freed up engineer this week and next to work on this ticket is it ok if I assign

[jira] [Updated] (KAFKA-1566) Kafka environment configuration (kafka-env.sh)

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

[jira] [Updated] (KAFKA-1700) examples directory - README and shell scripts are out of date

2014-10-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1700: - Fix Version/s: (was: 0.8.2) 0.8.3 examples directory - README and shell scripts

[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

[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

[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

[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

[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

[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

[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

[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

[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

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

[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-tabpanelfocusedCommentId=14178630#comment-14178630 ] Joe Stein commented on KAFKA-1678: -- Agreed, can this ticket be an update for those two

[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] [Created] (KAFKA-1714) more better bootstrapping of the gradle-wrapper.jar

2014-10-18 Thread Joe Stein (JIRA)
Joe Stein created KAFKA-1714: Summary: more better bootstrapping of the gradle-wrapper.jar Key: KAFKA-1714 URL: https://issues.apache.org/jira/browse/KAFKA-1714 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-1715) better advertising of the bound and working interface

2014-10-18 Thread Joe Stein (JIRA)
Joe Stein created KAFKA-1715: Summary: better advertising of the bound and working interface Key: KAFKA-1715 URL: https://issues.apache.org/jira/browse/KAFKA-1715 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-1691) new java consumer needs ssl support as a client

2014-10-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1691: - Component/s: security new java consumer needs ssl support as a client

[jira] [Updated] (KAFKA-1682) Security for Kafka

2014-10-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1682: - Component/s: security Security for Kafka -- Key: KAFKA-1682

[jira] [Updated] (KAFKA-1685) Implement TLS/SSL tests

2014-10-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1685: - Component/s: security Implement TLS/SSL tests --- Key: KAFKA-1685

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

2014-10-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1684: - Component/s: security Implement TLS/SSL authentication

[jira] [Updated] (KAFKA-1686) Implement SASL/Kerberos

2014-10-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1686: - Component/s: security Implement SASL/Kerberos --- Key: KAFKA-1686

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

2014-10-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1683: - Component/s: security Implement a session concept in the socket server

[jira] [Updated] (KAFKA-1695) Authenticate connection to Zookeeper

2014-10-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1695: - Component/s: security Authenticate connection to Zookeeper

[jira] [Updated] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

2014-10-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1477: - Component/s: security add authentication layer and initial JKS x509 implementation for brokers,

[jira] [Updated] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

2014-10-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1696: - Component/s: security Kafka should be able to generate Hadoop delegation tokens

[jira] [Updated] (KAFKA-1688) Add authorization interface and naive implementation

2014-10-14 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1688: - Component/s: security Add authorization interface and naive implementation

[jira] [Commented] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

2014-10-10 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14166880#comment-14166880 ] Joe Stein commented on KAFKA-1477: -- Jun, Getting this to work in the new (java) client

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

2014-10-09 Thread Joe Stein (JIRA)
Joe Stein created KAFKA-1694: Summary: kafka command line shell Key: KAFKA-1694 URL: https://issues.apache.org/jira/browse/KAFKA-1694 Project: Kafka Issue Type: Bug Reporter: Joe

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

2014-10-09 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: There are a lot of different kafka tools. Right now I think 5-6 of them are being used

[jira] [Updated] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

2014-10-08 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1477: - Fix Version/s: (was: 0.9.0) 0.8.3 add authentication layer and initial JKS x509

[jira] [Updated] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

2014-10-08 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1477: - Issue Type: Sub-task (was: New Feature) Parent: KAFKA-1682 add authentication layer and initial

[jira] [Created] (KAFKA-1691) new java consumer needs ssl support as a client

2014-10-08 Thread Joe Stein (JIRA)
Joe Stein created KAFKA-1691: Summary: new java consumer needs ssl support as a client Key: KAFKA-1691 URL: https://issues.apache.org/jira/browse/KAFKA-1691 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-1690) new java producer needs ssl support as a client

2014-10-08 Thread Joe Stein (JIRA)
Joe Stein created KAFKA-1690: Summary: new java producer needs ssl support as a client Key: KAFKA-1690 URL: https://issues.apache.org/jira/browse/KAFKA-1690 Project: Kafka Issue Type: Sub-task

[jira] [Commented] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

2014-10-08 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14164017#comment-14164017 ] Joe Stein commented on KAFKA-1477: -- We need to have it support configurable ports and we

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

2014-10-08 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14164147#comment-14164147 ] Joe Stein commented on KAFKA-1684: -- Three related ticket for this. I want to get one

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

2014-10-08 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14164147#comment-14164147 ] Joe Stein edited comment on KAFKA-1684 at 10/8/14 8:59 PM: ---

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

2014-10-06 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: 0.8.2 Assignee: Ivan Lyutov bootstrapping tidy-up -

<    1   2   3   4   5   6   7   8   9   >