[jira] [Created] (KAFKA-2409) Have KafkaConsumer.committed() return null when there is no committed offset

Jason Gustafson created KAFKA-2409: -- Summary: Have KafkaConsumer.committed() return null when there is no committed offset Key: KAFKA-2409 URL: https://issues.apache.org/jira/browse/KAFKA-2409 Projec

[jira] [Updated] (KAFKA-2409) Have KafkaConsumer.committed() return null when there is no committed offset

[ https://issues.apache.org/jira/browse/KAFKA-2409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2409: --- Issue Type: Sub-task (was: Improvement) Parent: KAFKA-2387 > Have KafkaConsumer.commi

[jira] [Commented] (KAFKA-2397) leave group request

[ https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14659275#comment-14659275 ] Jason Gustafson commented on KAFKA-2397: [~jkreps] I think the disconnect approach

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

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660241#comment-14660241 ] Jason Gustafson commented on KAFKA-2120: [~mgharat] It occurred to me that the glo

[jira] [Commented] (KAFKA-2397) leave group request

[ https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660269#comment-14660269 ] Jason Gustafson commented on KAFKA-2397: [~jkreps] Yeah, TCP is pretty resilient t

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

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660303#comment-14660303 ] Jason Gustafson commented on KAFKA-2120: [~mgharat] Yeah, that's what I mean. I th

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

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660329#comment-14660329 ] Jason Gustafson commented on KAFKA-2120: [~mgharat] Sounds reasonable to me. Thank

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

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660405#comment-14660405 ] Jason Gustafson commented on KAFKA-2120: [~becket_qin] That is what I was thinking

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

[ https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660717#comment-14660717 ] Jason Gustafson commented on KAFKA-1893: Ditto what [~onurkaraman] said. I think t

[jira] [Commented] (KAFKA-2400) Expose heartbeat frequency in new consumer configuration

[ https://issues.apache.org/jira/browse/KAFKA-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660903#comment-14660903 ] Jason Gustafson commented on KAFKA-2400: [~onurkaraman] The goal of the ticket was

[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-tabpanel&focusedCommentId=14660911#comment-14660911 ] Jason Gustafson commented on KAFKA-2403: No hurry to get this checked in, but I th

[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 ] Jason Gustafson updated KAFKA-2403: --- Status: Patch Available (was: Open) > Expose offset commit metadata in new consumer > ---

[jira] [Commented] (KAFKA-2400) Expose heartbeat frequency in new consumer configuration

[ https://issues.apache.org/jira/browse/KAFKA-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660950#comment-14660950 ] Jason Gustafson commented on KAFKA-2400: [~onurkaraman], [~guozhang] One related p

[jira] [Commented] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661135#comment-14661135 ] Jason Gustafson commented on KAFKA-2413: [~onurkaraman] I was able to reproduce th

[jira] [Commented] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661160#comment-14661160 ] Jason Gustafson commented on KAFKA-2413: I think the issue is in here: {code} p

[jira] [Comment Edited] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661160#comment-14661160 ] Jason Gustafson edited comment on KAFKA-2413 at 8/7/15 1:20 AM:

[jira] [Commented] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661167#comment-14661167 ] Jason Gustafson commented on KAFKA-2413: [~singhashish] I can attempt a patch if y

[jira] [Commented] (KAFKA-2389) CommitType seems not necessary in commit().

[ https://issues.apache.org/jira/browse/KAFKA-2389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14662543#comment-14662543 ] Jason Gustafson commented on KAFKA-2389: [~becket_qin] I'm definitely in favor of

[jira] [Commented] (KAFKA-2389) CommitType seems not necessary in commit().

[ https://issues.apache.org/jira/browse/KAFKA-2389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14662572#comment-14662572 ] Jason Gustafson commented on KAFKA-2389: [~gwenshap] This only reason we've resist

[jira] [Assigned] (KAFKA-2274) Add integration test for consumer coordinator

[ https://issues.apache.org/jira/browse/KAFKA-2274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2274: -- Assignee: Jason Gustafson > Add integration test for consumer coordinator > ---

[jira] [Commented] (KAFKA-2388) subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.

[ https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14695608#comment-14695608 ] Jason Gustafson commented on KAFKA-2388: [~onurkaraman] Have you had a chance to g

[jira] [Commented] (KAFKA-2388) subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.

[ https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14695877#comment-14695877 ] Jason Gustafson commented on KAFKA-2388: [~onurkaraman] I'll take a shot at it. If

[jira] [Commented] (KAFKA-2397) leave group request

[ https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14696351#comment-14696351 ] Jason Gustafson commented on KAFKA-2397: [~ewencp] The only case I can come up wit

[jira] [Reopened] (KAFKA-1782) Junit3 Misusage

[ https://issues.apache.org/jira/browse/KAFKA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reopened KAFKA-1782: It looks like this patch broke some of the tests (e.g. ConsumerTest). We probably need to go th

[jira] [Assigned] (KAFKA-2388) subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.

[ https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2388: -- Assignee: Jason Gustafson (was: Onur Karaman) > subscribe(topic)/unsubscribe(topic) sh

[jira] [Commented] (KAFKA-2388) subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.

[ https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14697692#comment-14697692 ] Jason Gustafson commented on KAFKA-2388: [~onurkaraman] I submitted a WIP patch fo

[jira] [Work started] (KAFKA-2388) subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.

[ https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2388 started by Jason Gustafson. -- > subscribe(topic)/unsubscribe(topic) should either take a callback to allow

[jira] [Commented] (KAFKA-2092) New partitioning for better load balancing

[ https://issues.apache.org/jira/browse/KAFKA-2092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699763#comment-14699763 ] Jason Gustafson commented on KAFKA-2092: [~gwenshap] [~guozhang] Can either of you

[jira] [Commented] (KAFKA-2389) CommitType seems not necessary in commit().

[ https://issues.apache.org/jira/browse/KAFKA-2389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14708577#comment-14708577 ] Jason Gustafson commented on KAFKA-2389: +1 This suggestion has nice symmetry. Pas

[jira] [Comment Edited] (KAFKA-2389) CommitType seems not necessary in commit().

[ https://issues.apache.org/jira/browse/KAFKA-2389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14708577#comment-14708577 ] Jason Gustafson edited comment on KAFKA-2389 at 8/23/15 10:42 PM: --

[jira] [Commented] (KAFKA-2389) CommitType seems not necessary in commit().

[ https://issues.apache.org/jira/browse/KAFKA-2389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14709631#comment-14709631 ] Jason Gustafson commented on KAFKA-2389: [~ewencp] If I understand correctly, you

[jira] [Created] (KAFKA-2464) Client-side assignment and group generalization

Jason Gustafson created KAFKA-2464: -- Summary: Client-side assignment and group generalization Key: KAFKA-2464 URL: https://issues.apache.org/jira/browse/KAFKA-2464 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-2388) subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.

[ https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14712236#comment-14712236 ] Jason Gustafson commented on KAFKA-2388: [~onurkaraman] I've updated the patch to

[jira] [Commented] (KAFKA-2478) KafkaConsumer javadoc example seems wrong

[ https://issues.apache.org/jira/browse/KAFKA-2478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14714505#comment-14714505 ] Jason Gustafson commented on KAFKA-2478: [~devstr] I agree that the example seems

[jira] [Commented] (KAFKA-2478) KafkaConsumer javadoc example seems wrong

[ https://issues.apache.org/jira/browse/KAFKA-2478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715459#comment-14715459 ] Jason Gustafson commented on KAFKA-2478: [~devstr] Not that I'm aware of. You can

[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-tabpanel&focusedCommentId=14715470#comment-14715470 ] Jason Gustafson commented on KAFKA-1977: Seems like there should be some options f

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

[ https://issues.apache.org/jira/browse/KAFKA-2486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14723607#comment-14723607 ] Jason Gustafson commented on KAFKA-2486: The sleep was intended to implement the f

[jira] [Created] (KAFKA-2491) Update ErrorMapping with New Consumer Errors

Jason Gustafson created KAFKA-2491: -- Summary: Update ErrorMapping with New Consumer Errors Key: KAFKA-2491 URL: https://issues.apache.org/jira/browse/KAFKA-2491 Project: Kafka Issue Type: Su

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

[ https://issues.apache.org/jira/browse/KAFKA-2486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14726063#comment-14726063 ] Jason Gustafson commented on KAFKA-2486: [~jkreps] I've been running the consumer

[jira] [Created] (KAFKA-4032) Uncaught exceptions when autocreating topics

Jason Gustafson created KAFKA-4032: -- Summary: Uncaught exceptions when autocreating topics Key: KAFKA-4032 URL: https://issues.apache.org/jira/browse/KAFKA-4032 Project: Kafka Issue Type: Bu

[jira] [Commented] (KAFKA-3916) Connection from controller to broker disconnects

[ https://issues.apache.org/jira/browse/KAFKA-3916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417813#comment-15417813 ] Jason Gustafson commented on KAFKA-3916: Could we be hitting the idle connection t

[jira] [Created] (KAFKA-4034) Consumer need not lookup coordinator when using manual assignment

Jason Gustafson created KAFKA-4034: -- Summary: Consumer need not lookup coordinator when using manual assignment Key: KAFKA-4034 URL: https://issues.apache.org/jira/browse/KAFKA-4034 Project: Kafka

[jira] [Assigned] (KAFKA-4034) Consumer need not lookup coordinator when using manual assignment

[ https://issues.apache.org/jira/browse/KAFKA-4034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-4034: -- Assignee: Jason Gustafson > Consumer need not lookup coordinator when using manual assi

[jira] [Created] (KAFKA-4036) Unsafe dictionary access in VerifiableConsumer service

Jason Gustafson created KAFKA-4036: -- Summary: Unsafe dictionary access in VerifiableConsumer service Key: KAFKA-4036 URL: https://issues.apache.org/jira/browse/KAFKA-4036 Project: Kafka Issu

[jira] [Created] (KAFKA-4038) Transient failure in DeleteTopicsRequestTest.testErrorDeleteTopicRequests

Jason Gustafson created KAFKA-4038: -- Summary: Transient failure in DeleteTopicsRequestTest.testErrorDeleteTopicRequests Key: KAFKA-4038 URL: https://issues.apache.org/jira/browse/KAFKA-4038 Project:

[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 si

[jira] [Assigned] (KAFKA-3949) Consumer topic subscription change may be ignored if a rebalance is in progress

[ https://issues.apache.org/jira/browse/KAFKA-3949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-3949: -- Assignee: Jason Gustafson > Consumer topic subscription change may be ignored if a reba

[jira] [Commented] (KAFKA-4091) Unable to produce or consume on any topic

[ https://issues.apache.org/jira/browse/KAFKA-4091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15446460#comment-15446460 ] Jason Gustafson commented on KAFKA-4091: [~datawiz...@gmail.com] It seems possible

[jira] [Commented] (KAFKA-156) Messages should not be dropped when brokers are unavailable

[ https://issues.apache.org/jira/browse/KAFKA-156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15446486#comment-15446486 ] Jason Gustafson commented on KAFKA-156: --- [~dpnchl] KAFKA-789 is already resolved as a

[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: Ka

[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&focusedCommentId=15447017#comment-15447017 ] Jason Gustafson commented on KAFKA-4081: I think it definitely makes sense to reje

[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&focusedCommentId=15447337#comment-15447337 ] Jason Gustafson commented on KAFKA-4101: [~andrey-sra] I think this might be fixed

[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&focusedCommentId=15447337#comment-15447337 ] Jason Gustafson edited comment on KAFKA-4101 at 8/29/16 11:03 PM: --

[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] [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&focusedCommentId=15452913#comment-15452913 ] Jason Gustafson commented on KAFKA-4106: [~fhussonnois] I think you might be able

[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 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 test_broker_rol

[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-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 Issue

[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 exi

[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&focusedCommentId=15459966#comment-15459966 ] Jason Gustafson commented on KAFKA-4118: [~guozhang] I have a patch available for

[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] [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 e

[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 Is

[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 Avail

[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 Projec

[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&focusedCommentId=15478521#comment-15478521 ] Jason Gustafson commented on KAFKA-4133: [~mimaison] You should have permission no

[jira] [Resolved] (KAFKA-2901) Extend ListGroups and DescribeGroup APIs to cover offsets

[ https://issues.apache.org/jira/browse/KAFKA-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2901. Resolution: Duplicate Assignee: Jason Gustafson (was: Neha Narkhede) We changed the b

[jira] [Comment Edited] (KAFKA-2901) Extend ListGroups and DescribeGroup APIs to cover offsets

[ https://issues.apache.org/jira/browse/KAFKA-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485727#comment-15485727 ] Jason Gustafson edited comment on KAFKA-2901 at 9/13/16 12:18 AM: --

[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 e

[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 deserializ

[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-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 To

[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 init

[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 TopicM

[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 Ro

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

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

[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 auto.offset.re

[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 separat

[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 rat

[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: 0.10

[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-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 to

[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 ConsumerPerformance.sc

[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 i

[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-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 parti

[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 Behavio

[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-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 and

[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 r

[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: https://cwik

[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 infor

[jira] [Updated] (KAFKA-1088) Ability to create a shadow consumer group

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

[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 > -

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