[
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
[
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
[
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
> --
[
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
> ---
[
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
> --
[
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
> ---
[
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
> --
[
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
> -
[
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
>
[
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.
> --
[
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
> --
>
>
[
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 (
[
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,
[
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?
[
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
[
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
> ---
[
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
[
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
[
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
>
[
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
>
[
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
>
[
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
>
[
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
> ---
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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:
[
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
>
[
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
>
>
>
[
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
> ---
[
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
> ---
[
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
[
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
> --
[
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
> -
>
[
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
> ---
>
>
[
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.
> -
>
>
[
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
[
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
[
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
[
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
[
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
> ---
[
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
[
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)
[
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
[
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
[
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
[
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
[
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
[
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
>
[
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
[
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
[
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
[
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
>
[
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
[
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
[
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
[
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
[
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
> --
[
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
[
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
>
[
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
[
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
[
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
>
[
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
> ---
[
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
>
>
>
[
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
>
[
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
> --
[
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
[
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
>
[
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
>
[
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
[
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
[
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
[
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
[
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.
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
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
[
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
[
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
[
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
[
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
>
[
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
[
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
[
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
[
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
[
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
[
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
[
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
301 - 400 of 3542 matches
Mail list logo