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

2015-04-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1054: --- Assignee: Ismael Juma Status: Patch Available (was: Open) > Eliminate Compilation Warnings for 0.8 Fina

[jira] [Updated] (KAFKA-2128) kafka.Kafka should return non-zero exit code when caught exception.

2015-04-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2128: --- Resolution: Fixed Assignee: Sasaki Toru Status: Resolved (was: Patch Available) > kafka.Kafka s

[jira] [Updated] (KAFKA-2114) Unable to change min.insync.replicas default

2015-04-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2114: --- Fix Version/s: (was: 0.8.2.1) 0.8.3 > Unable to change min.insync.replicas default > --

[jira] [Updated] (KAFKA-1936) Track offset commit requests separately from produce requests

2015-04-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1936: --- Reviewer: Joel Koshy > Track offset commit requests separately from produce requests > ---

[jira] [Updated] (KAFKA-2102) Remove unnecessary synchronization when managing metadata

2015-04-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2102: --- Reviewer: Jun Rao > Remove unnecessary synchronization when managing metadata > --

[jira] [Updated] (KAFKA-2041) Add ability to specify a KeyClass for KafkaLog4jAppender

2015-04-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2041: --- Reviewer: Jun Rao > Add ability to specify a KeyClass for KafkaLog4jAppender > ---

[jira] [Updated] (KAFKA-2105) NullPointerException in client on MetadataRequest

2015-04-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2105: --- Reviewer: Jun Rao > NullPointerException in client on MetadataRequest > --

[jira] [Updated] (KAFKA-2142) Follow-up patch for KAFKA-2138 Refactor the drain message logic in new producer

2015-04-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2142: --- Reviewer: Jun Rao > Follow-up patch for KAFKA-2138 Refactor the drain message logic in new > producer > -

[jira] [Updated] (KAFKA-1835) Kafka new producer needs options to make blocking behavior explicit

2015-04-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1835: --- Reviewer: Jun Rao > Kafka new producer needs options to make blocking behavior explicit >

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

2015-04-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1660: --- Reviewer: Jay Kreps > Ability to call close() with a timeout on the Java Kafka Producer. > --

[jira] [Updated] (KAFKA-1940) Initial checkout and build failing

2015-04-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1940: --- Reviewer: Jun Rao > Initial checkout and build failing > -- > >

[jira] [Updated] (KAFKA-1940) Initial checkout and build failing

