Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)

For the maven artifacts listed above, there doesn't seem to be any distinction between rc1 or rc2, so is it assumed that this is release2 here?: https://repository.apache.org/content/groups/staging/org/apache/kafka/kafka_2.11/0.8.2.0/ Thanks! Jason On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao wrot

Re: Review Request 32251: Patch for KAFKA-2032

tps://reviews.apache.org/r/32251/#comment124925> Should this be called 'validatePartitionAssignmentStrategy'? At any rate 'Stretegy' is mispelled there. - Jason Rosenberg On March 19, 2015, 6:47 p.

Re: Review Request 35867: Patch for KAFKA-1901

/JmxReporter.java (line 58) <https://reviews.apache.org/r/35867/#comment141935> what's the reason for this change? - Jason Rosenberg On June 25, 2015, 10:11 a.m., Manikumar Reddy O wrote: > > --- > This is an automatically

Re: Review Request 35867: Patch for KAFKA-1901

- Jason Rosenberg On June 25, 2015, 10:11 a.m., Manikumar Reddy O wrote: > > --- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache

Re: 0.9.0.0 remaining jiras

Hi Jun, Can you clarify, will there not be a 0.8.3.0 (and instead we move straight to 0.9.0.0)? Also, can you outline the man new features/updates for 0.9.0.0? Thanks, Jason On Sat, Sep 12, 2015 at 12:40 PM, Jun Rao wrote: > The following is a candidate list of jiras that we want to complete

Re: 0.9.0.0 remaining jiras

-archives.apache.org/mod_mbox/kafka-dev/201509.mbox/%3CCAFc58G-UScVKrSF1kdsowQ8Y96OAaZEdiZsk40G8fwf7iToFaw%40mail.gmail.com%3E > > Kind regards, > Stevo Slavic. > > > On Mon, Sep 14, 2015 at 8:56 AM, Jason Rosenberg wrote: > > > Hi Jun, > > > > Can you clarify,

Re: 0.9.0.0 remaining jiras

apache.org/jira/browse/KAFKA- (seems important to fix) Jason On Tue, Sep 15, 2015 at 3:28 PM, Jason Rosenberg wrote: > Yep, > > It looks like this was only communicated originally to the dev list (and > not the users list), so it wasn't obvious to all! > > Thanks, >

Re: pushing delete topic feature out of 0.8

Ok, This is a feature I've been hoping for, so I added an upvote to Kafka-330. But I will defer to you in terms of not wanting to delay 0.8 unnecessarily. Will we still have a backhanded way to remove a topic if need be? Ultimately, I'd like to see the feature where a topic automatically is cr

Re: 0.8.0-beta1 is now available in public maven

Thanks for doing this! I'm wondering whether there is a reason to prefer one version of scala over another, if we don't have any other particular scala dependency in our code. Are the newer versions better/more efficient, some how? We've essentially been using 2.8.0 so far, which seems to be fin

Re: Client improvement discussion

Jay, This seems like a great direction. Simplifying the consumer client would be a big win, and +1 for more native java client integration. On the last point, regarding memory usage for buffering per partition. I would think it could be possible to devise a dynamic queuing system, to allow high

Re: preparing for the 0.8 final release

Will the 0.8 release come from the HEAD of the 0.8 branch? I'd like to experiment with it, to see if it solves some of the issues I'm seeing, with consumers refusing to consume new messages. We've been using the beta1 version. I remember mention there was a Jira issues along these lines, which w

Re: preparing for the 0.8 final release

gt; On Fri, Oct 18, 2013 at 4:03 PM, Jason Rosenberg wrote: > > > Will the 0.8 release come from the HEAD of the 0.8 branch? I'd like to > > experiment with it, to see if it solves some of the issues I'm seeing, > with > > consumers refusing to consume new messages

Re: preparing for the 0.8 final release

I'll try to, next time it hangs! On Sat, Oct 19, 2013 at 4:04 PM, Neha Narkhede wrote: > Can you send around a thread dump of the halted consumer process? > > > > On Sat, Oct 19, 2013 at 12:16 PM, Jason Rosenberg > wrote: > > > The latest HEAD does seem to so

