[jira] [Comment Edited] (KAFKA-4739) KafkaConsumer poll going into an infinite loop

[ https://issues.apache.org/jira/browse/KAFKA-4739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860768#comment-15860768 ] Jason Gustafson edited comment on KAFKA-4739 at 2/10/17 5:48 AM: -

[jira] [Commented] (KAFKA-4753) KafkaConsumer susceptible to FetchResponse starvation

[ https://issues.apache.org/jira/browse/KAFKA-4753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860815#comment-15860815 ] Jason Gustafson commented on KAFKA-4753: Could scenario 1 be mitigated with a new partition

[jira] [Commented] (KAFKA-4159) Allow overriding producer & consumer properties at the connector level

[ https://issues.apache.org/jira/browse/KAFKA-4159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866212#comment-15866212 ] Jason Gustafson commented on KAFKA-4159: [~sjdurfey] I've added you as a contributor. You should

[jira] [Resolved] (KAFKA-4758) Connect WorkerSinkTask is missing checks for NO_TIMESTAMP

[ https://issues.apache.org/jira/browse/KAFKA-4758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4758. Resolution: Fixed Fix Version/s: 0.10.3.0 Issue resolved by pull request 2533

[jira] [Work started] (KAFKA-4761) NullPointerException if batch.size=0 for producer config

[ https://issues.apache.org/jira/browse/KAFKA-4761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4761 started by Jason Gustafson. -- > NullPointerException if batch.size=0 for producer config >

[jira] [Assigned] (KAFKA-4761) NullPointerException if batch.size=0 for producer config

[ https://issues.apache.org/jira/browse/KAFKA-4761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-4761: -- Assignee: Jason Gustafson > NullPointerException if batch.size=0 for producer config >

[jira] [Updated] (KAFKA-4761) NullPointerException if batch.size=0 for producer config

[ https://issues.apache.org/jira/browse/KAFKA-4761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4761: --- Status: Patch Available (was: In Progress) https://github.com/apache/kafka/pull/2545/files

[jira] [Updated] (KAFKA-4761) NullPointerException if batch.size=0 for producer config

[ https://issues.apache.org/jira/browse/KAFKA-4761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4761: --- Priority: Blocker (was: Minor) > NullPointerException if batch.size=0 for producer config >

[jira] [Updated] (KAFKA-4761) NullPointerException if batch.size=0 for producer config

[ https://issues.apache.org/jira/browse/KAFKA-4761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4761: --- Fix Version/s: 0.10.2.0 > NullPointerException if batch.size=0 for producer config >

[jira] [Commented] (KAFKA-4686) Null Message payload is shutting down broker

[ https://issues.apache.org/jira/browse/KAFKA-4686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870458#comment-15870458 ] Jason Gustafson commented on KAFKA-4686: [~Ormod] Thanks. Do you recall if the topic experiencing

[jira] [Resolved] (KAFKA-4456) Offsets of deleted topics are not removed from consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-4456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4456. Resolution: Duplicate This looks like a duplicate of KAFKA-2000, which has a patch

[jira] [Created] (KAFKA-4665) Inconsistent handling of non-existing topics in offset fetch handling

Jason Gustafson created KAFKA-4665: -- Summary: Inconsistent handling of non-existing topics in offset fetch handling Key: KAFKA-4665 URL: https://issues.apache.org/jira/browse/KAFKA-4665 Project:

[jira] [Updated] (KAFKA-3177) Kafka consumer can hang when position() is called on a non-existing partition.

[ https://issues.apache.org/jira/browse/KAFKA-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3177: --- Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > Kafka consumer can hang when

[jira] [Commented] (KAFKA-4635) Client Compatibility follow-up

[ https://issues.apache.org/jira/browse/KAFKA-4635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15826790#comment-15826790 ] Jason Gustafson commented on KAFKA-4635: [~ijuma] I think I'm convinced we should not do #6. The

[jira] [Resolved] (KAFKA-3502) Build is killed during kafka streams tests due to `pure virtual method called` error

[ https://issues.apache.org/jira/browse/KAFKA-3502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3502. Resolution: Fixed Fix Version/s: 0.10.2.0 Issue resolved by pull request 2381

[jira] [Resolved] (KAFKA-4491) OOME when Java client can not connect to brokers

[ https://issues.apache.org/jira/browse/KAFKA-4491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4491. Resolution: Duplicate Resolving this in favor KAFKA-4493, which has a patch available. >

[jira] [Resolved] (KAFKA-4670) Kafka Consumer should validate FetchResponse

[ https://issues.apache.org/jira/browse/KAFKA-4670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4670. Resolution: Duplicate > Kafka Consumer should validate FetchResponse >

[jira] [Updated] (KAFKA-4547) Consumer.position returns incorrect results for Kafka 0.10.1.0 client

[ https://issues.apache.org/jira/browse/KAFKA-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4547: --- Resolution: Fixed Status: Resolved (was: Patch Available) > Consumer.position

[jira] [Commented] (KAFKA-4676) Kafka consumers gets stuck for some partitions

[ https://issues.apache.org/jira/browse/KAFKA-4676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832255#comment-15832255 ] Jason Gustafson commented on KAFKA-4676: Logs from the consumer would also be helpful. Thanks. >

[jira] [Updated] (KAFKA-3117) Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-3117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3117: --- Resolution: Resolved Status: Resolved (was: Patch Available) Marking this resolved

[jira] [Resolved] (KAFKA-1526) Producer performance tool should have an option to enable transactions

[ https://issues.apache.org/jira/browse/KAFKA-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-1526. Resolution: Unresolved This work has been superseded by KIP-98:

[jira] [Resolved] (KAFKA-1525) DumpLogSegments should print transaction IDs

[ https://issues.apache.org/jira/browse/KAFKA-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-1525. Resolution: Unresolved This work has been superseded by KIP-98:

[jira] [Resolved] (KAFKA-1527) SimpleConsumer should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-1527. Resolution: Unresolved This work has been superseded by KIP-98:

[jira] [Resolved] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-1601. Resolution: Unresolved This work has been superseded by KIP-98:

[jira] [Resolved] (KAFKA-1541) Add transactional request definitions to clients package

[ https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-1541. Resolution: Unresolved This work has been superseded by KIP-98:

[jira] [Resolved] (KAFKA-1524) Implement transactional producer

[ https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-1524. Resolution: Unresolved This work has been superseded by KIP-98:

[jira] [Resolved] (KAFKA-1523) Implement transaction manager module

[ https://issues.apache.org/jira/browse/KAFKA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-1523. Resolution: Unresolved This work has been superseded by KIP-98:

[jira] [Resolved] (KAFKA-1604) System Test for Transaction Management

[ https://issues.apache.org/jira/browse/KAFKA-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-1604. Resolution: Unresolved This work has been superseded by KIP-98:

[jira] [Resolved] (KAFKA-1569) Tool for performance and correctness of transactions end-to-end

[ https://issues.apache.org/jira/browse/KAFKA-1569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-1569. Resolution: Unresolved This work has been superseded by KIP-98:

[jira] [Created] (KAFKA-4816) Message format changes for idempotent/transactional producer

Jason Gustafson created KAFKA-4816: -- Summary: Message format changes for idempotent/transactional producer Key: KAFKA-4816 URL: https://issues.apache.org/jira/browse/KAFKA-4816 Project: Kafka

[jira] [Updated] (KAFKA-4817) Implement idempotent producer

[ https://issues.apache.org/jira/browse/KAFKA-4817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4817: --- Summary: Implement idempotent producer (was: Basic idempotent producer implementation) >

[jira] [Created] (KAFKA-4818) Implement transactional producer

Jason Gustafson created KAFKA-4818: -- Summary: Implement transactional producer Key: KAFKA-4818 URL: https://issues.apache.org/jira/browse/KAFKA-4818 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-4815) Idempotent/transactional Producer Checklist (KIP-98)

Jason Gustafson created KAFKA-4815: -- Summary: Idempotent/transactional Producer Checklist (KIP-98) Key: KAFKA-4815 URL: https://issues.apache.org/jira/browse/KAFKA-4815 Project: Kafka Issue

[jira] [Created] (KAFKA-4817) Basic idempotent producer implementation

Jason Gustafson created KAFKA-4817: -- Summary: Basic idempotent producer implementation Key: KAFKA-4817 URL: https://issues.apache.org/jira/browse/KAFKA-4817 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-3807) OffsetValidationTest - transient failure on test_broker_rolling_bounce

[ https://issues.apache.org/jira/browse/KAFKA-3807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-3807: -- Assignee: Jason Gustafson > OffsetValidationTest - transient failure on

[jira] [Created] (KAFKA-4108) Improve DumpLogSegments offsets-decoder output format

Jason Gustafson created KAFKA-4108: -- Summary: Improve DumpLogSegments offsets-decoder output format Key: KAFKA-4108 URL: https://issues.apache.org/jira/browse/KAFKA-4108 Project: Kafka

[jira] [Work started] (KAFKA-3807) OffsetValidationTest - transient failure on test_broker_rolling_bounce

[ https://issues.apache.org/jira/browse/KAFKA-3807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3807 started by Jason Gustafson. -- > OffsetValidationTest - transient failure on test_broker_rolling_bounce >

[jira] [Created] (KAFKA-4107) Support offset reset capability in Kafka Connect

Jason Gustafson created KAFKA-4107: -- Summary: Support offset reset capability in Kafka Connect Key: KAFKA-4107 URL: https://issues.apache.org/jira/browse/KAFKA-4107 Project: Kafka Issue

[jira] [Commented] (KAFKA-4118) StreamsSmokeTest.test_streams started failing since 18 August build

[ https://issues.apache.org/jira/browse/KAFKA-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15459966#comment-15459966 ] Jason Gustafson commented on KAFKA-4118: [~guozhang] I have a patch available for KAFKA-3807 which

[jira] [Created] (KAFKA-4133) Provide a configuration to control consumer max in-flight fetches

Jason Gustafson created KAFKA-4133: -- Summary: Provide a configuration to control consumer max in-flight fetches Key: KAFKA-4133 URL: https://issues.apache.org/jira/browse/KAFKA-4133 Project: Kafka

[jira] [Created] (KAFKA-4135) Inconsistent javadoc for KafkaConsumer.poll behavior when there is no subscription

Jason Gustafson created KAFKA-4135: -- Summary: Inconsistent javadoc for KafkaConsumer.poll behavior when there is no subscription Key: KAFKA-4135 URL: https://issues.apache.org/jira/browse/KAFKA-4135

[jira] [Created] (KAFKA-4137) Refactor multi-threaded consumer for safer network layer access

Jason Gustafson created KAFKA-4137: -- Summary: Refactor multi-threaded consumer for safer network layer access Key: KAFKA-4137 URL: https://issues.apache.org/jira/browse/KAFKA-4137 Project: Kafka

[jira] [Resolved] (KAFKA-4106) Consumer / add configure method to PartitionAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-4106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4106. Resolution: Resolved Assignee: Jason Gustafson The requested functionality already

[jira] [Created] (KAFKA-4098) NetworkClient should not intercept all metadata requests on disconnect

Jason Gustafson created KAFKA-4098: -- Summary: NetworkClient should not intercept all metadata requests on disconnect Key: KAFKA-4098 URL: https://issues.apache.org/jira/browse/KAFKA-4098 Project:

[jira] [Commented] (KAFKA-4101) java.lang.IllegalStateException in org.apache.kafka.common.network.Selector.channelOrFail

[ https://issues.apache.org/jira/browse/KAFKA-4101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15447337#comment-15447337 ] Jason Gustafson commented on KAFKA-4101: [~andrey-sra] I think this might be fixed by KAFKA-3341

[jira] [Comment Edited] (KAFKA-4101) java.lang.IllegalStateException in org.apache.kafka.common.network.Selector.channelOrFail

[ https://issues.apache.org/jira/browse/KAFKA-4101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15447337#comment-15447337 ] Jason Gustafson edited comment on KAFKA-4101 at 8/29/16 11:03 PM: --

[jira] [Commented] (KAFKA-4081) Consumer API consumer new interface commitSyn does not verify the validity of offset

[ https://issues.apache.org/jira/browse/KAFKA-4081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15447017#comment-15447017 ] Jason Gustafson commented on KAFKA-4081: I think it definitely makes sense to reject negative

[jira] [Commented] (KAFKA-4106) Consumer / add configure method to PartitionAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-4106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15452913#comment-15452913 ] Jason Gustafson commented on KAFKA-4106: [~fhussonnois] I think you might be able to do this

[jira] [Assigned] (KAFKA-4103) DumpLogSegments cannot print data from offsets topic

[ https://issues.apache.org/jira/browse/KAFKA-4103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-4103: -- Assignee: Jason Gustafson > DumpLogSegments cannot print data from offsets topic >

[jira] [Updated] (KAFKA-4139) Kafka consumer stuck in ensureCoordinatorReady after broker failure

[ https://issues.apache.org/jira/browse/KAFKA-4139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4139: --- Resolution: Fixed Status: Resolved (was: Patch Available) > Kafka consumer stuck in

[jira] [Resolved] (KAFKA-4172) Fix masked test error in KafkaConsumerTest.testSubscriptionChangesWithAutoCommitEnabled

[ https://issues.apache.org/jira/browse/KAFKA-4172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4172. Resolution: Fixed Issue resolved by pull request 1857

[jira] [Created] (KAFKA-4172) Fix masked test error in KafkaConsumerTest.testSubscriptionChangesWithAutoCommitEnabled

Jason Gustafson created KAFKA-4172: -- Summary: Fix masked test error in KafkaConsumerTest.testSubscriptionChangesWithAutoCommitEnabled Key: KAFKA-4172 URL: https://issues.apache.org/jira/browse/KAFKA-4172

[jira] [Created] (KAFKA-4145) Avoid redundant integration testing in ProducerSendTests

Jason Gustafson created KAFKA-4145: -- Summary: Avoid redundant integration testing in ProducerSendTests Key: KAFKA-4145 URL: https://issues.apache.org/jira/browse/KAFKA-4145 Project: Kafka

[jira] [Commented] (KAFKA-4133) Provide a configuration to control consumer max in-flight fetches

[ https://issues.apache.org/jira/browse/KAFKA-4133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15478521#comment-15478521 ] Jason Gustafson commented on KAFKA-4133: [~mimaison] You should have permission now. > Provide a

[jira] [Created] (KAFKA-4147) Transient failure in ConsumerCoordinatorTest.testAutoCommitDynamicAssignment

Jason Gustafson created KAFKA-4147: -- Summary: Transient failure in ConsumerCoordinatorTest.testAutoCommitDynamicAssignment Key: KAFKA-4147 URL: https://issues.apache.org/jira/browse/KAFKA-4147

[jira] [Updated] (KAFKA-4033) KIP-70: Revise Partition Assignment Semantics on New Consumer's Subscription Change

[ https://issues.apache.org/jira/browse/KAFKA-4033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4033: --- Resolution: Fixed Fix Version/s: 0.10.1.0 Status: Resolved (was: Patch

[jira] [Commented] (KAFKA-3333) Client Partitioner - Round Robin

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15488853#comment-15488853 ] Jason Gustafson commented on KAFKA-: Admittedly, the line may not be totally clear, but we

[jira] [Created] (KAFKA-4160) Consumer onPartitionsRevoked should not be invoked while holding the coordinator lock

Jason Gustafson created KAFKA-4160: -- Summary: Consumer onPartitionsRevoked should not be invoked while holding the coordinator lock Key: KAFKA-4160 URL: https://issues.apache.org/jira/browse/KAFKA-4160

[jira] [Commented] (KAFKA-2307) Drop ConsumerOffsetChecker completely

[ https://issues.apache.org/jira/browse/KAFKA-2307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15488674#comment-15488674 ] Jason Gustafson commented on KAFKA-2307: Sounds good. I'll kick this to the next release then. >

[jira] [Updated] (KAFKA-2307) Drop ConsumerOffsetChecker completely

[ https://issues.apache.org/jira/browse/KAFKA-2307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2307: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Drop ConsumerOffsetChecker

[jira] [Updated] (KAFKA-740) Improve crash-safety of log segment swap

[ https://issues.apache.org/jira/browse/KAFKA-740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-740: -- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Improve crash-safety of log

[jira] [Updated] (KAFKA-3073) KafkaConnect should support regular expression for topics

[ https://issues.apache.org/jira/browse/KAFKA-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3073: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > KafkaConnect should support

[jira] [Updated] (KAFKA-2045) Memory Management on the consumer

[ https://issues.apache.org/jira/browse/KAFKA-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2045: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Memory Management on the

[jira] [Updated] (KAFKA-3478) Finer Stream Flow Control

[ https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3478: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Finer Stream Flow Control >

[jira] [Updated] (KAFKA-2000) Delete consumer offsets from kafka once the topic is deleted

[ https://issues.apache.org/jira/browse/KAFKA-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2000: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Delete consumer offsets from

[jira] [Created] (KAFKA-4155) Remove WorkerGroupMember from Connect

Jason Gustafson created KAFKA-4155: -- Summary: Remove WorkerGroupMember from Connect Key: KAFKA-4155 URL: https://issues.apache.org/jira/browse/KAFKA-4155 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-3543) Allow a variant of transform() which can emit multiple values

[ https://issues.apache.org/jira/browse/KAFKA-3543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3543: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Allow a variant of

[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 ] Jason Gustafson updated KAFKA-2311: --- Resolution: Fixed Status: Resolved (was: Patch Available) > Consumer's

[jira] [Updated] (KAFKA-3590) KafkaConsumer fails with "Messages are rejected since there are fewer in-sync replicas than required." when polling

[ https://issues.apache.org/jira/browse/KAFKA-3590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3590: --- Fix Version/s: 0.10.1.0 > KafkaConsumer fails with "Messages are rejected since there are

[jira] [Updated] (KAFKA-1617) Move Metadata Cache to TopicManager and handling of Offset Request to LogManager

[ https://issues.apache.org/jira/browse/KAFKA-1617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1617: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Move Metadata Cache to

[jira] [Updated] (KAFKA-4005) Add per topic compression ratio in broker and consumer.

[ https://issues.apache.org/jira/browse/KAFKA-4005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4005: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Add per topic compression

[jira] [Resolved] (KAFKA-334) Some tests fail when building on a Windows box

[ https://issues.apache.org/jira/browse/KAFKA-334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-334. --- Resolution: Won't Fix Fix Version/s: (was: 0.10.1.0) Resolving this since it's been

[jira] [Updated] (KAFKA-3701) Expose KafkaStreams metrics in public API

[ https://issues.apache.org/jira/browse/KAFKA-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3701: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Expose KafkaStreams metrics

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

[ https://issues.apache.org/jira/browse/KAFKA-3209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3209: --- Priority: Major (was: Critical) Fix Version/s: (was: 0.10.1.0)

[jira] [Updated] (KAFKA-3297) More optimally balanced partition assignment strategy (new consumer)

[ https://issues.apache.org/jira/browse/KAFKA-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3297: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > More optimally balanced

[jira] [Updated] (KAFKA-3522) Consider adding version information into rocksDB storage format

[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3522: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Consider adding version

[jira] [Updated] (KAFKA-3366) Find a way to auto-generate expected error codes

[ https://issues.apache.org/jira/browse/KAFKA-3366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3366: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Find a way to auto-generate

[jira] [Updated] (KAFKA-1895) Investigate moving deserialization and decompression out of KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-1895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1895: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Investigate moving

[jira] [Updated] (KAFKA-3364) Centrallize doc generation

[ https://issues.apache.org/jira/browse/KAFKA-3364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3364: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Centrallize doc generation >

[jira] [Updated] (KAFKA-853) Allow OffsetFetchRequest to initialize offsets

[ https://issues.apache.org/jira/browse/KAFKA-853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-853: -- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Allow OffsetFetchRequest to

[jira] [Commented] (KAFKA-3333) Client Partitioner - Round Robin

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15485820#comment-15485820 ] Jason Gustafson commented on KAFKA-: I think this change probably calls for a KIP since it's a

[jira] [Updated] (KAFKA-3333) Client Partitioner - Round Robin

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Client Partitioner - Round

[jira] [Updated] (KAFKA-3370) Add options to auto.offset.reset to reset offsets upon initialization only

[ https://issues.apache.org/jira/browse/KAFKA-3370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3370: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Add options to

[jira] [Resolved] (KAFKA-1332) Add functionality to the offsetsBeforeTime() API

[ https://issues.apache.org/jira/browse/KAFKA-1332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-1332. Resolution: Duplicate Assignee: Jason Gustafson Fix Version/s: (was:

[jira] [Updated] (KAFKA-1776) Re-factor out existing tools that have been implemented behind the CLI

[ https://issues.apache.org/jira/browse/KAFKA-1776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1776: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Re-factor out existing tools

[jira] [Updated] (KAFKA-3714) Allow users greater access to register custom streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-3714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3714: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Allow users greater access

[jira] [Updated] (KAFKA-2525) Update ConsumerPerformance.scala to report join group time (new consumer)

[ https://issues.apache.org/jira/browse/KAFKA-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2525: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Update

[jira] [Updated] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

[ https://issues.apache.org/jira/browse/KAFKA-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3596: --- Affects Version/s: (was: 0.10.1.0) 0.10.0.0 Fix Version/s:

[jira] [Updated] (KAFKA-3736) Add http metrics reporter

[ https://issues.apache.org/jira/browse/KAFKA-3736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3736: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Add http metrics reporter >

[jira] [Updated] (KAFKA-2787) Refactor gradle build

[ https://issues.apache.org/jira/browse/KAFKA-2787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2787: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Refactor gradle build >

[jira] [Updated] (KAFKA-2758) Improve Offset Commit Behavior

[ https://issues.apache.org/jira/browse/KAFKA-2758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2758: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Improve Offset Commit

[jira] [Updated] (KAFKA-3203) Add UnknownCodecException and UnknownMagicByteException to error mapping

[ https://issues.apache.org/jira/browse/KAFKA-3203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3203: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Add UnknownCodecException

[jira] [Updated] (KAFKA-1206) allow Kafka to start from a resource negotiator system

[ https://issues.apache.org/jira/browse/KAFKA-1206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1206: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > allow Kafka to start from a

[jira] [Updated] (KAFKA-3575) Use console consumer access topic that does not exist, can not use "Control + C" to exit process

[ https://issues.apache.org/jira/browse/KAFKA-3575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3575: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Use console consumer access

[jira] [Updated] (KAFKA-3677) Add a producer performance tuning tool

[ https://issues.apache.org/jira/browse/KAFKA-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3677: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Add a producer performance

[jira] [Updated] (KAFKA-1704) Add PartitionConfig besides LogConfig

[ https://issues.apache.org/jira/browse/KAFKA-1704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1704: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Add PartitionConfig besides

[jira] [Updated] (KAFKA-566) Add last modified time to the TopicMetadataRequest

[ https://issues.apache.org/jira/browse/KAFKA-566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-566: -- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Add last modified time to the

[jira] [Updated] (KAFKA-1935) Consumer should use a separate socket for Coordinator connection

[ https://issues.apache.org/jira/browse/KAFKA-1935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1935: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > Consumer should use a

[jira] [Updated] (KAFKA-1694) KIP-4: Command line and centralized operations

[ https://issues.apache.org/jira/browse/KAFKA-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-1694: --- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 Description:

[jira] [Updated] (KAFKA-747) RequestChannel re-design

[ https://issues.apache.org/jira/browse/KAFKA-747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-747: -- Fix Version/s: (was: 0.10.1.0) 0.10.2.0 > RequestChannel re-design >

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