2015-04-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1940: --- Resolution: Fixed Fix Version/s: 0.8.3 Assignee: Martin Lemanski Status: Resolved (

[jira] [Commented] (KAFKA-2147) Unbalanced replication can cause extreme purgatory growth

2015-04-29 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14520747#comment-14520747 ] Jun Rao commented on KAFKA-2147: If the replica fetch request is fetching many partitions,

[jira] [Commented] (KAFKA-1984) java producer may miss an available partition

2015-05-04 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14527865#comment-14527865 ] Jun Rao commented on KAFKA-1984: [~auradkar], did you attach the patch to the wrong jira?

[jira] [Updated] (KAFKA-1387) Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time

2015-05-05 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1387: --- Reviewer: Jun Rao > Kafka getting stuck creating ephemeral node it has already created when two > zookeeper s

[jira] [Updated] (KAFKA-2165) ReplicaFetcherThread: data loss on unknown exception

2015-05-05 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2165: --- Reviewer: Jun Rao > ReplicaFetcherThread: data loss on unknown exception > ---

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

2015-05-05 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1928: --- Reviewer: Jay Kreps > Move kafka.network over to using the network classes in > org.apache.kafka.common.netwo

[jira] [Updated] (KAFKA-2160) DelayedOperationPurgatory should remove the pair in watchersForKey with empty watchers list

2015-05-05 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2160: --- Reviewer: Jun Rao > DelayedOperationPurgatory should remove the pair in watchersForKey with empty > watchers

[jira] [Updated] (KAFKA-2161) Fix a few copyrights

2015-05-05 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2161: --- Reviewer: Joe Stein > Fix a few copyrights > > > Key: KAFKA-2161 >

[jira] [Updated] (KAFKA-2129) Consumer could make multiple concurrent metadata requests

2015-05-05 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2129: --- Reviewer: Guozhang Wang > Consumer could make multiple concurrent metadata requests >

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

2015-05-05 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1690: --- Reviewer: Jun Rao > new java producer needs ssl support as a client >

[jira] [Updated] (KAFKA-2123) Make new consumer offset commit API use callback + future

2015-05-05 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2123: --- Reviewer: Jay Kreps > Make new consumer offset commit API use callback + future >

[jira] [Updated] (KAFKA-2121) prevent potential resource leak in KafkaProducer and KafkaConsumer

2015-05-05 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2121: --- Reviewer: Guozhang Wang > prevent potential resource leak in KafkaProducer and KafkaConsumer > ---

[jira] [Commented] (KAFKA-2170) 10 LogTest cases failed for file.renameTo failed under windows

2015-05-05 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14529337#comment-14529337 ] Jun Rao commented on KAFKA-2170: We do have the logic in OffsetIndex.resize() to unmap bef

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

2015-05-07 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14533747#comment-14533747 ] Jun Rao commented on KAFKA-1690: Joel mentioned the use case that returning just the peer

[jira] [Updated] (KAFKA-1977) Make logEndOffset available in the Zookeeper consumer

2015-05-11 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1977: --- Status: In Progress (was: Patch Available) [~willf], thanks for the patch. This is a useful feature to add. I

[jira] [Commented] (KAFKA-2169) Upgrade to zkclient-0.5

2015-05-11 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14538199#comment-14538199 ] Jun Rao commented on KAFKA-2169: Parth, Thanks for the patch. Since we haven't officially

[jira] [Commented] (KAFKA-2169) Upgrade to zkclient-0.5

2015-05-11 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14538592#comment-14538592 ] Jun Rao commented on KAFKA-2169: 1) By api compatibility, I meant the following. Let's say

[jira] [Commented] (KAFKA-2169) Upgrade to zkclient-0.5

2015-05-11 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14538709#comment-14538709 ] Jun Rao commented on KAFKA-2169: Parth, 1. Have you done the api compatibility test? 3. D

[jira] [Commented] (KAFKA-1997) Refactor Mirror Maker

2015-05-11 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14538762#comment-14538762 ] Jun Rao commented on KAFKA-1997: A late comment: shouldn't we hardcode the key/value seria

[jira] [Commented] (KAFKA-1997) Refactor Mirror Maker

2015-05-11 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14538900#comment-14538900 ] Jun Rao commented on KAFKA-1997: The reasoning is that there is no good default value to s

[jira] [Updated] (KAFKA-2186) Follow-up patch of KAFKA-1650

2015-05-11 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2186: --- Reviewer: Joel Koshy > Follow-up patch of KAFKA-1650 > - > > Key:

[jira] [Updated] (KAFKA-2169) Upgrade to zkclient-0.5

2015-05-11 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2169: --- Reviewer: Jun Rao > Upgrade to zkclient-0.5 > --- > > Key: KAFKA-2169 >

[jira] [Updated] (KAFKA-2185) Update to Gradle 2.4

2015-05-11 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2185: --- Reviewer: Jun Rao Assignee: Ismael Juma > Update to Gradle 2.4 > > >

[jira] [Updated] (KAFKA-2132) Move Log4J appender to clients module

2015-05-11 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2132: --- Reviewer: Jay Kreps (was: Gwen Shapira) > Move Log4J appender to clients module > ---

[jira] [Updated] (KAFKA-2178) Loss of highwatermarks on incorrect cluster shutdown/restart

2015-05-11 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2178: --- Reviewer: Jun Rao > Loss of highwatermarks on incorrect cluster shutdown/restart > ---

[jira] [Updated] (KAFKA-2163) Offsets manager cache should prevent stale-offset-cleanup while an offset load is in progress; otherwise we can lose consumer offsets

2015-05-11 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2163: --- Reviewer: Jun Rao > Offsets manager cache should prevent stale-offset-cleanup while an offset > load is in pr

[jira] [Updated] (KAFKA-2176) DefaultPartitioner doesn't perform consistent hashing based on

2015-05-11 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2176: --- Reviewer: Guozhang Wang > DefaultPartitioner doesn't perform consistent hashing based on > --

[jira] [Updated] (KAFKA-2175) Reduce server log verbosity at info level

2015-05-11 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2175: --- Reviewer: Joel Koshy > Reduce server log verbosity at info level > - >

[jira] [Updated] (KAFKA-2174) Wrong TopicMetadata deserialization

2015-05-11 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2174: --- Reviewer: Jun Rao > Wrong TopicMetadata deserialization > --- > >

[jira] [Updated] (KAFKA-2103) kafka.producer.AsyncProducerTest failure.

2015-05-11 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2103: --- Reviewer: Jun Rao > kafka.producer.AsyncProducerTest failure. > - > >

[jira] [Commented] (KAFKA-2147) Unbalanced replication can cause extreme purgatory growth

2015-05-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540168#comment-14540168 ] Jun Rao commented on KAFKA-2147: A few other questions. 1. What's the produce request rate

[jira] [Commented] (KAFKA-2147) Unbalanced replication can cause extreme purgatory growth

2015-05-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540596#comment-14540596 ] Jun Rao commented on KAFKA-2147: 1. How many producer requests/sec are there on each broke

[jira] [Commented] (KAFKA-2147) Unbalanced replication can cause extreme purgatory growth

2015-05-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540917#comment-14540917 ] Jun Rao commented on KAFKA-2147: Created reviewboard https://reviews.apache.org/r/34125/di

[jira] [Updated] (KAFKA-2147) Unbalanced replication can cause extreme purgatory growth

2015-05-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2147: --- Assignee: Jun Rao (was: Joel Koshy) Status: Patch Available (was: Open) > Unbalanced replication can c

[jira] [Updated] (KAFKA-2147) Unbalanced replication can cause extreme purgatory growth

2015-05-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2147: --- Attachment: KAFKA-2147.patch > Unbalanced replication can cause extreme purgatory growth > ---

[jira] [Commented] (KAFKA-2147) Unbalanced replication can cause extreme purgatory growth

2015-05-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540921#comment-14540921 ] Jun Rao commented on KAFKA-2147: Looking a bit more at our code, it seems that this could

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

2015-05-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2189: --- Priority: Blocker (was: Major) Fix Version/s: 0.8.3 Assignee: (was: Jay Kreps)

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

2015-05-13 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1690: --- Status: In Progress (was: Patch Available) [~rsivaram], could you help review the patch too and especially se

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

2015-05-13 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14542145#comment-14542145 ] Jun Rao commented on KAFKA-1690: Also, could anyone comment on whether we need to support

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

2015-05-13 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14542422#comment-14542422 ] Jun Rao commented on KAFKA-1682: 3. The SSL work is now being done in KAFKA-1690, on top o

[jira] [Commented] (KAFKA-2169) Upgrade to zkclient-0.5

2015-05-13 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14542708#comment-14542708 ] Jun Rao commented on KAFKA-2169: Thought a bit more about this. When handling handleSessio

[jira] [Commented] (KAFKA-2147) Unbalanced replication can cause extreme purgatory growth

2015-05-14 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14543979#comment-14543979 ] Jun Rao commented on KAFKA-2147: Updated reviewboard https://reviews.apache.org/r/34125/di

[jira] [Updated] (KAFKA-2147) Unbalanced replication can cause extreme purgatory growth

2015-05-14 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2147: --- Attachment: KAFKA-2147_2015-05-14_09:41:56.patch > Unbalanced replication can cause extreme purgatory growth >

[jira] [Commented] (KAFKA-2147) Unbalanced replication can cause extreme purgatory growth

2015-05-14 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14543986#comment-14543986 ] Jun Rao commented on KAFKA-2147: I added a bit more instrumentation. Could you apply the p

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

2015-05-14 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14544028#comment-14544028 ] Jun Rao commented on KAFKA-1690: [~sriharsha], what about SASL? So we also rely on restart

[jira] [Commented] (KAFKA-2147) Unbalanced replication can cause extreme purgatory growth

2015-05-15 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546355#comment-14546355 ] Jun Rao commented on KAFKA-2147: Updated reviewboard https://reviews.apache.org/r/34125/di

[jira] [Updated] (KAFKA-2147) Unbalanced replication can cause extreme purgatory growth

2015-05-15 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2147: --- Attachment: KAFKA-2147_2015-05-15_16:14:44.patch > Unbalanced replication can cause extreme purgatory growth >

[jira] [Commented] (KAFKA-2147) Unbalanced replication can cause extreme purgatory growth

2015-05-15 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546356#comment-14546356 ] Jun Rao commented on KAFKA-2147: Interesting, looking at the code again, it seems that the

[jira] [Updated] (KAFKA-2169) Upgrade to zkclient-0.5

2015-05-18 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2169: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

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

2015-05-18 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14549117#comment-14549117 ] Jun Rao commented on KAFKA-1778: [~anigam], could you explain a bit the use case of pinnin

[jira] [Resolved] (KAFKA-1082) zkclient dies after UnknownHostException in zk reconnect

2015-05-18 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1082. Resolution: Duplicate Fix Version/s: 0.8.3 This is already resolved in KAFKA-2169. > zkclient dies a

[jira] [Updated] (KAFKA-2198) kafka-topics.sh exits with 0 status on failures

2015-05-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2198: --- Reviewer: Neha Narkhede > kafka-topics.sh exits with 0 status on failures > --

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

2015-05-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1928: --- Reporter: Jun Rao (was: Jay Kreps) > Move kafka.network over to using the network classes in > org.apache.ka

[jira] [Updated] (KAFKA-2199) Make signing artifacts optional, setting maven repository possible from command line

2015-05-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2199: --- Reviewer: Jun Rao > Make signing artifacts optional, setting maven repository possible from > command line >

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

2015-05-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1928: --- Reviewer: Jun Rao (was: Jay Kreps) > Move kafka.network over to using the network classes in > org.apache.ka

[jira] [Updated] (KAFKA-1906) Default the Kafka log directory to a relative path within the Kafka installation directory

2015-05-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1906: --- Reviewer: Jay Kreps > Default the Kafka log directory to a relative path within the Kafka > installation dire

[jira] [Updated] (KAFKA-2196) remove roundrobin identical topic constraint in consumer coordinator

2015-05-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2196: --- Reviewer: Joel Koshy > remove roundrobin identical topic constraint in consumer coordinator >

[jira] [Updated] (KAFKA-2190) Incorporate close(timeout) to Mirror Maker

2015-05-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2190: --- Reviewer: Guozhang Wang > Incorporate close(timeout) to Mirror Maker > ---

[jira] [Updated] (KAFKA-2191) Measured rate should not be infinite

2015-05-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2191: --- Reviewer: Guozhang Wang > Measured rate should not be infinite > > >

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

2015-05-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2189: --- Reviewer: Jun Rao > Snappy compression of message batches less efficient in 0.8.2.1 >

[jira] [Updated] (KAFKA-976) Order-Preserving Mirror Maker Testcase

2015-05-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-976: -- Status: Open (was: Patch Available) The current patch is too old. > Order-Preserving Mirror Maker Testcase > --

[jira] [Updated] (KAFKA-2188) JBOD Support

2015-05-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2188: --- Reviewer: Jay Kreps > JBOD Support > > > Key: KAFKA-2188 > URL: h

[jira] [Updated] (KAFKA-1907) ZkClient can block controlled shutdown indefinitely

2015-05-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1907: --- Reviewer: Jun Rao > ZkClient can block controlled shutdown indefinitely >

[jira] [Updated] (KAFKA-2195) Add versionId to AbstractRequest.getErrorResponse and AbstractRequest.getRequest

2015-05-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2195: --- Reviewer: Jun Rao > Add versionId to AbstractRequest.getErrorResponse and > AbstractRequest.getRequest >

[jira] [Commented] (KAFKA-2147) Unbalanced replication can cause extreme purgatory growth

2015-05-20 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14552918#comment-14552918 ] Jun Rao commented on KAFKA-2147: [~csallsop...@gmail.com], we probably won't patch 0.8.1.1

[jira] [Commented] (KAFKA-2147) Unbalanced replication can cause extreme purgatory growth

2015-05-20 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14553528#comment-14553528 ] Jun Rao commented on KAFKA-2147: Yes, one workaround is probably to set a relatively low m

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

2015-05-21 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14554515#comment-14554515 ] Jun Rao commented on KAFKA-1778: [~anigam], for the two use cases that you mentioned, it s

[jira] [Updated] (KAFKA-2195) Add versionId to AbstractRequest.getErrorResponse and AbstractRequest.getRequest

2015-05-22 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2195: --- Status: In Progress (was: Patch Available) > Add versionId to AbstractRequest.getErrorResponse and > Abstrac

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

2015-05-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14562053#comment-14562053 ] Jun Rao commented on KAFKA-1778: [~anigam], yes, you will need to configure multiple (e.g.

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

2015-05-28 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2189: --- Resolution: Fixed Status: Resolved (was: Patch Available) Thanks for the patch. +1 and committed to t

[jira] [Commented] (KAFKA-2225) Allow fetching from ISR

2015-05-28 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14563732#comment-14563732 ] Jun Rao commented on KAFKA-2225: [~iconara], just to clarify, so you are using the private

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

2015-05-28 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-948. --- Resolution: Cannot Reproduce Closing this since it's no longer active. > ISR list in LeaderAndISR path not upd

[jira] [Commented] (KAFKA-1367) Broker topic metadata not kept in sync with ZooKeeper

2015-05-28 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14563935#comment-14563935 ] Jun Rao commented on KAFKA-1367: There is actually a reasonable use case of ISR in KAFKA-2

[jira] [Updated] (KAFKA-2185) Update to Gradle 2.4

2015-05-28 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2185: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Commented] (KAFKA-1367) Broker topic metadata not kept in sync with ZooKeeper

