[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 ] Gwen Shapira updated KAFKA-2311: Priority: Major (was: Blocker) > Consumer's ensureNotClosed method not thread safe >

[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 ] Gwen Shapira updated KAFKA-2311: Reviewer: Jason Gustafson (was: Neha Narkhede) > Consumer's ensureNotClosed method not thread safe

[jira] [Updated] (KAFKA-2338) Warn users if they change max.message.bytes that they also need to update broker and consumer settings

[ https://issues.apache.org/jira/browse/KAFKA-2338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2338: Priority: Critical (was: Blocker) > Warn users if they change max.message.bytes that they also

[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 ] Gwen Shapira updated KAFKA-1387: Priority: Critical (was: Blocker) > Kafka getting stuck creating ephemeral node it has already

[jira] [Updated] (KAFKA-2064) Replace ConsumerMetadataRequest and Response with org.apache.kafka.common.requests objects

[ https://issues.apache.org/jira/browse/KAFKA-2064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2064: Fix Version/s: (was: 0.8.3) > Replace ConsumerMetadataRequest and Response with >

[jira] [Updated] (KAFKA-2066) Replace FetchRequest / FetchResponse with their org.apache.kafka.common.requests equivalents

[ https://issues.apache.org/jira/browse/KAFKA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2066: Fix Version/s: (was: 0.8.3) > Replace FetchRequest / FetchResponse with their >

[jira] [Updated] (KAFKA-1763) validate_index_log in system tests runs remotely but uses local paths

[ https://issues.apache.org/jira/browse/KAFKA-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1763: Fix Version/s: (was: 0.8.3) > validate_index_log in system tests runs remotely but uses local

[jira] [Updated] (KAFKA-2338) Warn users if they change max.message.bytes that they also need to update broker and consumer settings

[ https://issues.apache.org/jira/browse/KAFKA-2338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2338: Fix Version/s: (was: 0.8.3) > Warn users if they change max.message.bytes that they also need

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

[ https://issues.apache.org/jira/browse/KAFKA-2229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2229: Fix Version/s: (was: 0.8.3) > Phase 1: Requests and KafkaApis > ---

[jira] [Updated] (KAFKA-2303) Fix for KAFKA-2235 LogCleaner offset map overflow causes another compaction failures

[ https://issues.apache.org/jira/browse/KAFKA-2303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2303: Fix Version/s: (was: 0.8.3) > Fix for KAFKA-2235 LogCleaner offset map overflow causes another

[jira] [Updated] (KAFKA-2470) kafka-producer-perf-test.sh can't configure all to request-num-acks

[ https://issues.apache.org/jira/browse/KAFKA-2470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2470: Fix Version/s: (was: 0.8.3) > kafka-producer-perf-test.sh can't configure all to

[jira] [Updated] (KAFKA-2146) adding partition did not find the correct startIndex

[ https://issues.apache.org/jira/browse/KAFKA-2146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2146: Fix Version/s: (was: 0.8.3) > adding partition did not find the correct startIndex >

[jira] [Updated] (KAFKA-2070) Replace OffsetRequest/response with ListOffsetRequest/response from org.apache.kafka.common.requests

[ https://issues.apache.org/jira/browse/KAFKA-2070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2070: Fix Version/s: (was: 0.8.3) > Replace OffsetRequest/response with ListOffsetRequest/response

[jira] [Updated] (KAFKA-2375) Implement elasticsearch Copycat sink connector

[ https://issues.apache.org/jira/browse/KAFKA-2375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2375: Fix Version/s: (was: 0.8.3) > Implement elasticsearch Copycat sink connector >

[jira] [Updated] (KAFKA-438) Code cleanup in MessageTest

[ https://issues.apache.org/jira/browse/KAFKA-438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-438: --- Fix Version/s: (was: 0.8.3) > Code cleanup in MessageTest > --- > >

[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 ] Gwen Shapira updated KAFKA-1755: Fix Version/s: (was: 0.8.3) > Improve error handling in log cleaner >

[jira] [Updated] (KAFKA-1566) Kafka environment configuration (kafka-env.sh)

[ https://issues.apache.org/jira/browse/KAFKA-1566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1566: Fix Version/s: (was: 0.8.3) > Kafka environment configuration (kafka-env.sh) >

[jira] [Updated] (KAFKA-1927) Replace requests in kafka.api with requests in org.apache.kafka.common.requests

[ https://issues.apache.org/jira/browse/KAFKA-1927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1927: Fix Version/s: (was: 0.8.3) > Replace requests in kafka.api with requests in >

[jira] [Commented] (KAFKA-2500) Make logEndOffset available in the 0.8.3 Consumer

[ https://issues.apache.org/jira/browse/KAFKA-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14726238#comment-14726238 ] Gwen Shapira commented on KAFKA-2500: - [~hachikuji], do you want to take a look at this one? > Make

[jira] [Updated] (KAFKA-1898) compatibility testing framework

[ https://issues.apache.org/jira/browse/KAFKA-1898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1898: Fix Version/s: (was: 0.8.3) > compatibility testing framework >

[jira] [Updated] (KAFKA-2442) QuotasTest should not fail when cpu is busy

[ https://issues.apache.org/jira/browse/KAFKA-2442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2442: Fix Version/s: (was: 0.8.3) > QuotasTest should not fail when cpu is busy >

[jira] [Updated] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2120: Fix Version/s: (was: 0.8.3) > Add a request timeout to NetworkClient >

[jira] [Updated] (KAFKA-2073) Replace TopicMetadata request/response with o.a.k.requests.metadata

[ https://issues.apache.org/jira/browse/KAFKA-2073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2073: Fix Version/s: (was: 0.8.3) > Replace TopicMetadata request/response with

[jira] [Updated] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2120: Fix Version/s: 0.8.3 > Add a request timeout to NetworkClient >

[jira] [Updated] (KAFKA-1967) Support more flexible serialization in Log4jAppender

[ https://issues.apache.org/jira/browse/KAFKA-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1967: Fix Version/s: (was: 0.8.3) > Support more flexible serialization in Log4jAppender >

[jira] [Updated] (KAFKA-1853) Unsuccessful suffix rename of expired LogSegment can leak open files and also leave the LogSegment in an invalid state

[ https://issues.apache.org/jira/browse/KAFKA-1853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1853: Fix Version/s: (was: 0.8.3) > Unsuccessful suffix rename of expired LogSegment can leak open

[jira] [Updated] (KAFKA-2378) Add Copycat embedded API

[ https://issues.apache.org/jira/browse/KAFKA-2378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2378: Assignee: Ewen Cheslack-Postava > Add Copycat embedded API > > >

[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 ] Gwen Shapira updated KAFKA-2254: Fix Version/s: (was: 0.8.3) > The shell script should be optimized , even kafka-run-class.sh

[jira] [Updated] (KAFKA-2075) Validate that all kafka.api requests has been removed and clean up compatibility code

[ https://issues.apache.org/jira/browse/KAFKA-2075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2075: Fix Version/s: (was: 0.8.3) > Validate that all kafka.api requests has been removed and clean

[jira] [Updated] (KAFKA-2449) Update mirror maker (MirrorMaker) docs

[ https://issues.apache.org/jira/browse/KAFKA-2449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2449: Assignee: Geoff Anderson > Update mirror maker (MirrorMaker) docs >

[jira] [Updated] (KAFKA-2417) Ducktape tests for SSL/TLS

[ https://issues.apache.org/jira/browse/KAFKA-2417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2417: Assignee: Geoff Anderson > Ducktape tests for SSL/TLS > -- > >

[jira] [Updated] (KAFKA-2475) Reduce copycat configs to only specify a converter or serializer, not both

[ https://issues.apache.org/jira/browse/KAFKA-2475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2475: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-2485) Allow producer performance to take properties from a file via --producer.config command line parameter

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

[jira] [Resolved] (KAFKA-2486) New consumer performance

[ https://issues.apache.org/jira/browse/KAFKA-2486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2486. - Resolution: Fixed Issue resolved by pull request 180 [https://github.com/apache/kafka/pull/180]

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

[ https://issues.apache.org/jira/browse/KAFKA-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2367: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-2377) Add copycat system tests

[ https://issues.apache.org/jira/browse/KAFKA-2377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2377: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

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

[ https://issues.apache.org/jira/browse/KAFKA-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14715409#comment-14715409 ] Gwen Shapira commented on KAFKA-1977: - I lost track of the new consumer APIs, so I'm

[jira] [Resolved] (KAFKA-1683) Implement a session concept in the socket server

[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-1683. - Resolution: Fixed Issue resolved by pull request 155 [https://github.com/apache/kafka/pull/155]

[jira] [Updated] (KAFKA-2122) Remove controller.message.queue.size Config

[ https://issues.apache.org/jira/browse/KAFKA-2122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2122: Fix Version/s: 0.8.3 Remove controller.message.queue.size Config

[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=14712401#comment-14712401 ] Gwen Shapira commented on KAFKA-2367: - My opinions / comments on the above: * Logical

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

[ https://issues.apache.org/jira/browse/KAFKA-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2367: Status: Patch Available (was: Open) Add Copycat runtime data API

[jira] [Updated] (KAFKA-2461) request logger no longer logs extra information in debug mode

[ https://issues.apache.org/jira/browse/KAFKA-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2461: Fix Version/s: 0.8.3 request logger no longer logs extra information in debug mode

[jira] [Created] (KAFKA-2461) request logger no longer logs extra information in debug mode

Gwen Shapira created KAFKA-2461: --- Summary: request logger no longer logs extra information in debug mode Key: KAFKA-2461 URL: https://issues.apache.org/jira/browse/KAFKA-2461 Project: Kafka

[jira] [Commented] (KAFKA-2461) request logger no longer logs extra information in debug mode

[ https://issues.apache.org/jira/browse/KAFKA-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14709988#comment-14709988 ] Gwen Shapira commented on KAFKA-2461: - Of course. Thanks [~singhashish] request

[jira] [Created] (KAFKA-2462) allow modifying soft limit for open files in Kafka startup script

Gwen Shapira created KAFKA-2462: --- Summary: allow modifying soft limit for open files in Kafka startup script Key: KAFKA-2462 URL: https://issues.apache.org/jira/browse/KAFKA-2462 Project: Kafka

[jira] [Created] (KAFKA-2465) Need to document replica.fetcher.backoff.ms

Gwen Shapira created KAFKA-2465: --- Summary: Need to document replica.fetcher.backoff.ms Key: KAFKA-2465 URL: https://issues.apache.org/jira/browse/KAFKA-2465 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-2465) Need to document replica.fetcher.backoff.ms

[ https://issues.apache.org/jira/browse/KAFKA-2465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14710457#comment-14710457 ] Gwen Shapira commented on KAFKA-2465: - [~harsha_ch] - since you added the

[jira] [Resolved] (KAFKA-2463) Our shell scripts should use getopts for argument parsing.

[ https://issues.apache.org/jira/browse/KAFKA-2463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2463. - Resolution: Won't Fix Never mind, getopts doesn't support long options, which means we will break

[jira] [Created] (KAFKA-2463) Our shell scripts should use getopts for argument parsing.

Gwen Shapira created KAFKA-2463: --- Summary: Our shell scripts should use getopts for argument parsing. Key: KAFKA-2463 URL: https://issues.apache.org/jira/browse/KAFKA-2463 Project: Kafka Issue

[jira] [Commented] (KAFKA-2338) Warn users if they change max.message.bytes that they also need to update broker and consumer settings

[ https://issues.apache.org/jira/browse/KAFKA-2338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708277#comment-14708277 ] Gwen Shapira commented on KAFKA-2338: - OK, this patch doesn't even come close to

[jira] [Resolved] (KAFKA-2439) Add MirrorMakerService to ducktape system tests

[ https://issues.apache.org/jira/browse/KAFKA-2439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2439. - Resolution: Fixed Issue resolved by pull request 148 [https://github.com/apache/kafka/pull/148]

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

[ https://issues.apache.org/jira/browse/KAFKA-2403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2403: Fix Version/s: 0.8.3 Expose offset commit metadata in new consumer

[jira] [Updated] (KAFKA-2338) Warn users if they change max.message.bytes that they also need to update broker and consumer settings

[ https://issues.apache.org/jira/browse/KAFKA-2338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2338: Status: In Progress (was: Patch Available) Warn users if they change max.message.bytes that they

[jira] [Commented] (KAFKA-2338) Warn users if they change max.message.bytes that they also need to update broker and consumer settings

[ https://issues.apache.org/jira/browse/KAFKA-2338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708278#comment-14708278 ] Gwen Shapira commented on KAFKA-2338: - Sorry, patch doesn't apply again :( Can you

[jira] [Updated] (KAFKA-2377) Add copycat system tests

[ https://issues.apache.org/jira/browse/KAFKA-2377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2377: Assignee: Ewen Cheslack-Postava Status: In Progress (was: Patch Available) Looks good.

[jira] [Commented] (KAFKA-1566) Kafka environment configuration (kafka-env.sh)

[ https://issues.apache.org/jira/browse/KAFKA-1566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708280#comment-14708280 ] Gwen Shapira commented on KAFKA-1566: - Thanks for the PR, [~harsha_ch] I like the

[jira] [Commented] (KAFKA-1877) Expose version via JMX for 'new' producer

[ https://issues.apache.org/jira/browse/KAFKA-1877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14707377#comment-14707377 ] Gwen Shapira commented on KAFKA-1877: - Thanks for updating the status. Expose

[jira] [Updated] (KAFKA-2457) StackOverflowError during builds

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

[jira] [Commented] (KAFKA-2412) Documentation bug: Add information for key.serializer and value.serializer to New Producer Config sections

[ https://issues.apache.org/jira/browse/KAFKA-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14707249#comment-14707249 ] Gwen Shapira commented on KAFKA-2412: - Thank you for contributing! Documenting our

[jira] [Updated] (KAFKA-1897) Enhance MockProducer for more sophisticated tests

[ https://issues.apache.org/jira/browse/KAFKA-1897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1897: Fix Version/s: (was: 0.8.3) Enhance MockProducer for more sophisticated tests

[jira] [Resolved] (KAFKA-1855) Topic unusable after unsuccessful UpdateMetadataRequest

[ https://issues.apache.org/jira/browse/KAFKA-1855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-1855. - Resolution: Cannot Reproduce Topic unusable after unsuccessful UpdateMetadataRequest

[jira] [Updated] (KAFKA-1877) Expose version via JMX for 'new' producer

[ https://issues.apache.org/jira/browse/KAFKA-1877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1877: Fix Version/s: (was: 0.8.3) Expose version via JMX for 'new' producer

[jira] [Commented] (KAFKA-1898) compatibility testing framework

[ https://issues.apache.org/jira/browse/KAFKA-1898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14706121#comment-14706121 ] Gwen Shapira commented on KAFKA-1898: - Looping back here [~granders], is this

[jira] [Updated] (KAFKA-1912) Create a simple request re-routing facility

[ https://issues.apache.org/jira/browse/KAFKA-1912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1912: Fix Version/s: (was: 0.8.3) Create a simple request re-routing facility

[jira] [Updated] (KAFKA-1911) Log deletion on stopping replicas should be async

[ https://issues.apache.org/jira/browse/KAFKA-1911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1911: Fix Version/s: (was: 0.8.3) Log deletion on stopping replicas should be async

[jira] [Resolved] (KAFKA-1913) App hungs when calls producer.send to wrong IP of Kafka broker

[ https://issues.apache.org/jira/browse/KAFKA-1913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-1913. - Resolution: Duplicate App hungs when calls producer.send to wrong IP of Kafka broker

[jira] [Updated] (KAFKA-1893) Allow regex subscriptions in the new consumer

[ https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1893: Reviewer: Gwen Shapira Allow regex subscriptions in the new consumer

[jira] [Updated] (KAFKA-2007) update offsetrequest for more useful information we have on broker about partition

[ https://issues.apache.org/jira/browse/KAFKA-2007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2007: Fix Version/s: (was: 0.8.3) update offsetrequest for more useful information we have on broker

[jira] [Updated] (KAFKA-1566) Kafka environment configuration (kafka-env.sh)

[ https://issues.apache.org/jira/browse/KAFKA-1566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1566: Reviewer: Gwen Shapira Kafka environment configuration (kafka-env.sh)

[jira] [Created] (KAFKA-2455) Test Failure: kafka.consumer.MetricsTest testMetricsLeak

Gwen Shapira created KAFKA-2455: --- Summary: Test Failure: kafka.consumer.MetricsTest testMetricsLeak Key: KAFKA-2455 URL: https://issues.apache.org/jira/browse/KAFKA-2455 Project: Kafka

[jira] [Commented] (KAFKA-1683) Implement a session concept in the socket server

[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14706099#comment-14706099 ] Gwen Shapira commented on KAFKA-1683: - [~harsha_ch] mmm... I'm talking about returning

[jira] [Updated] (KAFKA-1792) change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments

[ https://issues.apache.org/jira/browse/KAFKA-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1792: Fix Version/s: (was: 0.8.3) change behavior of --generate to produce assignment config with

[jira] [Updated] (KAFKA-1802) Add a new type of request for the discovery of the controller

[ https://issues.apache.org/jira/browse/KAFKA-1802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1802: Fix Version/s: (was: 0.8.3) Add a new type of request for the discovery of the controller

[jira] [Updated] (KAFKA-1842) New producer/consumer should support configurable connection timeouts

[ https://issues.apache.org/jira/browse/KAFKA-1842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1842: Fix Version/s: (was: 0.8.3) New producer/consumer should support configurable connection

[jira] [Updated] (KAFKA-1817) AdminUtils.createTopic vs kafka-topics.sh --create with partitions

[ https://issues.apache.org/jira/browse/KAFKA-1817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1817: Fix Version/s: (was: 0.8.3) AdminUtils.createTopic vs kafka-topics.sh --create with partitions

[jira] [Updated] (KAFKA-1796) Sanity check partition command line tools

[ https://issues.apache.org/jira/browse/KAFKA-1796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1796: Fix Version/s: (was: 0.8.3) Sanity check partition command line tools

[jira] [Updated] (KAFKA-1772) Add an Admin message type for request response

[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1772: Fix Version/s: (was: 0.8.3) Add an Admin message type for request response

[jira] [Updated] (KAFKA-1775) Re-factor TopicCommand into thew handerAdminMessage call

[ https://issues.apache.org/jira/browse/KAFKA-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1775: Fix Version/s: (was: 0.8.3) Re-factor TopicCommand into thew handerAdminMessage call

[jira] [Updated] (KAFKA-1786) implement a global configuration feature for brokers

[ https://issues.apache.org/jira/browse/KAFKA-1786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1786: Fix Version/s: (was: 0.8.3) implement a global configuration feature for brokers

[jira] [Updated] (KAFKA-1774) REPL and Shell Client for Admin Message RQ/RP

[ https://issues.apache.org/jira/browse/KAFKA-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1774: Fix Version/s: (was: 0.8.3) REPL and Shell Client for Admin Message RQ/RP

[jira] [Updated] (KAFKA-1777) Re-factor reasign-partitions into CLI

[ https://issues.apache.org/jira/browse/KAFKA-1777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1777: Fix Version/s: (was: 0.8.3) Re-factor reasign-partitions into CLI

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

[ https://issues.apache.org/jira/browse/KAFKA-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1778: Fix Version/s: (was: 0.8.3) Create new re-elect controller admin function

[jira] [Commented] (KAFKA-1683) Implement a session concept in the socket server

[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14705540#comment-14705540 ] Gwen Shapira commented on KAFKA-1683: - I think I'm good, expect a patch by Friday.

[jira] [Updated] (KAFKA-1756) never allow the replica fetch size to be less than the max message size

[ https://issues.apache.org/jira/browse/KAFKA-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1756: Fix Version/s: (was: 0.8.3) never allow the replica fetch size to be less than the max message

[jira] [Commented] (KAFKA-2444) Fail test: kafka.api.QuotasTest testThrottledProducerConsumer FAILED

[ https://issues.apache.org/jira/browse/KAFKA-2444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703183#comment-14703183 ] Gwen Shapira commented on KAFKA-2444: - [~aauradkar] - can you take a look? Fail

[jira] [Updated] (KAFKA-1489) Global threshold on data retention size

[ https://issues.apache.org/jira/browse/KAFKA-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1489: Labels: (was: newbie) Global threshold on data retention size

[jira] [Updated] (KAFKA-1489) Global threshold on data retention size

[ https://issues.apache.org/jira/browse/KAFKA-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1489: Fix Version/s: (was: 0.8.3) Global threshold on data retention size

[jira] [Commented] (KAFKA-934) kafka hadoop consumer and producer use older 0.19.2 hadoop api's

[ https://issues.apache.org/jira/browse/KAFKA-934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703240#comment-14703240 ] Gwen Shapira commented on KAFKA-934: I'm really not sure. I removed it from 0.8.3 since

[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 ] Gwen Shapira updated KAFKA-1904: Fix Version/s: (was: 0.8.3) run sanity failed test --

[jira] [Updated] (KAFKA-1678) add new options for reassign partition to better manager dead brokers

[ https://issues.apache.org/jira/browse/KAFKA-1678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1678: Fix Version/s: (was: 0.8.3) add new options for reassign partition to better manager dead

[jira] [Updated] (KAFKA-1714) more better bootstrapping of the gradle-wrapper.jar

[ https://issues.apache.org/jira/browse/KAFKA-1714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1714: Fix Version/s: (was: 0.8.3) more better bootstrapping of the gradle-wrapper.jar

[jira] [Updated] (KAFKA-1665) controller state gets stuck in message after execute

[ https://issues.apache.org/jira/browse/KAFKA-1665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1665: Fix Version/s: (was: 0.8.3) controller state gets stuck in message after execute

[jira] [Updated] (KAFKA-1659) Ability to cleanly abort the KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1659: Fix Version/s: (was: 0.8.3) Ability to cleanly abort the KafkaProducer

[jira] [Updated] (KAFKA-1675) bootstrapping tidy-up

[ https://issues.apache.org/jira/browse/KAFKA-1675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1675: Fix Version/s: (was: 0.8.3) bootstrapping tidy-up -

[jira] [Updated] (KAFKA-1694) kafka command line and centralized operations

[ https://issues.apache.org/jira/browse/KAFKA-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1694: Fix Version/s: (was: 0.8.3) kafka command line and centralized operations

[jira] [Updated] (KAFKA-1825) leadership election state is stale and never recovers without all brokers restarting

[ https://issues.apache.org/jira/browse/KAFKA-1825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1825: Fix Version/s: (was: 0.8.3) leadership election state is stale and never recovers without all

[jira] [Updated] (KAFKA-686) 0.8 Kafka broker should give a better error message when running against 0.7 zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-686: --- Fix Version/s: (was: 0.8.3) 0.8 Kafka broker should give a better error message when running

[jira] [Updated] (KAFKA-1561) Data Loss for Incremented Replica Factor and Leader Election

[ https://issues.apache.org/jira/browse/KAFKA-1561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1561: Fix Version/s: (was: 0.8.3) Data Loss for Incremented Replica Factor and Leader Election

[jira] [Updated] (KAFKA-2218) reassignment tool needs to parse and validate the json

[ https://issues.apache.org/jira/browse/KAFKA-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2218: Fix Version/s: (was: 0.8.3) reassignment tool needs to parse and validate the json

[jira] [Updated] (KAFKA-2219) reassign partition fails with offset 0 being asked for but obviously not there

[ https://issues.apache.org/jira/browse/KAFKA-2219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2219: Fix Version/s: (was: 0.8.3) reassign partition fails with offset 0 being asked for but

<    3   4   5   6   7   8   9   10   11   12   >