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

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14578020#comment-14578020 ] Jun Rao commented on KAFKA-1690: 2. I am not sure what the best approach is. Currently, Se

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

[ https://issues.apache.org/jira/browse/KAFKA-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14578053#comment-14578053 ] Jun Rao commented on KAFKA-1367: Yes, perhaps some kind of more general locality could be

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

[ https://issues.apache.org/jira/browse/KAFKA-2232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14579324#comment-14579324 ] Jun Rao commented on KAFKA-2232: [~apakulov], we haven't officially moved to submitting pa

[jira] [Created] (KAFKA-2262) LogSegmentSize validation should be consistent

Jun Rao created KAFKA-2262: -- Summary: LogSegmentSize validation should be consistent Key: KAFKA-2262 URL: https://issues.apache.org/jira/browse/KAFKA-2262 Project: Kafka Issue Type: Bug Co

[jira] [Created] (KAFKA-2264) SESSION_TIMEOUT_MS_CONFIG in ConsumerConfig should be int

Jun Rao created KAFKA-2264: -- Summary: SESSION_TIMEOUT_MS_CONFIG in ConsumerConfig should be int Key: KAFKA-2264 URL: https://issues.apache.org/jira/browse/KAFKA-2264 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-2265) creating a topic with large number of partitions takes a long time

Jun Rao created KAFKA-2265: -- Summary: creating a topic with large number of partitions takes a long time Key: KAFKA-2265 URL: https://issues.apache.org/jira/browse/KAFKA-2265 Project: Kafka Issue T

[jira] [Updated] (KAFKA-2005) Generate html report for system tests

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

[jira] [Updated] (KAFKA-2249) KafkaConfig does not preserve original Properties

[ https://issues.apache.org/jira/browse/KAFKA-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2249: --- Status: In Progress (was: Patch Available) > KafkaConfig does not preserve original Properties >

[jira] [Commented] (KAFKA-2238) KafkaMetricsConfig cannot be configured in broker (KafkaConfig)

[ https://issues.apache.org/jira/browse/KAFKA-2238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14582722#comment-14582722 ] Jun Rao commented on KAFKA-2238: [~auradkar], took a look at your patch. Currently, the Ka

[jira] [Resolved] (KAFKA-2263) Update "Is it possible to delete a topic" wiki FAQ answer

[ https://issues.apache.org/jira/browse/KAFKA-2263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2263. Resolution: Fixed Thanks for reporting this. Updated the wiki. > Update "Is it possible to delete a topic"

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

[ https://issues.apache.org/jira/browse/KAFKA-2132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2132: --- Status: In Progress (was: Patch Available) > Move Log4J appender to a separate module > -

[jira] [Updated] (KAFKA-2266) Client Selector can drop idle connections without notifying NetworkClient

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

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

[ https://issues.apache.org/jira/browse/KAFKA-2232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2232. Resolution: Fixed Assignee: Alexander Pakulov Thanks for the latest patch. +1 and committed to trunk.

[jira] [Updated] (KAFKA-2168) New consumer poll() can block other calls like position(), commit(), and close() indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2168: --- Reviewer: Guozhang Wang > New consumer poll() can block other calls like position(), commit(), and > close()

[jira] [Commented] (KAFKA-2241) AbstractFetcherThread.shutdown() should not block on ReadableByteChannel.read(buffer)

[ https://issues.apache.org/jira/browse/KAFKA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14584140#comment-14584140 ] Jun Rao commented on KAFKA-2241: [~lindong], thanks for reporting this. Does this happen o

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

[ https://issues.apache.org/jira/browse/KAFKA-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2147: --- Resolution: Implemented Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) [~eapa

[jira] [Updated] (KAFKA-2254) The shell script should be optimized , even kafka-run-class.sh has a syntax error.

[ https://issues.apache.org/jira/browse/KAFKA-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2254: --- Reviewer: Joe Stein > The shell script should be optimized , even kafka-run-class.sh has a syntax > error. >

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

[ 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) [~abiletskyi], did you see my last comment on the RB? > Add versi

[jira] [Commented] (KAFKA-2229) Phase 1: Requests and KafkaApis

[ https://issues.apache.org/jira/browse/KAFKA-2229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14584211#comment-14584211 ] Jun Rao commented on KAFKA-2229: We probably should commit KAFKA-2195 first. > Phase 1: R

[jira] [Commented] (KAFKA-2217) Refactor Client Selectable Interface for Better Concurrency Options

[ https://issues.apache.org/jira/browse/KAFKA-2217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14584216#comment-14584216 ] Jun Rao commented on KAFKA-2217: [~hachikuji], do we still need to fix this now that we wa

[jira] [Updated] (KAFKA-2107) Script to generate waiting-for-review report

[ https://issues.apache.org/jira/browse/KAFKA-2107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2107: --- Reviewer: Neha Narkhede > Script to generate waiting-for-review report > -

[jira] [Updated] (KAFKA-2214) kafka-reassign-partitions.sh --verify should return non-zero exit codes when reassignment is not completed yet

[ https://issues.apache.org/jira/browse/KAFKA-2214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2214: --- Reviewer: Neha Narkhede > kafka-reassign-partitions.sh --verify should return non-zero exit codes when > reas

[jira] [Updated] (KAFKA-1755) Improve error handling in log cleaner

[ https://issues.apache.org/jira/browse/KAFKA-1755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1755: --- Reviewer: Jay Kreps > Improve error handling in log cleaner > - > >

[jira] [Updated] (KAFKA-2235) LogCleaner offset map overflow

[ https://issues.apache.org/jira/browse/KAFKA-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2235: --- Reviewer: Jay Kreps > LogCleaner offset map overflow > -- > > Key:

[jira] [Updated] (KAFKA-2164) ReplicaFetcherThread: suspicious log message on reset offset

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

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

[ https://issues.apache.org/jira/browse/KAFKA-2165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2165: --- Status: In Progress (was: Patch Available) Thanks for reporting this. A couple of comments. 1. Currently, if

[jira] [Updated] (KAFKA-2241) AbstractFetcherThread.shutdown() should not block on ReadableByteChannel.read(buffer)

[ https://issues.apache.org/jira/browse/KAFKA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2241: --- Reviewer: Jun Rao > AbstractFetcherThread.shutdown() should not block on > ReadableByteChannel.read(buffer) >

[jira] [Updated] (KAFKA-2101) Metric metadata-age is reset on a failed update

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

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

[ https://issues.apache.org/jira/browse/KAFKA-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2102: --- Status: In Progress (was: Patch Available) > Remove unnecessary synchronization when managing metadata >

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

[ https://issues.apache.org/jira/browse/KAFKA-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14587281#comment-14587281 ] Jun Rao commented on KAFKA-2102: [~timbrooks], thanks for the patch. Took a quick look at

[jira] [Created] (KAFKA-2270) incorrect package name in unit tests

Jun Rao created KAFKA-2270: -- Summary: incorrect package name in unit tests Key: KAFKA-2270 URL: https://issues.apache.org/jira/browse/KAFKA-2270 Project: Kafka Issue Type: Bug Components:

[jira] [Created] (KAFKA-2271) transient unit test failure in KafkaConfigConfigDefTest.testFromPropsToProps

Jun Rao created KAFKA-2271: -- Summary: transient unit test failure in KafkaConfigConfigDefTest.testFromPropsToProps Key: KAFKA-2271 URL: https://issues.apache.org/jira/browse/KAFKA-2271 Project: Kafka

[jira] [Commented] (KAFKA-2270) incorrect package name in unit tests

[ https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588109#comment-14588109 ] Jun Rao commented on KAFKA-2270: Thanks for the patch. Got a bunch of compilation errors l

[jira] [Updated] (KAFKA-2270) incorrect package name in unit tests

[ https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2270: --- Assignee: Proneet Verma > incorrect package name in unit tests > > >

[jira] [Commented] (KAFKA-1646) Improve consumer read performance for Windows

[ https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588170#comment-14588170 ] Jun Rao commented on KAFKA-1646: [~waldenchen], thanks for the latest patch. A couple of o

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

[ https://issues.apache.org/jira/browse/KAFKA-2195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2195. Resolution: Fixed Thanks for the latest patch. +1 and committed to trunk. > Add versionId to AbstractReques

[jira] [Resolved] (KAFKA-2270) incorrect package name in unit tests

[ https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2270. Resolution: Fixed Thanks for the patch. +1. Committed to trunk after removing {} on single class imports.

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

[ https://issues.apache.org/jira/browse/KAFKA-2195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao reassigned KAFKA-2195: -- Assignee: Andrii Biletskyi (was: Jun Rao) > Add versionId to AbstractRequest.getErrorResponse and > A

[jira] [Updated] (KAFKA-2272) listeners endpoint parsing fails if the hostname has capital letter

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

[jira] [Updated] (KAFKA-2264) SESSION_TIMEOUT_MS_CONFIG in ConsumerConfig should be int

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

[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 ] Jun Rao updated KAFKA-2252: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Updated] (KAFKA-2262) LogSegmentSize validation should be consistent

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

[jira] [Created] (KAFKA-2279) add a main method in LogConfig to generate topic level configs in html

Jun Rao created KAFKA-2279: -- Summary: add a main method in LogConfig to generate topic level configs in html Key: KAFKA-2279 URL: https://issues.apache.org/jira/browse/KAFKA-2279 Project: Kafka Iss

[jira] [Updated] (KAFKA-2235) LogCleaner offset map overflow

[ https://issues.apache.org/jira/browse/KAFKA-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2235: --- Reviewer: Jun Rao (was: Jay Kreps) Status: In Progress (was: Patch Available) Thanks for the patch. Ni

[jira] [Commented] (KAFKA-2078) Getting Selector [WARN] Error in I/O with host java.io.EOFException

[ https://issues.apache.org/jira/browse/KAFKA-2078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14589079#comment-14589079 ] Jun Rao commented on KAFKA-2078: The producer will retry on connection failure (if retry i

[jira] [Updated] (KAFKA-2249) KafkaConfig does not preserve original Properties

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

[jira] [Resolved] (KAFKA-2279) add a main method in LogConfig to generate topic level configs in html

[ https://issues.apache.org/jira/browse/KAFKA-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2279. Resolution: Implemented Fix Version/s: 0.8.3 This is already fixed in KAFKA-2249. > add a main metho

[jira] [Updated] (KAFKA-2210) KafkaAuthorizer: Add all public entities, config changes and changes to KafkaAPI and kafkaServer to allow pluggable authorizer implementation.

[ https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2210: --- Status: In Progress (was: Patch Available) [~parth.brahmbhatt], KAFKA-2249 is now committed. Could you rebase

[jira] [Reopened] (KAFKA-2249) KafkaConfig does not preserve original Properties

[ https://issues.apache.org/jira/browse/KAFKA-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao reopened KAFKA-2249: [~gwenshap], with this patch, an issue that I realized is that we print out the configs in LogConfig for every

[jira] [Updated] (KAFKA-2265) creating a topic with large number of partitions takes a long time

[ https://issues.apache.org/jira/browse/KAFKA-2265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2265: --- Resolution: Fixed Status: Resolved (was: Patch Available) Thanks for the patch. This is great finding

[jira] [Updated] (KAFKA-2234) Partition reassignment of a nonexistent topic prevents future reassignments

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

[jira] [Commented] (KAFKA-2234) Partition reassignment of a nonexistent topic prevents future reassignments

[ https://issues.apache.org/jira/browse/KAFKA-2234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14592757#comment-14592757 ] Jun Rao commented on KAFKA-2234: The patch introduced a unit test failure. Checked in a tr

[jira] [Updated] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2012: --- Status: In Progress (was: Patch Available) > Broker should automatically handle corrupt index files > ---

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

[ https://issues.apache.org/jira/browse/KAFKA-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1758: --- Resolution: Fixed Fix Version/s: (was: 0.9.0) 0.8.3 Status: Resolved

[jira] [Commented] (KAFKA-2249) KafkaConfig does not preserve original Properties

[ https://issues.apache.org/jira/browse/KAFKA-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593469#comment-14593469 ] Jun Rao commented on KAFKA-2249: Also, I am not sure if LogConfigTest.testFromPropsToProps

[jira] [Resolved] (KAFKA-1646) Improve consumer read performance for Windows

[ https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1646. Resolution: Fixed Fix Version/s: 0.8.3 Assignee: Honghai Chen (was: xueqiang wang) Thanks f

[jira] [Commented] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593496#comment-14593496 ] Jun Rao commented on KAFKA-2012: The latest patch looks good to me. Could you rebase since

[jira] [Commented] (KAFKA-2249) KafkaConfig does not preserve original Properties

[ https://issues.apache.org/jira/browse/KAFKA-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593585#comment-14593585 ] Jun Rao commented on KAFKA-2249: Yes, fixing it in another jira is fine. Thanks. > KafkaC

[jira] [Updated] (KAFKA-2012) Broker should automatically handle corrupt index files

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

[jira] [Commented] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593953#comment-14593953 ] Jun Rao commented on KAFKA-2012: I am not sure if it's better to add another config. Perha

[jira] [Created] (KAFKA-2290) OffsetIndex should open RandomAccessFile consistently

Jun Rao created KAFKA-2290: -- Summary: OffsetIndex should open RandomAccessFile consistently Key: KAFKA-2290 URL: https://issues.apache.org/jira/browse/KAFKA-2290 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-2290) OffsetIndex should open RandomAccessFile consistently

[ https://issues.apache.org/jira/browse/KAFKA-2290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2290. Resolution: Fixed Fix Version/s: 0.8.3 Thanks for the patch. +1 and committed to trunk. > OffsetInde

[jira] [Resolved] (KAFKA-2235) LogCleaner offset map overflow

[ https://issues.apache.org/jira/browse/KAFKA-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2235. Resolution: Fixed Fix Version/s: 0.8.3 Assignee: Ivan Simoneko (was: Jay Kreps) Thanks for

[jira] [Commented] (KAFKA-1215) Rack-Aware replica assignment option

[ https://issues.apache.org/jira/browse/KAFKA-1215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14604154#comment-14604154 ] Jun Rao commented on KAFKA-1215: [~allenxwang], thanks for the update. How do you model th

[jira] [Commented] (KAFKA-2210) KafkaAuthorizer: Add all public entities, config changes and changes to KafkaAPI and kafkaServer to allow pluggable authorizer implementation.

[ https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14606548#comment-14606548 ] Jun Rao commented on KAFKA-2210: [~parthbhave], are you still working on this jira? Thanks

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

[ https://issues.apache.org/jira/browse/KAFKA-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1688: --- Status: Open (was: Patch Available) This is now going to be handled in KAFKA-2210, KAFKA-2211, and KAFKA-2212

[jira] [Updated] (KAFKA-972) MetadataRequest returns stale list of brokers

[ https://issues.apache.org/jira/browse/KAFKA-972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-972: -- Status: In Progress (was: Patch Available) > MetadataRequest returns stale list of brokers > ---

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

[ https://issues.apache.org/jira/browse/KAFKA-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1367: --- Status: In Progress (was: Patch Available) > Broker topic metadata not kept in sync with ZooKeeper >

[jira] [Updated] (KAFKA-972) MetadataRequest returns stale list of brokers

[ https://issues.apache.org/jira/browse/KAFKA-972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-972: -- Status: In Progress (was: Patch Available) > MetadataRequest returns stale list of brokers > ---

[jira] [Updated] (KAFKA-2248) Use Apache Rat to enforce copyright headers

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

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

[ https://issues.apache.org/jira/browse/KAFKA-2132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2132: --- Resolution: Fixed Reviewer: Jun Rao (was: Jay Kreps) Fix Version/s: 0.8.3 Status: R

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

[ https://issues.apache.org/jira/browse/KAFKA-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1367: --- Status: In Progress (was: Patch Available) > Broker topic metadata not kept in sync with ZooKeeper >

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

[ https://issues.apache.org/jira/browse/KAFKA-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1367: --- Resolution: Fixed Status: Resolved (was: Patch Available) Thanks for the latest patch. +1. Committed

[jira] [Commented] (KAFKA-2205) Generalize TopicConfigManager to handle multiple entity configs

[ https://issues.apache.org/jira/browse/KAFKA-2205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625550#comment-14625550 ] Jun Rao commented on KAFKA-2205: Reviewed and just have a couple of more minor comments.

[jira] [Resolved] (KAFKA-2182) zkClient dies if there is any exception while reconnecting

[ https://issues.apache.org/jira/browse/KAFKA-2182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2182. Resolution: Implemented Fix Version/s: 0.8.3 As [~parth.brahmbhatt] pointed out, this is already fixe

[jira] [Updated] (KAFKA-972) MetadataRequest returns stale list of brokers

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

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

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

[jira] [Updated] (KAFKA-2210) KafkaAuthorizer: Add all public entities, config changes and changes to KafkaAPI and kafkaServer to allow pluggable authorizer implementation.

[ https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2210: --- Reviewer: Jun Rao > KafkaAuthorizer: Add all public entities, config changes and changes to > KafkaAPI and ka

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

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

[jira] [Commented] (KAFKA-2288) Follow-up to KAFKA-2249 - reduce logging and testing

[ https://issues.apache.org/jira/browse/KAFKA-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14628877#comment-14628877 ] Jun Rao commented on KAFKA-2288: [~gwenshap], now that you are a committer, do you want to

[jira] [Resolved] (KAFKA-2249) KafkaConfig does not preserve original Properties

[ https://issues.apache.org/jira/browse/KAFKA-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2249. Resolution: Fixed Resolving the jira since the remaining issues are being followed up in KAFKA-2288. > Kaf

[jira] [Updated] (KAFKA-2210) KafkaAuthorizer: Add all public entities, config changes and changes to KafkaAPI and kafkaServer to allow pluggable authorizer implementation.

[ https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2210: --- Status: In Progress (was: Patch Available) > KafkaAuthorizer: Add all public entities, config changes and cha

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

[ https://issues.apache.org/jira/browse/KAFKA-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2188: --- Status: In Progress (was: Patch Available) [~tnachen], thanks for the patch. It seems that KIP-18 is still u

[jira] [Updated] (KAFKA-2323) Simplify ScalaTest dependency versions

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

[jira] [Updated] (KAFKA-2241) AbstractFetcherThread.shutdown() should not block on ReadableByteChannel.read(buffer)

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

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

[ https://issues.apache.org/jira/browse/KAFKA-2041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2041: --- Status: In Progress (was: Patch Available) [~benoyantony], thanks for the patch. We will use org.apache.kafk

[jira] [Created] (KAFKA-2342) transient unit test failure in testConsumptionWithBrokerFailures

Jun Rao created KAFKA-2342: -- Summary: transient unit test failure in testConsumptionWithBrokerFailures Key: KAFKA-2342 URL: https://issues.apache.org/jira/browse/KAFKA-2342 Project: Kafka Issue Typ

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

[ https://issues.apache.org/jira/browse/KAFKA-2174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2174: --- Status: In Progress (was: Patch Available) Thanks for the patch. +1 and committed to trunk. The patch handle

[jira] [Updated] (KAFKA-2271) transient unit test failure in KafkaConfigConfigDefTest.testFromPropsToProps

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

[jira] [Commented] (KAFKA-2342) transient unit test failure in testConsumptionWithBrokerFailures

[ https://issues.apache.org/jira/browse/KAFKA-2342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14630613#comment-14630613 ] Jun Rao commented on KAFKA-2342: Also, this test takes more than 40 secs, which is a bit t

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-2178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2178: --- Status: In Progress (was: Patch Available) [~aozeritsky], thanks for the patch. The current logic in ReplicaM

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

[ https://issues.apache.org/jira/browse/KAFKA-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14635305#comment-14635305 ] Jun Rao commented on KAFKA-2188: Another thing that's worth mentioning is that currently w

[jira] [Updated] (KAFKA-388) Add a highly available consumer co-ordinator to a Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-388: -- Resolution: Duplicate Status: Resolved (was: Patch Available) This is now handled in KAFKA-1326. > Add

[jira] [Commented] (KAFKA-251) The ConsumerStats MBean's PartOwnerStats attribute is a string

[ https://issues.apache.org/jira/browse/KAFKA-251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14640624#comment-14640624 ] Jun Rao commented on KAFKA-251: --- Since we are developing the new java consumer, not sure if i

[jira] [Updated] (KAFKA-2351) Brokers are having a problem shutting down correctly

[ https://issues.apache.org/jira/browse/KAFKA-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2351: --- Status: In Progress (was: Patch Available) > Brokers are having a problem shutting down correctly > -

[jira] [Commented] (KAFKA-2337) Verify that metric names will not collide when creating new topics

[ https://issues.apache.org/jira/browse/KAFKA-2337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14649421#comment-14649421 ] Jun Rao commented on KAFKA-2337: Sorry for the late comment. It seems that in KafkaApis.ge

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

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14652110#comment-14652110 ] Jun Rao commented on KAFKA-1690: [~sriharsha], I made another pass of the patch and left s

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

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14652805#comment-14652805 ] Jun Rao commented on KAFKA-1690: [~erajasekar], for 3, the SSL patch only works for the ne

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

[ https://issues.apache.org/jira/browse/KAFKA-1684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653714#comment-14653714 ] Jun Rao commented on KAFKA-1684: [~NavjotBhardwaj], the ssl work is being covered in KAFKA

<    5   6   7   8   9   10   11   12   13   14   >