2015-05-28 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564002#comment-14564002 ] Jun Rao commented on KAFKA-1367: It's probably better to always let the controller propaga

[jira] [Commented] (KAFKA-1367) Broker topic metadata not kept in sync with ZooKeeper

2015-05-28 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564029#comment-14564029 ] Jun Rao commented on KAFKA-1367: Well, in that approach, you still have the problem on the

[jira] [Commented] (KAFKA-1367) Broker topic metadata not kept in sync with ZooKeeper

2015-05-29 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14565078#comment-14565078 ] Jun Rao commented on KAFKA-1367: Yes. > Broker topic metadata not kept in sync with ZooKe

[jira] [Created] (KAFKA-2232) make MockProducer generic

2015-05-31 Thread Jun Rao (JIRA)
Jun Rao created KAFKA-2232: -- Summary: make MockProducer generic Key: KAFKA-2232 URL: https://issues.apache.org/jira/browse/KAFKA-2232 Project: Kafka Issue Type: Bug Components: clients

[jira] [Updated] (KAFKA-2232) make MockProducer generic

2015-05-31 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2232: --- Fix Version/s: 0.8.3 > make MockProducer generic > - > > Key: KAFKA-22

[jira] [Updated] (KAFKA-2226) NullPointerException in TestPurgatoryPerformance