Re: preparing for the 0.8 final release

te time re-polling all those (and getting nothing) before coming back to the topics that are lagging? Perhaps having a larger fetch size would help here? Jason On Sat, Oct 19, 2013 at 6:24 PM, Jason Rosenberg wrote: > I'll try to, next time it hangs! > > > On Sat, Oct 19, 201

Consumer lag issues

sumer%3F > , > which may be related to your issue. > > Thanks, > > Jun > > > On Sun, Oct 20, 2013 at 2:48 AM, Jason Rosenberg wrote: > > > Ok, > > > > So here's an outline of what I think seems to have happened. > > > > I have a consumer

[jira] [Commented] (KAFKA-3536) ReplicaFetcherThread should not log errors when leadership changes

[ https://issues.apache.org/jira/browse/KAFKA-3536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15332767#comment-15332767 ] Jason Rosenberg commented on KAFKA-3536: which version are you seeing thi

[jira] [Created] (KAFKA-2125) Infinite loop after controlled shutdown succeeds

Jason Rosenberg created KAFKA-2125: -- Summary: Infinite loop after controlled shutdown succeeds Key: KAFKA-2125 URL: https://issues.apache.org/jira/browse/KAFKA-2125 Project: Kafka Issue

[jira] [Updated] (KAFKA-2125) Infinite loop after controlled shutdown succeeds

[ https://issues.apache.org/jira/browse/KAFKA-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Rosenberg updated KAFKA-2125: --- Attachment: grep_shut.log > Infinite loop after controlled shutdown succe

[jira] [Commented] (KAFKA-2125) Infinite loop after controlled shutdown succeeds

[ https://issues.apache.org/jira/browse/KAFKA-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14496794#comment-14496794 ] Jason Rosenberg commented on KAFKA-2125: I uploaded an edited result of d

[jira] [Updated] (KAFKA-2125) Infinite loop after controlled shutdown succeeds

[ https://issues.apache.org/jira/browse/KAFKA-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Rosenberg updated KAFKA-2125: --- Attachment: (was: grep_shut.log) > Infinite loop after controlled shutdown succe

[jira] [Updated] (KAFKA-2125) Infinite loop after controlled shutdown succeeds

[ https://issues.apache.org/jira/browse/KAFKA-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Rosenberg updated KAFKA-2125: --- Attachment: grep_shut_edited.log > Infinite loop after controlled shutdown succe

[jira] [Comment Edited] (KAFKA-2125) Infinite loop after controlled shutdown succeeds

[ https://issues.apache.org/jira/browse/KAFKA-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14496794#comment-14496794 ] Jason Rosenberg edited comment on KAFKA-2125 at 4/15/15 8:0

[jira] [Commented] (KAFKA-2125) Infinite loop after controlled shutdown succeeds

[ https://issues.apache.org/jira/browse/KAFKA-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14496883#comment-14496883 ] Jason Rosenberg commented on KAFKA-2125: Joel, unfortunately I have no s

[jira] [Commented] (KAFKA-2125) Infinite loop after controlled shutdown succeeds

[ https://issues.apache.org/jira/browse/KAFKA-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14496898#comment-14496898 ] Jason Rosenberg commented on KAFKA-2125: Ooh, it looks before the 500 repe

[jira] [Commented] (KAFKA-2125) Infinite loop after controlled shutdown succeeds

[ https://issues.apache.org/jira/browse/KAFKA-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14497035#comment-14497035 ] Jason Rosenberg commented on KAFKA-2125: This cluster has 4 nodes. each node

[jira] [Created] (KAFKA-2127) Running TopicCommand --alter causes connection close/reset errors in kafka logs

Jason Rosenberg created KAFKA-2127: -- Summary: Running TopicCommand --alter causes connection close/reset errors in kafka logs Key: KAFKA-2127 URL: https://issues.apache.org/jira/browse/KAFKA-2127

[jira] [Updated] (KAFKA-2127) Running TopicCommand --alter causes connection close/reset errors in kafka logs

[ https://issues.apache.org/jira/browse/KAFKA-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Rosenberg updated KAFKA-2127: --- Description: I am using 0.8.2.1. I've been noticing that any time I use TopicComma

[jira] [Commented] (KAFKA-2127) Running TopicCommand --alter causes connection close/reset errors in kafka logs

[ https://issues.apache.org/jira/browse/KAFKA-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14497570#comment-14497570 ] Jason Rosenberg commented on KAFKA-2127: the ip's that show in the

[jira] [Comment Edited] (KAFKA-2127) Running TopicCommand --alter causes connection close/reset errors in kafka logs

[ https://issues.apache.org/jira/browse/KAFKA-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14497570#comment-14497570 ] Jason Rosenberg edited comment on KAFKA-2127 at 4/16/15 5:1

[jira] [Comment Edited] (KAFKA-2127) Running TopicCommand --alter causes connection close/reset errors in kafka logs

[ https://issues.apache.org/jira/browse/KAFKA-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14497570#comment-14497570 ] Jason Rosenberg edited comment on KAFKA-2127 at 4/16/15 5:1

[jira] [Updated] (KAFKA-2127) Running TopicCommand --alter causes connection close/reset errors in kafka logs

[ https://issues.apache.org/jira/browse/KAFKA-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Rosenberg updated KAFKA-2127: --- Description: I am using 0.8.2.1. I've been noticing that any time I use TopicComma

[jira] [Commented] (KAFKA-2127) Running TopicCommand --alter causes connection close/reset errors in kafka logs

[ https://issues.apache.org/jira/browse/KAFKA-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14497576#comment-14497576 ] Jason Rosenberg commented on KAFKA-2127: Also, unrelated to the socket er

[jira] [Commented] (KAFKA-2125) Infinite loop after controlled shutdown succeeds

[ https://issues.apache.org/jira/browse/KAFKA-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14497616#comment-14497616 ] Jason Rosenberg commented on KAFKA-2125: So, I'd think the exception the

[jira] [Created] (KAFKA-2172) Round-robin partition assignment strategy too restrictive

Jason Rosenberg created KAFKA-2172: -- Summary: Round-robin partition assignment strategy too restrictive Key: KAFKA-2172 URL: https://issues.apache.org/jira/browse/KAFKA-2172 Project: Kafka

[jira] [Commented] (KAFKA-2172) Round-robin partition assignment strategy too restrictive

[ https://issues.apache.org/jira/browse/KAFKA-2172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14529436#comment-14529436 ] Jason Rosenberg commented on KAFKA-2172: as a side note, the documentation

[jira] [Created] (KAFKA-2181) online doc issues

Jason Rosenberg created KAFKA-2181: -- Summary: online doc issues Key: KAFKA-2181 URL: https://issues.apache.org/jira/browse/KAFKA-2181 Project: Kafka Issue Type: Bug Reporter

[jira] [Created] (KAFKA-2222) Write "Input/output error" did not result in broker shutdown

Jason Rosenberg created KAFKA-: -- Summary: Write "Input/output error" did not result in broker shutdown Key: KAFKA- URL: https://issues.apache.org/jira/browse/KAFKA- Proj

[jira] [Commented] (KAFKA-2222) Write "Input/output error" did not result in broker shutdown

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14560387#comment-14560387 ] Jason Rosenberg commented on KAFKA-: Interestingly, after restarting

[jira] [Comment Edited] (KAFKA-2222) Write "Input/output error" did not result in broker shutdown

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14560387#comment-14560387 ] Jason Rosenberg edited comment on KAFKA- at 5/27/15 5:0

[jira] [Commented] (KAFKA-2222) Write "Input/output error" did not result in broker shutdown

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14560417#comment-14560417 ] Jason Rosenberg commented on KAFKA-: [~guozhang] I don't think so.

[jira] [Commented] (KAFKA-2222) Write "Input/output error" did not result in broker shutdown

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14566956#comment-14566956 ] Jason Rosenberg commented on KAFKA-: Agreed. I think in the past there w

[jira] [Created] (KAFKA-2250) ConcurrentModificationException in metrics reporting

Jason Rosenberg created KAFKA-2250: -- Summary: ConcurrentModificationException in metrics reporting Key: KAFKA-2250 URL: https://issues.apache.org/jira/browse/KAFKA-2250 Project: Kafka Issue

[jira] [Created] (KAFKA-2251) "Connection reset by peer" IOExceptions should not be logged as ERROR

Jason Rosenberg created KAFKA-2251: -- Summary: "Connection reset by peer" IOExceptions should not be logged as ERROR Key: KAFKA-2251 URL: https://issues.apache.org/jira/browse/KAFKA-2251

[jira] [Updated] (KAFKA-2251) "Connection reset by peer" IOExceptions should not be logged as ERROR

[ https://issues.apache.org/jira/browse/KAFKA-2251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Rosenberg updated KAFKA-2251: --- Description: It's normal to see lots of these exceptions logged in the broker logs:

[jira] [Created] (KAFKA-2252) Socket connection closing is logged, but not corresponding opening of socket

Jason Rosenberg created KAFKA-2252: -- Summary: Socket connection closing is logged, but not corresponding opening of socket Key: KAFKA-2252 URL: https://issues.apache.org/jira/browse/KAFKA-2252

[jira] [Updated] (KAFKA-2252) Socket connection closing is logged, but not corresponding opening of socket

[ https://issues.apache.org/jira/browse/KAFKA-2252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Rosenberg updated KAFKA-2252: --- Description: (using 0.8.2.1) We see a large number of "Closing socket connection"

[jira] [Created] (KAFKA-1901) Move Kafka version to be generated in code by build (instead of in manifest)

Jason Rosenberg created KAFKA-1901: -- Summary: Move Kafka version to be generated in code by build (instead of in manifest) Key: KAFKA-1901 URL: https://issues.apache.org/jira/browse/KAFKA-1901

[jira] [Commented] (KAFKA-1507) Using GetOffsetShell against non-existent topic creates the topic unintentionally

[ https://issues.apache.org/jira/browse/KAFKA-1507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14292220#comment-14292220 ] Jason Rosenberg commented on KAFKA-1507: I think relegating topic creation t

[jira] [Commented] (KAFKA-1902) fix MetricName so that Yammer reporter can work correctly

[ https://issues.apache.org/jira/browse/KAFKA-1902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14293840#comment-14293840 ] Jason Rosenberg commented on KAFKA-1902: In the yammer metric reporter (whic

[jira] [Comment Edited] (KAFKA-1902) fix MetricName so that Yammer reporter can work correctly

[ https://issues.apache.org/jira/browse/KAFKA-1902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14293840#comment-14293840 ] Jason Rosenberg edited comment on KAFKA-1902 at 1/27/15 5:3

[jira] [Commented] (KAFKA-1901) Move Kafka version to be generated in code by build (instead of in manifest)

[ https://issues.apache.org/jira/browse/KAFKA-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14293913#comment-14293913 ] Jason Rosenberg commented on KAFKA-1901: At the very least, this could be upd

[jira] [Comment Edited] (KAFKA-1902) fix MetricName so that Yammer reporter can work correctly

[ https://issues.apache.org/jira/browse/KAFKA-1902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14293840#comment-14293840 ] Jason Rosenberg edited comment on KAFKA-1902 at 1/27/15 7:3

[jira] [Commented] (KAFKA-1902) fix MetricName so that Yammer reporter can work correctly

[ https://issues.apache.org/jira/browse/KAFKA-1902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14294053#comment-14294053 ] Jason Rosenberg commented on KAFKA-1902: Since many people use the van

[jira] [Commented] (KAFKA-1902) fix MetricName so that Yammer reporter can work correctly

[ https://issues.apache.org/jira/browse/KAFKA-1902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14294261#comment-14294261 ] Jason Rosenberg commented on KAFKA-1902: [~jjkoshy] I did mean to just rep

[jira] [Commented] (KAFKA-1902) fix MetricName so that Yammer reporter can work correctly

[ https://issues.apache.org/jira/browse/KAFKA-1902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14294287#comment-14294287 ] Jason Rosenberg commented on KAFKA-1902: Actually, a red flag here too, is

[jira] [Commented] (KAFKA-1902) fix MetricName so that Yammer reporter can work correctly

[ https://issues.apache.org/jira/browse/KAFKA-1902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14294332#comment-14294332 ] Jason Rosenberg commented on KAFKA-1902: +1 > fix MetricName so that

[jira] [Commented] (KAFKA-1902) fix MetricName so that Yammer reporter can work correctly

[ https://issues.apache.org/jira/browse/KAFKA-1902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14295359#comment-14295359 ] Jason Rosenberg commented on KAFKA-1902: For the record, at Square, we do

[jira] [Commented] (KAFKA-1902) fix MetricName so that Yammer reporter can work correctly

[ https://issues.apache.org/jira/browse/KAFKA-1902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14295526#comment-14295526 ] Jason Rosenberg commented on KAFKA-1902: LGTM > fix MetricName so that

[jira] [Created] (KAFKA-2032) ConsumerConfig doesn't validate partition.assignment.strategy values

Jason Rosenberg created KAFKA-2032: -- Summary: ConsumerConfig doesn't validate partition.assignment.strategy values Key: KAFKA-2032 URL: https://issues.apache.org/jira/browse/KAFKA-2032 Pr

[jira] [Commented] (KAFKA-2032) ConsumerConfig doesn't validate partition.assignment.strategy values

[ https://issues.apache.org/jira/browse/KAFKA-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14369871#comment-14369871 ] Jason Rosenberg commented on KAFKA-2032: Currently, I am using the s

[jira] [Commented] (KAFKA-2032) ConsumerConfig doesn't validate partition.assignment.strategy values

[ https://issues.apache.org/jira/browse/KAFKA-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14369881#comment-14369881 ] Jason Rosenberg commented on KAFKA-2032: What does "blah" signi

[jira] [Commented] (KAFKA-2032) ConsumerConfig doesn't validate partition.assignment.strategy values

[ https://issues.apache.org/jira/browse/KAFKA-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14369952#comment-14369952 ] Jason Rosenberg commented on KAFKA-2032: LGTM Thanks! > ConsumerConfig

[jira] [Commented] (KAFKA-1901) Move Kafka version to be generated in code by build (instead of in manifest)

[ https://issues.apache.org/jira/browse/KAFKA-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371784#comment-14371784 ] Jason Rosenberg commented on KAFKA-1901: This is really a pretty severe e

[jira] [Commented] (KAFKA-2143) Replicas get ahead of leader and fail

[ https://issues.apache.org/jira/browse/KAFKA-2143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15242412#comment-15242412 ] Jason Rosenberg commented on KAFKA-2143: Hello, I recently experienced this i

[jira] [Commented] (KAFKA-2143) Replicas get ahead of leader and fail

[ https://issues.apache.org/jira/browse/KAFKA-2143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15242428#comment-15242428 ] Jason Rosenberg commented on KAFKA-2143: After looking at KAFKA-2477, I t

[jira] [Created] (KAFKA-2292) failed fetch request logging doesn't indicate source of request

Jason Rosenberg created KAFKA-2292: -- Summary: failed fetch request logging doesn't indicate source of request Key: KAFKA-2292 URL: https://issues.apache.org/jira/browse/KAFKA-2292 Project:

[jira] [Commented] (KAFKA-1901) Move Kafka version to be generated in code by build (instead of in manifest)

[ https://issues.apache.org/jira/browse/KAFKA-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14599317#comment-14599317 ] Jason Rosenberg commented on KAFKA-1901: [~omkreddy] Yes, that sounds

[jira] [Created] (KAFKA-2318) replica manager repeatedly tries to fetch from partitions already moved during controlled shutdown

Jason Rosenberg created KAFKA-2318: -- Summary: replica manager repeatedly tries to fetch from partitions already moved during controlled shutdown Key: KAFKA-2318 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Updated] (KAFKA-2318) replica manager repeatedly tries to fetch from partitions already moved during controlled shutdown

[ https://issues.apache.org/jira/browse/KAFKA-2318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Rosenberg updated KAFKA-2318: --- Description: Using version 0.8.2.1. During a controlled shutdown, it seems like the left-hand

[jira] [Created] (KAFKA-2319) After controlled shutdown: IllegalStateException: Kafka scheduler has not been started

Jason Rosenberg created KAFKA-2319: -- Summary: After controlled shutdown: IllegalStateException: Kafka scheduler has not been started Key: KAFKA-2319 URL: https://issues.apache.org/jira/browse/KAFKA-2319

[jira] [Commented] (KAFKA-2222) Write "Input/output error" did not result in broker shutdown

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933721#comment-14933721 ] Jason Rosenberg commented on KAFKA-: Ok, so was this a read or a w

[jira] [Comment Edited] (KAFKA-2222) Write "Input/output error" did not result in broker shutdown

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933721#comment-14933721 ] Jason Rosenberg edited comment on KAFKA- at 9/28/15 6:2

[jira] [Commented] (KAFKA-2125) Infinite loop after controlled shutdown succeeds

[ https://issues.apache.org/jira/browse/KAFKA-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933724#comment-14933724 ] Jason Rosenberg commented on KAFKA-2125: Unfortunately, I've only seen t

[jira] [Commented] (KAFKA-2189) Snappy compression of message batches less efficient in 0.8.2.1

[ https://issues.apache.org/jira/browse/KAFKA-2189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14948972#comment-14948972 ] Jason Rosenberg commented on KAFKA-2189: quick question, I assume there shoul

[jira] [Commented] (KAFKA-1180) WhiteList topic filter gets a NullPointerException on complex Regex

[ https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13906986#comment-13906986 ] Jason Rosenberg commented on KAFKA-1180: is it too late to reconsider for 0

[jira] [Commented] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13943920#comment-13943920 ] Jason Rosenberg commented on KAFKA-1029: I'm seeing this happening no

[jira] [Comment Edited] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13943920#comment-13943920 ] Jason Rosenberg edited comment on KAFKA-1029 at 3/22/14 5:2

[jira] [Commented] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13944775#comment-13944775 ] Jason Rosenberg commented on KAFKA-1029: Perhaps this should be re-open

[jira] [Comment Edited] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13944775#comment-13944775 ] Jason Rosenberg edited comment on KAFKA-1029 at 3/24/14 6:2

[jira] [Commented] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13945223#comment-13945223 ] Jason Rosenberg commented on KAFKA-1029: I'm starting to suspect my

[jira] [Commented] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13955320#comment-13955320 ] Jason Rosenberg commented on KAFKA-1029: Just to wrap this up, it turns out

[jira] [Commented] (KAFKA-1124) Sending to a new topic (with auto.create.topics.enable) returns ERROR

[ https://issues.apache.org/jira/browse/KAFKA-1124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13965422#comment-13965422 ] Jason Rosenberg commented on KAFKA-1124: Well, not sure if that will do the r

[jira] [Commented] (KAFKA-1124) Sending to a new topic (with auto.create.topics.enable) returns ERROR

[ https://issues.apache.org/jira/browse/KAFKA-1124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13965729#comment-13965729 ] Jason Rosenberg commented on KAFKA-1124: Yes, I think it sounds like it w

[jira] [Commented] (KAFKA-1124) Sending to a new topic (with auto.create.topics.enable) returns ERROR

[ https://issues.apache.org/jira/browse/KAFKA-1124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13965876#comment-13965876 ] Jason Rosenberg commented on KAFKA-1124: when will it be part of the '

[jira] [Commented] (KAFKA-1180) WhiteList topic filter gets a NullPointerException on complex Regex

[ https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13966262#comment-13966262 ] Jason Rosenberg commented on KAFKA-1180: [~joestein] What's the statu

[jira] [Commented] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13984631#comment-13984631 ] Jason Rosenberg commented on KAFKA-1029: I'll add that we still see

[jira] [Commented] (KAFKA-1180) WhiteList topic filter gets a NullPointerException on complex Regex

[ https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14012741#comment-14012741 ] Jason Rosenberg commented on KAFKA-1180: I see this is marked now for 0.8.2.

[jira] [Commented] (KAFKA-1100) metrics shouldn't have generation/timestamp specific names

[ https://issues.apache.org/jira/browse/KAFKA-1100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14015455#comment-14015455 ] Jason Rosenberg commented on KAFKA-1100: what's the timeline for 0.9?

[jira] [Updated] (KAFKA-1180) WhiteList topic filter gets a NullPointerException on complex Regex

[ https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Rosenberg updated KAFKA-1180: --- Attachment: apply-patch-1180-to-0.8.1.patch I've uploaded a patch that refactor

[jira] [Commented] (KAFKA-1180) WhiteList topic filter gets a NullPointerException on complex Regex

[ https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14061599#comment-14061599 ] Jason Rosenberg commented on KAFKA-1180: anything more to be done to get

[jira] [Commented] (KAFKA-1025) Producer.send should provide recoverability info on failiure

[ https://issues.apache.org/jira/browse/KAFKA-1025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133944#comment-14133944 ] Jason Rosenberg commented on KAFKA-1025: Yes, I think if the new prod

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

Jason Rosenberg created KAFKA-1758: -- Summary: corrupt recovery file prevents startup Key: KAFKA-1758 URL: https://issues.apache.org/jira/browse/KAFKA-1758 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-1305) Controller can hang on controlled shutdown with auto leader balance enabled

[ https://issues.apache.org/jira/browse/KAFKA-1305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14213960#comment-14213960 ] Jason Rosenberg commented on KAFKA-1305: Is it safe to say then, if we are

[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=13595339#comment-13595339 ] Jason Rosenberg commented on KAFKA-330: --- I'd also like to see an auto-delet

[jira] [Commented] (KAFKA-253) Refactor the async producer to have only one queue instead of one queue per broker in a Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13616045#comment-13616045 ] Jason Rosenberg commented on KAFKA-253: --- Was this change merged to the 0.7 br

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

Jason Rosenberg created KAFKA-839: - Summary: Race condition between flushInterval and flushSchedulerInterval Key: KAFKA-839 URL: https://issues.apache.org/jira/browse/KAFKA-839 Project: Kafka

[jira] [Commented] (KAFKA-294) "Path length must be > 0" error during startup

[ https://issues.apache.org/jira/browse/KAFKA-294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13652744#comment-13652744 ] Jason Rosenberg commented on KAFKA-294: --- This issue happens also in 0.8.0 It w

[jira] [Created] (KAFKA-899) LeaderNotAvailableException the first time a new message for a partition is processed.

Jason Rosenberg created KAFKA-899: - Summary: LeaderNotAvailableException the first time a new message for a partition is processed. Key: KAFKA-899 URL: https://issues.apache.org/jira/browse/KAFKA-899

[jira] [Created] (KAFKA-900) ClosedByInterruptException when high-level consumer shutdown normally

Jason Rosenberg created KAFKA-900: - Summary: ClosedByInterruptException when high-level consumer shutdown normally Key: KAFKA-900 URL: https://issues.apache.org/jira/browse/KAFKA-900 Project: Kafka

[jira] [Commented] (KAFKA-602) A ConsumerConnector that never receives messages does not shutdown cleanly

[ https://issues.apache.org/jira/browse/KAFKA-602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13676262#comment-13676262 ] Jason Rosenberg commented on KAFKA-602: --- This is still an issue in 0.8 branch

  1   2   >