[jira] [Updated] (KAFKA-3185) Allow users to cleanup internal data

[ https://issues.apache.org/jira/browse/KAFKA-3185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-3185: - Labels: developer-experience (was: ) > Allow users to cleanup internal data >

[jira] [Updated] (KAFKA-3262) Make KafkaStreams debugging friendly

[ https://issues.apache.org/jira/browse/KAFKA-3262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-3262: - Labels: developer-experience (was: ) > Make KafkaStreams debugging friendly >

[jira] [Updated] (KAFKA-3337) Extract selector as a separate groupBy operator for KTable aggregations

[ https://issues.apache.org/jira/browse/KAFKA-3337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-3337: - Labels: api-change newbie++ (was: newbie++) > Extract selector as a separate groupBy operator

[jira] [Commented] (KAFKA-1464) Add a throttling option to the Kafka replication tool

[ https://issues.apache.org/jira/browse/KAFKA-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15146250#comment-15146250 ] Neha Narkhede commented on KAFKA-1464: -- The most useful resource to throttle for is network bandwidth

[jira] [Comment Edited] (KAFKA-1464) Add a throttling option to the Kafka replication tool

[ https://issues.apache.org/jira/browse/KAFKA-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15146250#comment-15146250 ] Neha Narkhede edited comment on KAFKA-1464 at 2/13/16 11:36 PM: The most

[jira] [Created] (KAFKA-3209) Support single message transforms in Kafka Connect

Neha Narkhede created KAFKA-3209: Summary: Support single message transforms in Kafka Connect Key: KAFKA-3209 URL: https://issues.apache.org/jira/browse/KAFKA-3209 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-2807) Movement of throughput throttler to common broke upgrade tests

[ https://issues.apache.org/jira/browse/KAFKA-2807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000969#comment-15000969 ] Neha Narkhede commented on KAFKA-2807: -- We don't want our tests to fail, so marking this as a

[jira] [Updated] (KAFKA-2807) Movement of throughput throttler to common broke upgrade tests

[ https://issues.apache.org/jira/browse/KAFKA-2807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2807: - Priority: Blocker (was: Major) > Movement of throughput throttler to common broke upgrade tests

[jira] [Updated] (KAFKA-2517) Performance Regression post SSL implementation

[ https://issues.apache.org/jira/browse/KAFKA-2517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2517: - Priority: Blocker (was: Critical) > Performance Regression post SSL implementation >

[jira] [Commented] (KAFKA-2403) Expose offset commit metadata in new consumer

[ https://issues.apache.org/jira/browse/KAFKA-2403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708125#comment-14708125 ] Neha Narkhede commented on KAFKA-2403: -- [~hachikuji] [~ewencp] Cross posting my

[jira] [Commented] (KAFKA-2367) Add Copycat runtime data API

[ https://issues.apache.org/jira/browse/KAFKA-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14702063#comment-14702063 ] Neha Narkhede commented on KAFKA-2367: -- I think there are various tradeoffs, as with

[jira] [Commented] (KAFKA-2365) Copycat checklist

[ https://issues.apache.org/jira/browse/KAFKA-2365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14643087#comment-14643087 ] Neha Narkhede commented on KAFKA-2365: -- Worth discussing a process for including a

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642229#comment-14642229 ] Neha Narkhede commented on KAFKA-2350: -- Few thoughts: bq. 1. Add pause/unpause bq. 2.

[jira] [Comment Edited] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642229#comment-14642229 ] Neha Narkhede edited comment on KAFKA-2350 at 7/27/15 3:55 AM:

[jira] [Updated] (KAFKA-2311) Consumer's ensureNotClosed method not thread safe

[ https://issues.apache.org/jira/browse/KAFKA-2311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2311: - Reviewer: Neha Narkhede Consumer's ensureNotClosed method not thread safe

[jira] [Updated] (KAFKA-2321) Introduce CONTRIBUTING.md

[ https://issues.apache.org/jira/browse/KAFKA-2321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2321: - Reviewer: Neha Narkhede Introduce CONTRIBUTING.md -

[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 ] Neha Narkhede updated KAFKA-2323: - Reviewer: Jun Rao Simplify ScalaTest dependency versions --

[jira] [Updated] (KAFKA-2236) offset request reply racing with segment rolling

[ https://issues.apache.org/jira/browse/KAFKA-2236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2236: - Assignee: Jason Gustafson offset request reply racing with segment rolling

[jira] [Commented] (KAFKA-2187) Introduce merge-kafka-pr.py script

[ https://issues.apache.org/jira/browse/KAFKA-2187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569499#comment-14569499 ] Neha Narkhede commented on KAFKA-2187: -- [~ijuma] As I went through the patch again, I

[jira] [Commented] (KAFKA-2231) Deleting a topic fails

[ https://issues.apache.org/jira/browse/KAFKA-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14566889#comment-14566889 ] Neha Narkhede commented on KAFKA-2231: -- [~JGH] Thanks for reporting the issue. Would

[jira] [Updated] (KAFKA-2233) Log deletion is not removing log metrics

[ https://issues.apache.org/jira/browse/KAFKA-2233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2233: - Labels: newbie (was: ) Log deletion is not removing log metrics

[jira] [Updated] (KAFKA-2187) Introduce merge-kafka-pr.py script

[ https://issues.apache.org/jira/browse/KAFKA-2187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2187: - Reviewer: Neha Narkhede Introduce merge-kafka-pr.py script --

[jira] [Commented] (KAFKA-2187) Introduce merge-kafka-pr.py script

[ https://issues.apache.org/jira/browse/KAFKA-2187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14566884#comment-14566884 ] Neha Narkhede commented on KAFKA-2187: -- [~ijuma] This looks great. I can check it in,

[jira] [Commented] (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:comment-tabpanelfocusedCommentId=14562061#comment-14562061 ] Neha Narkhede commented on KAFKA-2168: -- There are tradeoffs to having multiple

[jira] [Commented] (KAFKA-2197) Controller not able to update state for broker on the same machine

[ https://issues.apache.org/jira/browse/KAFKA-2197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14545751#comment-14545751 ] Neha Narkhede commented on KAFKA-2197: -- [~bedwards] Unassigning myself as I probably

[jira] [Updated] (KAFKA-2197) Controller not able to update state for broker on the same machine

[ https://issues.apache.org/jira/browse/KAFKA-2197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2197: - Assignee: (was: Neha Narkhede) Controller not able to update state for broker on the same

[jira] [Commented] (KAFKA-2166) Recreation breaks topic-list

[ https://issues.apache.org/jira/browse/KAFKA-2166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14526860#comment-14526860 ] Neha Narkhede commented on KAFKA-2166: -- [~Alien2150] Thanks for reporting this issue.

[jira] [Updated] (KAFKA-824) java.lang.NullPointerException in commitOffsets

[ https://issues.apache.org/jira/browse/KAFKA-824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-824: Affects Version/s: 0.8.2.0 Assignee: (was: Neha Narkhede) Labels:

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

Neha Narkhede created KAFKA-2169: Summary: Upgrade to zkclient-0.5 Key: KAFKA-2169 URL: https://issues.apache.org/jira/browse/KAFKA-2169 Project: Kafka Issue Type: Bug Affects Versions:

[jira] [Updated] (KAFKA-2159) offsets.topic.segment.bytes and offsets.topic.retention.minutes are ignored

[ https://issues.apache.org/jira/browse/KAFKA-2159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2159: - Labels: newbie (was: ) offsets.topic.segment.bytes and offsets.topic.retention.minutes are

[jira] [Updated] (KAFKA-2159) offsets.topic.segment.bytes and offsets.topic.retention.minutes are ignored

[ https://issues.apache.org/jira/browse/KAFKA-2159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2159: - Component/s: offset manager offsets.topic.segment.bytes and offsets.topic.retention.minutes are

[jira] [Commented] (KAFKA-2156) Possibility to plug in custom MetricRegistry

[ https://issues.apache.org/jira/browse/KAFKA-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14526932#comment-14526932 ] Neha Narkhede commented on KAFKA-2156: -- [~sandris] KM = Kafka Metrics

[jira] [Comment Edited] (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

[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14526945#comment-14526945 ] Neha Narkhede edited comment on KAFKA-1387 at 5/4/15 5:58 PM: --

[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

[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1387: - Priority: Blocker (was: Major) When this happens, there isn't a way to get out of this without

[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

[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1387: - Labels: newbie patch zkclient-problems (was: newbie patch) Kafka getting stuck creating

[jira] [Commented] (KAFKA-2157) kafka-console-consumer.sh: Mismatch in CLI usage docs vs. Scala Option parsing

[ https://issues.apache.org/jira/browse/KAFKA-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14526972#comment-14526972 ] Neha Narkhede commented on KAFKA-2157: -- [~tvaughan77] topics is correct. Patch is

[jira] [Resolved] (KAFKA-2155) Add option to control ZK root for kafka.tools.ConsumerOffsetChecker

[ https://issues.apache.org/jira/browse/KAFKA-2155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-2155. -- Resolution: Not A Problem Add option to control ZK root for kafka.tools.ConsumerOffsetChecker

[jira] [Commented] (KAFKA-2155) Add option to control ZK root for kafka.tools.ConsumerOffsetChecker

[ https://issues.apache.org/jira/browse/KAFKA-2155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14526978#comment-14526978 ] Neha Narkhede commented on KAFKA-2155: -- You can just specify the zk root as part of

[jira] [Updated] (KAFKA-1843) Metadata fetch/refresh in new producer should handle all node connection states gracefully

[ https://issues.apache.org/jira/browse/KAFKA-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1843: - Labels: newbie++ (was: ) Metadata fetch/refresh in new producer should handle all node

[jira] [Updated] (KAFKA-1843) Metadata fetch/refresh in new producer should handle all node connection states gracefully

[ https://issues.apache.org/jira/browse/KAFKA-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1843: - Priority: Blocker (was: Major) Metadata fetch/refresh in new producer should handle all node

[jira] [Commented] (KAFKA-2139) Add a separate controller messge queue with higher priority on broker side

[ https://issues.apache.org/jira/browse/KAFKA-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14527048#comment-14527048 ] Neha Narkhede commented on KAFKA-2139: -- [~becket_qin] Left some comments regarding

[jira] [Updated] (KAFKA-1843) Metadata fetch/refresh in new producer should handle all node connection states gracefully

[ https://issues.apache.org/jira/browse/KAFKA-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1843: - Labels: (was: newbie++) Metadata fetch/refresh in new producer should handle all node

[jira] [Resolved] (KAFKA-1886) SimpleConsumer swallowing ClosedByInterruptException

[ https://issues.apache.org/jira/browse/KAFKA-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1886. -- Resolution: Fixed Thanks, pushed to trunk SimpleConsumer swallowing

[jira] [Updated] (KAFKA-2158) Close all fetchers in AbstractFetcherManager without blocking

[ https://issues.apache.org/jira/browse/KAFKA-2158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2158: - Reviewer: Jun Rao Close all fetchers in AbstractFetcherManager without blocking

[jira] [Updated] (KAFKA-2153) kafka-patch-review tool uploads a patch even if it is empty

[ https://issues.apache.org/jira/browse/KAFKA-2153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2153: - Resolution: Fixed Status: Resolved (was: Patch Available) Thanks, pushed to trunk.

[jira] [Commented] (KAFKA-313) Add JSON/CSV output and looping options to ConsumerGroupCommand

[ https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14527075#comment-14527075 ] Neha Narkhede commented on KAFKA-313: - [~singhashish] I'm sorry for the delay. Not sure

[jira] [Updated] (KAFKA-1621) Standardize --messages option in perf scripts

[ https://issues.apache.org/jira/browse/KAFKA-1621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1621: - Resolution: Fixed Assignee: Rekha Joshi Status: Resolved (was: Patch Available)

[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-tabpanelfocusedCommentId=14516298#comment-14516298 ] Neha Narkhede commented on KAFKA-1367: -- [~jjkoshy] That would work too but looks like

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

[ https://issues.apache.org/jira/browse/KAFKA-1054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1054: - Resolution: Fixed Status: Resolved (was: Patch Available) Thanks. Merged the github PR.

[jira] [Commented] (KAFKA-1748) Decouple system test cluster resources definition from service definitions

[ https://issues.apache.org/jira/browse/KAFKA-1748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513111#comment-14513111 ] Neha Narkhede commented on KAFKA-1748: -- [~ewencp] With the ducktape work, I guess we

[jira] [Updated] (KAFKA-2034) sourceCompatibility not set in Kafka build.gradle

[ https://issues.apache.org/jira/browse/KAFKA-2034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2034: - Resolution: Fixed Reviewer: Ewen Cheslack-Postava Assignee: Ismael Juma

[jira] [Commented] (KAFKA-1351) String.format is very expensive in Scala

[ https://issues.apache.org/jira/browse/KAFKA-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513096#comment-14513096 ] Neha Narkhede commented on KAFKA-1351: -- Not sure that this is still a concern. I was

[jira] [Resolved] (KAFKA-1293) Mirror maker housecleaning

[ https://issues.apache.org/jira/browse/KAFKA-1293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1293. -- Resolution: Fixed Closing based on [~mwarhaftig]'s latest comment. Mirror maker housecleaning

[jira] [Resolved] (KAFKA-1277) Keep the summery/description when updating the RB with kafka-patch-review

[ https://issues.apache.org/jira/browse/KAFKA-1277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1277. -- Resolution: Incomplete Closing due to inactivity. Keep the summery/description when updating

[jira] [Commented] (KAFKA-2140) Improve code readability

[ https://issues.apache.org/jira/browse/KAFKA-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513094#comment-14513094 ] Neha Narkhede commented on KAFKA-2140: -- +1 Improve code readability

[jira] [Commented] (KAFKA-1737) Document required ZkSerializer for ZkClient used with AdminUtils

[ https://issues.apache.org/jira/browse/KAFKA-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513312#comment-14513312 ] Neha Narkhede commented on KAFKA-1737: -- [~vivekpm] Makes sense. Would you like to

[jira] [Updated] (KAFKA-2080) quick cleanup of producer performance scripts

[ https://issues.apache.org/jira/browse/KAFKA-2080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2080: - Component/s: tools quick cleanup of producer performance scripts

[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 ] Neha Narkhede updated KAFKA-2041: - Status: Patch Available (was: Open) Add ability to specify a KeyClass for KafkaLog4jAppender

[jira] [Updated] (KAFKA-2003) Add upgrade tests

[ https://issues.apache.org/jira/browse/KAFKA-2003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2003: - Component/s: system tests Add upgrade tests - Key: KAFKA-2003

[jira] [Resolved] (KAFKA-2108) Node deleted all data and re-sync from replicas after attempted upgrade from 0.8.1.1 to 0.8.2.0

[ https://issues.apache.org/jira/browse/KAFKA-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-2108. -- Resolution: Incomplete Closing due to inactivity. [~slimunholyone], [~becket_qin] feel free to

[jira] [Commented] (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:comment-tabpanelfocusedCommentId=14513318#comment-14513318 ] Neha Narkhede commented on KAFKA-2101: -- [~timbrooks] To clarify your question - we

[jira] [Updated] (KAFKA-2100) Client Error doesn't preserve or display original server error code when it is an unknown code

[ https://issues.apache.org/jira/browse/KAFKA-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2100: - Component/s: clients Client Error doesn't preserve or display original server error code when it

[jira] [Commented] (KAFKA-1621) Standardize --messages option in perf scripts

[ https://issues.apache.org/jira/browse/KAFKA-1621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513324#comment-14513324 ] Neha Narkhede commented on KAFKA-1621: -- [~rekhajoshm] Sorry for the delay, reviewed

[jira] [Updated] (KAFKA-1904) run sanity failed test

[ https://issues.apache.org/jira/browse/KAFKA-1904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1904: - Component/s: system tests run sanity failed test -- Key:

[jira] [Updated] (KAFKA-2080) quick cleanup of producer performance scripts

[ https://issues.apache.org/jira/browse/KAFKA-2080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2080: - Labels: newbie (was: ) quick cleanup of producer performance scripts

[jira] [Updated] (KAFKA-1858) Make ServerShutdownTest a bit less flaky

[ https://issues.apache.org/jira/browse/KAFKA-1858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1858: - Reviewer: Jun Rao Status: Patch Available (was: Open) Make ServerShutdownTest a bit less

[jira] [Updated] (KAFKA-2014) Chaos Monkey / Failure Inducer for Kafka

[ https://issues.apache.org/jira/browse/KAFKA-2014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2014: - Component/s: system tests Chaos Monkey / Failure Inducer for Kafka

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

[ https://issues.apache.org/jira/browse/KAFKA-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513316#comment-14513316 ] Neha Narkhede commented on KAFKA-2103: -- [~becket_qin] Is this still an issue? If so,

[jira] [Updated] (KAFKA-2100) Client Error doesn't preserve or display original server error code when it is an unknown code

[ https://issues.apache.org/jira/browse/KAFKA-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2100: - Labels: newbie (was: ) Client Error doesn't preserve or display original server error code when

[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 ] Neha Narkhede updated KAFKA-1758: - Reviewer: Neha Narkhede corrupt recovery file prevents startup

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

[ https://issues.apache.org/jira/browse/KAFKA-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513186#comment-14513186 ] Neha Narkhede commented on KAFKA-1758: -- [~omkreddy] I took a quick look and left a

[jira] [Updated] (KAFKA-2150) FetcherThread backoff need to grab lock before wait on condition.

[ https://issues.apache.org/jira/browse/KAFKA-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2150: - Reviewer: Guozhang Wang [~guozhang] This was introduced in KAFKA-1461, so assigning to you for

[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-tabpanelfocusedCommentId=14513265#comment-14513265 ] Neha Narkhede commented on KAFKA-1367: -- [~jkreps] Yup, issue still exists and the

[jira] [Commented] (KAFKA-2027) kafka never notifies the zookeeper client when a partition moved with due to an auto-rebalance (when auto.leader.rebalance.enable=true)

[ https://issues.apache.org/jira/browse/KAFKA-2027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513151#comment-14513151 ] Neha Narkhede commented on KAFKA-2027: -- Can you describe the end user behavior that

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

[ https://issues.apache.org/jira/browse/KAFKA-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2105: - Status: Patch Available (was: Open) NullPointerException in client on MetadataRequest

[jira] [Commented] (KAFKA-2029) Improving controlled shutdown for rolling updates

[ https://issues.apache.org/jira/browse/KAFKA-2029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513138#comment-14513138 ] Neha Narkhede commented on KAFKA-2029: -- [~jkreps] That's somewhat right. When the

[jira] [Updated] (KAFKA-2029) Improving controlled shutdown for rolling updates

[ https://issues.apache.org/jira/browse/KAFKA-2029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2029: - Reviewer: Neha Narkhede Improving controlled shutdown for rolling updates

[jira] [Commented] (KAFKA-2140) Improve code readability

[ https://issues.apache.org/jira/browse/KAFKA-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513202#comment-14513202 ] Neha Narkhede commented on KAFKA-2140: -- Fixed and pushed. Improve code readability

[jira] [Commented] (KAFKA-1887) controller error message on shutting the last broker

[ https://issues.apache.org/jira/browse/KAFKA-1887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513159#comment-14513159 ] Neha Narkhede commented on KAFKA-1887: -- [~sriharsha] The patch is waiting for a

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

[ https://issues.apache.org/jira/browse/KAFKA-1940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1940: - Status: Patch Available (was: Open) Initial checkout and build failing

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503169#comment-14503169 ] Neha Narkhede commented on KAFKA-873: - I'm not so sure yet that moving to Curator is a

[jira] [Updated] (KAFKA-2057) DelayedOperationTest.testRequestExpiry transient failure

[ https://issues.apache.org/jira/browse/KAFKA-2057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2057: - Resolution: Fixed Reviewer: Neha Narkhede Status: Resolved (was: Patch Available)

[jira] [Updated] (KAFKA-2087) TopicConfigManager javadoc references incorrect paths

[ https://issues.apache.org/jira/browse/KAFKA-2087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2087: - Reviewer: Neha Narkhede TopicConfigManager javadoc references incorrect paths

[jira] [Updated] (KAFKA-2087) TopicConfigManager javadoc references incorrect paths

[ https://issues.apache.org/jira/browse/KAFKA-2087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2087: - Resolution: Fixed Status: Resolved (was: Patch Available) Pushed to trunk. Thanks!

[jira] [Commented] (KAFKA-1961) Looks like its possible to delete _consumer_offsets topic

[ https://issues.apache.org/jira/browse/KAFKA-1961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14394856#comment-14394856 ] Neha Narkhede commented on KAFKA-1961: -- +1. Checking it in... Looks like its

[jira] [Updated] (KAFKA-1961) Looks like its possible to delete _consumer_offsets topic

[ https://issues.apache.org/jira/browse/KAFKA-1961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1961: - Resolution: Fixed Assignee: Ted Malaska (was: Gwen Shapira) Status: Resolved (was:

[jira] [Comment Edited] (KAFKA-1293) Mirror maker housecleaning

[ https://issues.apache.org/jira/browse/KAFKA-1293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386039#comment-14386039 ] Neha Narkhede edited comment on KAFKA-1293 at 3/30/15 12:15 AM:

[jira] [Commented] (KAFKA-1293) Mirror maker housecleaning

[ https://issues.apache.org/jira/browse/KAFKA-1293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386039#comment-14386039 ] Neha Narkhede commented on KAFKA-1293: -- cc [~junrao] Mirror maker housecleaning

[jira] [Updated] (KAFKA-1994) Evaluate performance effect of chroot check on Topic creation

[ https://issues.apache.org/jira/browse/KAFKA-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1994: - Reviewer: Jun Rao Evaluate performance effect of chroot check on Topic creation

[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-tabpanelfocusedCommentId=14386037#comment-14386037 ] Neha Narkhede commented on KAFKA-1215: -- [~allenxwang] This was inactive for a while,

[jira] [Commented] (KAFKA-2046) Delete topic still doesn't work

[ https://issues.apache.org/jira/browse/KAFKA-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14385996#comment-14385996 ] Neha Narkhede commented on KAFKA-2046: -- [~onurkaraman] Shouldn't

[jira] [Commented] (KAFKA-527) Compression support does numerous byte copies

[ https://issues.apache.org/jira/browse/KAFKA-527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14385999#comment-14385999 ] Neha Narkhede commented on KAFKA-527: - [~guozhang] +1. Will be great to re-run the test

[jira] [Commented] (KAFKA-2046) Delete topic still doesn't work

[ https://issues.apache.org/jira/browse/KAFKA-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386021#comment-14386021 ] Neha Narkhede commented on KAFKA-2046: -- [~onurkaraman] Could [~clarkhaskins]

[jira] [Commented] (KAFKA-1983) TestEndToEndLatency can be unreliable after hard kill

[ https://issues.apache.org/jira/browse/KAFKA-1983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386028#comment-14386028 ] Neha Narkhede commented on KAFKA-1983: -- cc [~junrao] TestEndToEndLatency can be

[jira] [Updated] (KAFKA-2034) sourceCompatibility not set in Kafka build.gradle

[ https://issues.apache.org/jira/browse/KAFKA-2034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2034: - Labels: newbie (was: ) sourceCompatibility not set in Kafka build.gradle

[jira] [Updated] (KAFKA-2034) sourceCompatibility not set in Kafka build.gradle

[ https://issues.apache.org/jira/browse/KAFKA-2034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2034: - Component/s: build sourceCompatibility not set in Kafka build.gradle

[jira] [Commented] (KAFKA-2046) Delete topic still doesn't work

[ https://issues.apache.org/jira/browse/KAFKA-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14378783#comment-14378783 ] Neha Narkhede commented on KAFKA-2046: -- [~clarkhaskins] As discussed previously, the

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

[ https://issues.apache.org/jira/browse/KAFKA-1928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1928: - Issue Type: Sub-task (was: Improvement) Parent: KAFKA-1682 Move kafka.network over to

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

[ https://issues.apache.org/jira/browse/KAFKA-1928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1928: - Component/s: security Move kafka.network over to using the network classes in

[jira] [Commented] (KAFKA-1546) Automate replica lag tuning

[ https://issues.apache.org/jira/browse/KAFKA-1546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14362581#comment-14362581 ] Neha Narkhede commented on KAFKA-1546: -- [~aauradkar] Thanks for the patch. Overall,

  1   2   3   4   5   6   7   8   9   10   >