2015-06-01 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2226: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14568257#comment-14568257 ] Jun Rao commented on KAFKA-1282: [~nmarasoi], thanks for the patch. We are changing Socket

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1282: --- Status: In Progress (was: Patch Available) > Disconnect idle socket connection in Selector >

[jira] [Commented] (KAFKA-1367) Broker topic metadata not kept in sync with ZooKeeper

2015-06-02 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14569484#comment-14569484 ] Jun Rao commented on KAFKA-1367: [~joel koshy], yes, that's a good point. If we want to sw

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

2015-06-03 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1928: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) +1 on the la

[jira] [Commented] (KAFKA-1120) Controller could miss a broker state change

2016-11-22 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688448#comment-15688448 ] Jun Rao commented on KAFKA-1120: [~wushujames], it seems that the controller did detect th

[jira] [Comment Edited] (KAFKA-1120) Controller could miss a broker state change

2016-11-22 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15325496#comment-15325496 ] Jun Rao edited comment on KAFKA-1120 at 11/23/16 1:03 AM: -- A bett

[jira] [Commented] (KAFKA-4021) system tests need to enable trace level logging for controller and state-change log

2016-11-22 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688546#comment-15688546 ] Jun Rao commented on KAFKA-4021: [~ewencp], those trace level logging only happens when th

[jira] [Resolved] (KAFKA-1429) Yet another deadlock in controller shutdown

2016-11-23 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1429. Resolution: Duplicate Assignee: (was: Neha Narkhede) This is already fixed by KAFKA-4360. > Yet a

[jira] [Commented] (KAFKA-4443) Controller should send UpdateMetadataRequest prior to LeaderAndIsrRequest during failover

2016-11-29 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15705851#comment-15705851 ] Jun Rao commented on KAFKA-4443: [~lindong], thanks for filing the jira. A couple of quest

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