[jira] [Updated] (KAFKA-806) Index may not always observe log.index.interval.bytes

[ https://issues.apache.org/jira/browse/KAFKA-806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-806: -- Fix Version/s: 0.9.0 It's still an issue. We don't have to fix in 0.8 though. > Index may not always observe lo

[jira] [Created] (KAFKA-1236) Add ability to existing system tests to use the new producer client

Neha Narkhede created KAFKA-1236: Summary: Add ability to existing system tests to use the new producer client Key: KAFKA-1236 URL: https://issues.apache.org/jira/browse/KAFKA-1236 Project: Kafka

[jira] [Updated] (KAFKA-1236) Add ability to existing system tests to use the new producer client

[ https://issues.apache.org/jira/browse/KAFKA-1236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1236: - Assignee: (was: Jun Rao) > Add ability to existing system tests to use the new producer clien

[jira] [Comment Edited] (KAFKA-330) Add delete topic support

[ https://issues.apache.org/jira/browse/KAFKA-330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888769#comment-13888769 ] Neha Narkhede edited comment on KAFKA-330 at 2/1/14 11:08 PM: --

[jira] [Updated] (KAFKA-330) Add delete topic support

[ https://issues.apache.org/jira/browse/KAFKA-330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-330: Fix Version/s: 0.8.1 > Add delete topic support > - > > Key

[jira] [Issue Comment Deleted] (KAFKA-330) Add delete topic support

[ https://issues.apache.org/jira/browse/KAFKA-330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-330: Comment: was deleted (was: Updated reviewboard against branch trunk) > Add delete topic support >

Re: code layout

I like A. It will be simpler to maintain and evolve when we add the admin APIs. On Fri, Jan 31, 2014 at 7:32 PM, Steve Morin wrote: > I like A or C > > I think it will be clearer for people to separate the two. > > > On Fri, Jan 31, 2014 at 3:29 PM, Jay Kreps wrote: > > > For the new producer

[jira] [Commented] (KAFKA-330) Add delete topic support

[ https://issues.apache.org/jira/browse/KAFKA-330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888769#comment-13888769 ] Neha Narkhede commented on KAFKA-330: - Updated reviewboard https://reviews.apache.org/r

[jira] [Updated] (KAFKA-330) Add delete topic support

[ https://issues.apache.org/jira/browse/KAFKA-330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-330: Attachment: KAFKA-330_2014-02-01_14:58:31.patch > Add delete topic support > --

Re: Review Request 17460: Patch for KAFKA-330

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/17460/ --- (Updated Feb. 1, 2014, 10:58 p.m.) Review request for kafka. Bugs: KAFKA-330

Re: Proposed Changes To New Producer Public API

1. Change send to use java.util.concurrent.Future in send(): Future send(ProducerRecord record, Callback callback) The cancel method will always return false and not do anything. Callback will then be changed to interface Callback { public void onCompletion(RecordPosition position, Exceptio

Preparing for 0.8.1 release

Hi, I cleaned up the JIRAs in preparation for the 0.8.1 release. Here are some JIRAsmarked for 0.8.1 that either n

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

[ https://issues.apache.org/jira/browse/KAFKA-934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-934: Fix Version/s: (was: 0.8.1) 0.8.2 > kafka hadoop consumer and producer use ol

[jira] [Updated] (KAFKA-777) Add system tests for important tools

[ https://issues.apache.org/jira/browse/KAFKA-777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-777: Fix Version/s: (was: 0.8.1) 0.9.0 > Add system tests for important tools > --

[jira] [Updated] (KAFKA-853) Allow OffsetFetchRequest to initialize offsets

[ https://issues.apache.org/jira/browse/KAFKA-853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-853: Fix Version/s: (was: 0.8.1) 0.8.2 > Allow OffsetFetchRequest to initialize of

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

[ https://issues.apache.org/jira/browse/KAFKA-478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-478: Fix Version/s: (was: 0.8.1) 0.9.0 > Move start_consumer & start_producer insi

[jira] [Updated] (KAFKA-665) Outgoing responses delayed on a busy Kafka broker

[ https://issues.apache.org/jira/browse/KAFKA-665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-665: Fix Version/s: (was: 0.8.1) 0.8.2 > Outgoing responses delayed on a busy Kafk

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

[ https://issues.apache.org/jira/browse/KAFKA-934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-934: Labels: hadoop hadoop-2.0 newbie (was: hadoop hadoop-2.0) > kafka hadoop consumer and producer use

[jira] [Commented] (KAFKA-1032) Messages sent to the old leader will be lost on broker GC resulted failure

[ https://issues.apache.org/jira/browse/KAFKA-1032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888727#comment-13888727 ] Neha Narkhede commented on KAFKA-1032: -- [~junrao], [~guozhang] Do we want this in 0.8

[jira] [Updated] (KAFKA-1026) Dynamically Adjust Batch Size Upon Receiving MessageSizeTooLargeException

[ https://issues.apache.org/jira/browse/KAFKA-1026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1026: - Fix Version/s: (was: 0.8.1) 0.9.0 > Dynamically Adjust Batch Size Upon Rec

[jira] [Updated] (KAFKA-472) update metadata in batches in Producer

[ https://issues.apache.org/jira/browse/KAFKA-472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-472: Fix Version/s: (was: 0.8.1) 0.9.0 > update metadata in batches in Producer >

[jira] [Updated] (KAFKA-1043) Time-consuming FetchRequest could block other request in the response queue

[ https://issues.apache.org/jira/browse/KAFKA-1043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1043: - Fix Version/s: (was: 0.8.1) 0.8.2 > Time-consuming FetchRequest could bloc

[jira] [Updated] (KAFKA-485) Support MacOS for this test framework

[ https://issues.apache.org/jira/browse/KAFKA-485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-485: Fix Version/s: (was: 0.8.1) 0.9.0 > Support MacOS for this test framework > -

[jira] [Commented] (KAFKA-1080) why are builds for 2.10 not coming out with the trailing minor version number

[ https://issues.apache.org/jira/browse/KAFKA-1080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888726#comment-13888726 ] Neha Narkhede commented on KAFKA-1080: -- [~joestein] Do we need any changes here? > w

[jira] [Updated] (KAFKA-1057) Trim whitespaces from user specified configs

[ https://issues.apache.org/jira/browse/KAFKA-1057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1057: - Fix Version/s: (was: 0.8.1) 0.8.2 > Trim whitespaces from user specified c

[jira] [Updated] (KAFKA-1056) Evenly Distribute Intervals in OffsetIndex

[ https://issues.apache.org/jira/browse/KAFKA-1056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1056: - Fix Version/s: (was: 0.8.1) 0.8.2 > Evenly Distribute Intervals in OffsetI

[jira] [Updated] (KAFKA-1054) Elimiate Compilation Warnings for 0.8 Final Release

[ https://issues.apache.org/jira/browse/KAFKA-1054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1054: - Fix Version/s: (was: 0.8.1) 0.8.2 > Elimiate Compilation Warnings for 0.8

[jira] [Updated] (KAFKA-1056) Evenly Distribute Intervals in OffsetIndex

[ https://issues.apache.org/jira/browse/KAFKA-1056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1056: - Component/s: log > Evenly Distribute Intervals in OffsetIndex > -

[jira] [Updated] (KAFKA-1061) Break-down sendTime to multipleSendTime

[ https://issues.apache.org/jira/browse/KAFKA-1061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1061: - Fix Version/s: (was: 0.8.1) 0.8.2 > Break-down sendTime to multipleSendTim

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

[ https://issues.apache.org/jira/browse/KAFKA-1230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888724#comment-13888724 ] Neha Narkhede commented on KAFKA-1230: -- [~aloklal99] Would you like to attach a patch

[jira] [Commented] (KAFKA-1190) create a draw performance graph script

[ https://issues.apache.org/jira/browse/KAFKA-1190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888723#comment-13888723 ] Neha Narkhede commented on KAFKA-1190: -- Patch pending, moving out of 0.8.1 > create

[jira] [Updated] (KAFKA-1213) Adding fetcher needs to be avoided upon make-follower when replica manager is shutting down

[ https://issues.apache.org/jira/browse/KAFKA-1213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1213: - Fix Version/s: (was: 0.8.1) 0.8.2 > Adding fetcher needs to be avoided upo

[jira] [Updated] (KAFKA-1041) Number of file handles increases indefinitely in producer if broker host is unresolvable

[ https://issues.apache.org/jira/browse/KAFKA-1041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1041: - Labels: features newbie (was: features) > Number of file handles increases indefinitely in produ

[jira] [Updated] (KAFKA-1190) create a draw performance graph script

[ https://issues.apache.org/jira/browse/KAFKA-1190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1190: - Fix Version/s: (was: 0.8.1) 0.8.2 > create a draw performance graph script

[jira] [Updated] (KAFKA-1041) Number of file handles increases indefinitely in producer if broker host is unresolvable

[ https://issues.apache.org/jira/browse/KAFKA-1041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1041: - Fix Version/s: (was: 0.8.1) 0.8.2 > Number of file handles increases indef

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

[ https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-313: Fix Version/s: (was: 0.8.1) 0.8.2 > Add JSON output and looping options to Co

[jira] [Commented] (KAFKA-334) Some tests fail when building on a Windows box

[ https://issues.apache.org/jira/browse/KAFKA-334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888721#comment-13888721 ] Neha Narkhede commented on KAFKA-334: - [~romangarciam] Do these still fail on latest tr

[jira] [Commented] (KAFKA-121) pom should include standard maven niceties

[ https://issues.apache.org/jira/browse/KAFKA-121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888722#comment-13888722 ] Neha Narkhede commented on KAFKA-121: - [~joestein] What do we need to do here before th

[jira] [Updated] (KAFKA-322) Remove one-off Send objects

[ https://issues.apache.org/jira/browse/KAFKA-322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-322: Fix Version/s: (was: 0.8.1) 0.9.0 > Remove one-off Send objects > ---

[jira] [Updated] (KAFKA-179) Log files always touched when broker is bounced

[ https://issues.apache.org/jira/browse/KAFKA-179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-179: Fix Version/s: (was: 0.8.1) 0.8.2 > Log files always touched when broker is b

[jira] [Updated] (KAFKA-997) Provide a strict verification mode when reading configuration properties

[ https://issues.apache.org/jira/browse/KAFKA-997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-997: Fix Version/s: (was: 0.8.1) 0.8.2 > Provide a strict verification mode when r

[jira] [Updated] (KAFKA-1116) Need to upgrade sbt-assembly to compile on scala 2.10.2

[ https://issues.apache.org/jira/browse/KAFKA-1116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1116: - Resolution: Won't Fix Status: Resolved (was: Patch Available) Since we are moving to gra

[jira] [Updated] (KAFKA-334) Some tests fail when building on a Windows box

[ https://issues.apache.org/jira/browse/KAFKA-334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-334: Fix Version/s: (was: 0.8.1) 0.8.2 > Some tests fail when building on a Window

[jira] [Closed] (KAFKA-1116) Need to upgrade sbt-assembly to compile on scala 2.10.2

[ https://issues.apache.org/jira/browse/KAFKA-1116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1116. > Need to upgrade sbt-assembly to compile on scala 2.10.2 > ---

[jira] [Commented] (KAFKA-997) Provide a strict verification mode when reading configuration properties

[ https://issues.apache.org/jira/browse/KAFKA-997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888719#comment-13888719 ] Neha Narkhede commented on KAFKA-997: - Need a rebased patch > Provide a strict verific

[jira] [Resolved] (KAFKA-712) Controlled shutdown tool should provide a meaningful message if a controller failover occurs during the operation

[ https://issues.apache.org/jira/browse/KAFKA-712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-712. - Resolution: Not A Problem > Controlled shutdown tool should provide a meaningful message if a cont

[jira] [Updated] (KAFKA-1040) ConsumerConfig and ProducerConfig do "work" in the Constructor

[ https://issues.apache.org/jira/browse/KAFKA-1040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1040: - Fix Version/s: (was: 0.8.1) 0.9.0 > ConsumerConfig and ProducerConfig do "

[jira] [Updated] (KAFKA-1027) Add documentation for system tests

[ https://issues.apache.org/jira/browse/KAFKA-1027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1027: - Fix Version/s: (was: 0.8.1) 0.9.0 > Add documentation for system tests > -

[jira] [Updated] (KAFKA-392) Refactor and optimize system tests

[ https://issues.apache.org/jira/browse/KAFKA-392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-392: Fix Version/s: (was: 0.8.1) 0.9.0 > Refactor and optimize system tests >

[jira] [Updated] (KAFKA-451) follower replica may need to backoff the fetching if leader is not ready yet

[ https://issues.apache.org/jira/browse/KAFKA-451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-451: Fix Version/s: (was: 0.8.1) 0.8.2 > follower replica may need to backoff the

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

[ https://issues.apache.org/jira/browse/KAFKA-438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-438: Fix Version/s: (was: 0.8.1) 0.8.2 > Code cleanup in MessageTest > ---

[jira] [Updated] (KAFKA-1146) toString() on KafkaStream gets stuck indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-1146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1146: - Fix Version/s: (was: 0.8.1) 0.9.0 > toString() on KafkaStream gets stuck i

[jira] [Updated] (KAFKA-803) Offset returned to producer is not consistent

[ https://issues.apache.org/jira/browse/KAFKA-803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-803: Fix Version/s: (was: 0.8.1) 0.9.0 > Offset returned to producer is not consis

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

[ https://issues.apache.org/jira/browse/KAFKA-795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-795: Fix Version/s: (was: 0.8.1) 0.8.2 > Improvements to PreferredReplicaLeaderEle

[jira] [Updated] (KAFKA-806) Index may not always observe log.index.interval.bytes

[ https://issues.apache.org/jira/browse/KAFKA-806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-806: Fix Version/s: (was: 0.8.1) > Index may not always observe log.index.interval.bytes > --

[jira] [Updated] (KAFKA-766) Isr shrink/expand check is fragile

[ https://issues.apache.org/jira/browse/KAFKA-766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-766: Fix Version/s: (was: 0.8.1) > Isr shrink/expand check is fragile > -

[jira] [Commented] (KAFKA-806) Index may not always observe log.index.interval.bytes

[ https://issues.apache.org/jira/browse/KAFKA-806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888718#comment-13888718 ] Neha Narkhede commented on KAFKA-806: - [~junrao] Do we still need this? > Index may no

[jira] [Updated] (KAFKA-806) Index may not always observe log.index.interval.bytes

[ https://issues.apache.org/jira/browse/KAFKA-806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-806: Component/s: (was: core) log > Index may not always observe log.index.interval.

[jira] [Updated] (KAFKA-404) When using chroot path, create chroot on startup if it doesn't exist

[ https://issues.apache.org/jira/browse/KAFKA-404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-404: Fix Version/s: (was: 0.8.1) 0.8.2 > When using chroot path, create chroot on

[jira] [Commented] (KAFKA-747) RequestChannel re-design

[ https://issues.apache.org/jira/browse/KAFKA-747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888717#comment-13888717 ] Neha Narkhede commented on KAFKA-747: - Relatively large redesign, moving out of 0.8.1

[jira] [Updated] (KAFKA-747) RequestChannel re-design

[ https://issues.apache.org/jira/browse/KAFKA-747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-747: Fix Version/s: (was: 0.8.1) 0.8.2 > RequestChannel re-design > --

[jira] [Updated] (KAFKA-740) Improve crash-safety of log segment swap

[ https://issues.apache.org/jira/browse/KAFKA-740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-740: Fix Version/s: (was: 0.8.1) 0.8.2 > Improve crash-safety of log segment swap

[jira] [Updated] (KAFKA-740) Improve crash-safety of log segment swap

[ https://issues.apache.org/jira/browse/KAFKA-740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-740: Component/s: log > Improve crash-safety of log segment swap > --

[jira] [Resolved] (KAFKA-666) Fetch requests from the replicas take several seconds to complete on the leader

[ https://issues.apache.org/jira/browse/KAFKA-666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-666. - Resolution: Incomplete Fix Version/s: (was: 0.8.1) Need more information to understand

[jira] [Updated] (KAFKA-1034) Improve partition reassignment to optimize writes to zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-1034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1034: - Description: For ReassignPartition tool, check if optimizing the writes to ZK after every replica

[jira] [Closed] (KAFKA-906) Invoke halt on shutdown and startup failure to ensure the jvm is brought down

[ https://issues.apache.org/jira/browse/KAFKA-906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-906. --- > Invoke halt on shutdown and startup failure to ensure the jvm is brought down >

[jira] [Updated] (KAFKA-906) Invoke halt on shutdown and startup failure to ensure the jvm is brought down

[ https://issues.apache.org/jira/browse/KAFKA-906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-906: Fix Version/s: (was: 0.8.1) > Invoke halt on shutdown and startup failure to ensure the jvm is b

[jira] [Resolved] (KAFKA-926) Error in consumer when the leader for some partitions is failing over to another replica.

[ https://issues.apache.org/jira/browse/KAFKA-926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-926. - Resolution: Not A Problem Fix Version/s: (was: 0.8.1) > Error in consumer when the lead

[jira] [Updated] (KAFKA-1034) Improve partition reassignment to optimize writes to zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-1034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1034: - Fix Version/s: (was: 0.8.1) 0.8.2 > Improve partition reassignment to opti

[jira] [Resolved] (KAFKA-906) Invoke halt on shutdown and startup failure to ensure the jvm is brought down

[ https://issues.apache.org/jira/browse/KAFKA-906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-906. - Resolution: Won't Fix > Invoke halt on shutdown and startup failure to ensure the jvm is brought d

[jira] [Updated] (KAFKA-984) Avoid a full rebalance in cases when a new topic is discovered but container/broker set stay the same

[ https://issues.apache.org/jira/browse/KAFKA-984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-984: Fix Version/s: (was: 0.8.1) 0.9.0 > Avoid a full rebalance in cases when a ne

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

[ https://issues.apache.org/jira/browse/KAFKA-493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888711#comment-13888711 ] Neha Narkhede commented on KAFKA-493: - We should try this on Java 7 and observe the CPU

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

[ https://issues.apache.org/jira/browse/KAFKA-493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-493: Fix Version/s: (was: 0.8.1) 0.8.2 > High CPU usage on inactive server > -

[jira] [Commented] (KAFKA-661) Prevent a shutting down broker from re-entering the ISR

[ https://issues.apache.org/jira/browse/KAFKA-661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888709#comment-13888709 ] Neha Narkhede commented on KAFKA-661: - 0.8.1 will add callbacks as part of delete topic

[jira] [Updated] (KAFKA-661) Prevent a shutting down broker from re-entering the ISR

[ https://issues.apache.org/jira/browse/KAFKA-661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-661: Fix Version/s: (was: 0.8.1) 0.8.2 > Prevent a shutting down broker from re-en

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

[ https://issues.apache.org/jira/browse/KAFKA-558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-558: Fix Version/s: (was: 0.8.1) 0.9.0 > KafkaETLContext should use getTopicMetada

[jira] [Updated] (KAFKA-564) Wildcard-based topic consumption should assign partitions to threads uniformly

[ https://issues.apache.org/jira/browse/KAFKA-564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-564: Fix Version/s: (was: 0.8.1) 0.9.0 > Wildcard-based topic consumption should a

[jira] [Updated] (KAFKA-570) Kafka should not need snappy jar at runtime

[ https://issues.apache.org/jira/browse/KAFKA-570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-570: Fix Version/s: (was: 0.8.1) 0.8.2 > Kafka should not need snappy jar at runti

[jira] [Commented] (KAFKA-566) Add last modified time to the TopicMetadataRequest

[ https://issues.apache.org/jira/browse/KAFKA-566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888708#comment-13888708 ] Neha Narkhede commented on KAFKA-566: - 0.8.1 will include delete topic. Probably ok to

[jira] [Updated] (KAFKA-1002) Delete aliveLeaders field from LeaderAndIsrRequest

[ https://issues.apache.org/jira/browse/KAFKA-1002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1002: - Fix Version/s: (was: 0.8.1) 0.8.2 > Delete aliveLeaders field from LeaderA

[jira] [Updated] (KAFKA-566) Add last modified time to the TopicMetadataRequest

[ https://issues.apache.org/jira/browse/KAFKA-566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-566: Fix Version/s: (was: 0.8.1) 0.8.2 > Add last modified time to the TopicMetada

[jira] [Updated] (KAFKA-1108) when controlled shutdown attempt fails, the reason is not always logged

[ https://issues.apache.org/jira/browse/KAFKA-1108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1108: - Fix Version/s: (was: 0.8.1) 0.8.2 > when controlled shutdown attempt fails

[jira] [Updated] (KAFKA-1096) An old controller coming out of long GC could update its epoch to the latest controller's epoch

[ https://issues.apache.org/jira/browse/KAFKA-1096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1096: - Component/s: controller > An old controller coming out of long GC could update its epoch to the l

[jira] [Updated] (KAFKA-1011) Decompression and re-compression on MirrorMaker could result in messages being dropped in the pipeline

[ https://issues.apache.org/jira/browse/KAFKA-1011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1011: - Fix Version/s: (was: 0.8.1) 0.9.0 > Decompression and re-compression on Mi

[jira] [Updated] (KAFKA-1096) An old controller coming out of long GC could update its epoch to the latest controller's epoch

[ https://issues.apache.org/jira/browse/KAFKA-1096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1096: - Fix Version/s: (was: 0.8.1) 0.8.2 > An old controller coming out of long G

[jira] [Commented] (KAFKA-1096) An old controller coming out of long GC could update its epoch to the latest controller's epoch

[ https://issues.apache.org/jira/browse/KAFKA-1096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888707#comment-13888707 ] Neha Narkhede commented on KAFKA-1096: -- This is relatively rare, moving to 0.8.2 > A

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

[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888705#comment-13888705 ] Neha Narkhede commented on KAFKA-1173: -- Not sure what needs to happen here, moving ou

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

[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1173: - Fix Version/s: (was: 0.8.1) > Using Vagrant to get up and running with Apache Kafka > ---

[jira] [Commented] (KAFKA-1160) have the pom reference the exclusions necessary so folks don't have to

[ https://issues.apache.org/jira/browse/KAFKA-1160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888703#comment-13888703 ] Neha Narkhede commented on KAFKA-1160: -- [~joestein] What changes do we need before th

[jira] [Commented] (KAFKA-1159) try to get the bin tar smaller

[ https://issues.apache.org/jira/browse/KAFKA-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888704#comment-13888704 ] Neha Narkhede commented on KAFKA-1159: -- [~joestein] What changes do we need before th

[jira] [Commented] (KAFKA-1162) handle duplicate entry for ZK in the pom file

[ https://issues.apache.org/jira/browse/KAFKA-1162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888701#comment-13888701 ] Neha Narkhede commented on KAFKA-1162: -- [~joestein] Could you add more details on wha

[jira] [Commented] (KAFKA-1163) see whats going on with the 2.8.0 pom

[ https://issues.apache.org/jira/browse/KAFKA-1163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888700#comment-13888700 ] Neha Narkhede commented on KAFKA-1163: -- [~joestein] Is this still a problem? > see w

[jira] [Commented] (KAFKA-1161) review report of the dependencies, conflicts, and licenses into ivy-report

[ https://issues.apache.org/jira/browse/KAFKA-1161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888702#comment-13888702 ] Neha Narkhede commented on KAFKA-1161: -- [~joestein] What changes do we need before th

[jira] [Commented] (KAFKA-1129) if we have a script to run the jar then we should include it in the build or remove it during release

[ https://issues.apache.org/jira/browse/KAFKA-1129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13888699#comment-13888699 ] Neha Narkhede commented on KAFKA-1129: -- [~joestein] Do you think we can have this bef

[jira] [Updated] (KAFKA-1147) Consumer socket timeout should be greater than fetch max wait

[ https://issues.apache.org/jira/browse/KAFKA-1147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1147: - Fix Version/s: (was: 0.8.1) 0.8.2 0.9.0 > Consumer sock

[jira] [Updated] (KAFKA-1164) kafka should depend on snappy 1.0.5 (instead of 1.0.4.1)

[ https://issues.apache.org/jira/browse/KAFKA-1164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1164: - Fix Version/s: (was: 0.8.1) 0.8.2 > kafka should depend on snappy 1.0.5 (i

[jira] [Updated] (KAFKA-1148) Delayed fetch/producer requests should be satisfied on a leader change

[ https://issues.apache.org/jira/browse/KAFKA-1148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1148: - Fix Version/s: (was: 0.8.1) > Delayed fetch/producer requests should be satisfied on a leader

[jira] [Updated] (KAFKA-1143) Consumer should cache topic partition info

[ https://issues.apache.org/jira/browse/KAFKA-1143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1143: - Fix Version/s: (was: 0.8.1) 0.9.0 > Consumer should cache topic partition

[jira] [Updated] (KAFKA-175) Add helper scripts to wrap the current perf tools

[ https://issues.apache.org/jira/browse/KAFKA-175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-175: Fix Version/s: (was: 0.8.1) 0.9.0 > Add helper scripts to wrap the current pe

[jira] [Updated] (KAFKA-156) Messages should not be dropped when brokers are unavailable

[ https://issues.apache.org/jira/browse/KAFKA-156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-156: Fix Version/s: (was: 0.8.1) > Messages should not be dropped when brokers are unavailable >

  1   2   >