[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

2018-08-21 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16588173#comment-16588173 ] Jason Gustafson commented on KAFKA-7190: [~lambdaliu] Yeah, I think maintaining t

[jira] [Resolved] (KAFKA-5891) Cast transformation fails if record schema contains timestamp field

2018-08-20 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5891. Resolution: Fixed Fix Version/s: 2.0.1 1.1.2 1.

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

2018-08-20 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586359#comment-16586359 ] Jason Gustafson commented on KAFKA-7190: Posted a KIP here: https://cwiki.apache

[jira] [Resolved] (KAFKA-7278) replaceSegments() should not call asyncDeleteSegment() for segments which have been removed from segments list

2018-08-20 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7278. Resolution: Fixed Fix Version/s: 2.0.1 > replaceSegments() should not call asyncDele

[jira] [Resolved] (KAFKA-7298) Concurrent DeleteRecords can lead to fatal OutOfSequence error in producer

2018-08-20 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7298. Resolution: Fixed Fix Version/s: 2.0.1 > Concurrent DeleteRecords can lead to fatal

[jira] [Comment Edited] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

2018-08-17 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16584462#comment-16584462 ] Jason Gustafson edited comment on KAFKA-7190 at 8/17/18 11:09 PM: -

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

2018-08-17 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16584462#comment-16584462 ] Jason Gustafson commented on KAFKA-7190: Sorry, this will be lengthy comment beca

[jira] [Resolved] (KAFKA-7296) Producer should handle COORDINATOR_LOADING error in TxnOffsetCommit

2018-08-16 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7296. Resolution: Fixed > Producer should handle COORDINATOR_LOADING error in TxnOffsetCommit > -

[jira] [Created] (KAFKA-7298) Concurrent DeleteRecords can lead to fatal OutOfSequence error in producer

2018-08-15 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-7298: -- Summary: Concurrent DeleteRecords can lead to fatal OutOfSequence error in producer Key: KAFKA-7298 URL: https://issues.apache.org/jira/browse/KAFKA-7298 Project:

[jira] [Updated] (KAFKA-7296) Producer should handle COORDINATOR_LOADING error in TxnOffsetCommit

2018-08-15 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7296: --- Summary: Producer should handle COORDINATOR_LOADING error in TxnOffsetCommit (was: Producer

[jira] [Created] (KAFKA-7296) Producer should handler COORDINATOR_LOADING error in TxnOffsetCommit

2018-08-15 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-7296: -- Summary: Producer should handler COORDINATOR_LOADING error in TxnOffsetCommit Key: KAFKA-7296 URL: https://issues.apache.org/jira/browse/KAFKA-7296 Project: Kafka

[jira] [Updated] (KAFKA-7164) Follower should truncate after every leader epoch change

2018-08-12 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7164: --- Fix Version/s: (was: 1.1.2) > Follower should truncate after every leader epoch change >

[jira] [Resolved] (KAFKA-7164) Follower should truncate after every leader epoch change

2018-08-12 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7164. Resolution: Fixed Fix Version/s: 2.1.0 2.0.1 1.

[jira] [Resolved] (KAFKA-7140) Remove deprecated poll usages

2018-08-10 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7140. Resolution: Fixed > Remove deprecated poll usages > - > >

[jira] [Resolved] (KAFKA-6751) Make max.connections.per.ip.overrides a dynamic config

2018-08-09 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6751. Resolution: Fixed > Make max.connections.per.ip.overrides a dynamic config > --

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

2018-08-07 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16572763#comment-16572763 ] Jason Gustafson commented on KAFKA-7190: This is a tough one. To guarantee transa

[jira] [Created] (KAFKA-7234) Allow auto leader rebalance during partition reassignment

2018-08-01 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-7234: -- Summary: Allow auto leader rebalance during partition reassignment Key: KAFKA-7234 URL: https://issues.apache.org/jira/browse/KAFKA-7234 Project: Kafka I

[jira] [Commented] (KAFKA-7231) NetworkClient.newClientRequest() ignores custom request timeout in favor of the default

2018-08-01 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565964#comment-16565964 ] Jason Gustafson commented on KAFKA-7231: Ouch. I think the only place we use this

[jira] [Assigned] (KAFKA-7231) NetworkClient.newClientRequest() ignores custom request timeout in favor of the default

2018-08-01 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-7231: -- Assignee: Jason Gustafson > NetworkClient.newClientRequest() ignores custom request ti

[jira] [Commented] (KAFKA-6014) new consumer mirror maker halts after committing offsets to a deleted topic

2018-07-26 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16558706#comment-16558706 ] Jason Gustafson commented on KAFKA-6014: [~felixgv] It's a good question. In the

[jira] [Created] (KAFKA-7211) MM should handle timeouts in commitSync

2018-07-26 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-7211: -- Summary: MM should handle timeouts in commitSync Key: KAFKA-7211 URL: https://issues.apache.org/jira/browse/KAFKA-7211 Project: Kafka Issue Type: Improve

[jira] [Resolved] (KAFKA-6014) new consumer mirror maker halts after committing offsets to a deleted topic

2018-07-25 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6014. Resolution: Resolved We changed the behavior of the consumer in KAFKA-6829 so that unknown

[jira] [Assigned] (KAFKA-6635) Producer close does not await pending transaction

2018-07-25 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-6635: -- Assignee: (was: Jason Gustafson) > Producer close does not await pending transacti

[jira] [Resolved] (KAFKA-4994) Fix findbugs warning about OffsetStorageWriter#currentFlushId

2018-07-18 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4994. Resolution: Fixed Fix Version/s: 2.1.0 > Fix findbugs warning about OffsetStorageWri

[jira] [Commented] (KAFKA-7128) Lagging high watermark can lead to committed data loss after ISR expansion

2018-07-18 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16548600#comment-16548600 ] Jason Gustafson commented on KAFKA-7128: Yes, go ahead. Sorry, I assigned myself

[jira] [Resolved] (KAFKA-7170) NPE in ConsumerGroupCommand when describe consumer group

2018-07-17 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7170. Resolution: Duplicate Resolving as duplicate. Please continue discussion in KAFKA-7044 if n

[jira] [Commented] (KAFKA-7171) KafkaPerformanceProducer crashes with same transaction id.

2018-07-17 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16547095#comment-16547095 ] Jason Gustafson commented on KAFKA-7171: What is the client version? The exceptio

[jira] [Created] (KAFKA-7173) Update BrokerApiVersionsCommand to use new AdminClient

2018-07-17 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-7173: -- Summary: Update BrokerApiVersionsCommand to use new AdminClient Key: KAFKA-7173 URL: https://issues.apache.org/jira/browse/KAFKA-7173 Project: Kafka Issu

[jira] [Assigned] (KAFKA-7164) Follower should truncate after every leader epoch change

2018-07-16 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-7164: -- Assignee: (was: Jason Gustafson) > Follower should truncate after every leader epo

[jira] [Updated] (KAFKA-7164) Follower should truncate after every leader epoch change

2018-07-14 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7164: --- Description: Currently we skip log truncation for followers if a LeaderAndIsr request is rec

[jira] [Created] (KAFKA-7164) Follower should truncate after every leader epoch change

2018-07-14 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-7164: -- Summary: Follower should truncate after every leader epoch change Key: KAFKA-7164 URL: https://issues.apache.org/jira/browse/KAFKA-7164 Project: Kafka Is

[jira] [Updated] (KAFKA-6292) KafkaConsumer ran into Unknown error fetching data for topic-partition caused by integer overflow in FileLogInputStream

2018-07-06 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6292: --- Fix Version/s: 1.1.2 1.0.3 > KafkaConsumer ran into Unknown error fetching

[jira] [Resolved] (KAFKA-7130) EOFException after rolling log segment

2018-07-06 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7130. Resolution: Duplicate > EOFException after rolling log segment > --

[jira] [Commented] (KAFKA-7130) EOFException after rolling log segment

2018-07-06 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535439#comment-16535439 ] Jason Gustafson commented on KAFKA-7130: Yeah, this looks like it was fixed by KA

[jira] [Commented] (KAFKA-7130) EOFException after rolling log segment

2018-07-03 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16532029#comment-16532029 ] Jason Gustafson commented on KAFKA-7130: Also it would be helpful if you include

[jira] [Comment Edited] (KAFKA-7130) EOFException after rolling log segment

2018-07-03 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16532024#comment-16532024 ] Jason Gustafson edited comment on KAFKA-7130 at 7/3/18 10:31 PM: --

[jira] [Commented] (KAFKA-7130) EOFException after rolling log segment

2018-07-03 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16532024#comment-16532024 ] Jason Gustafson commented on KAFKA-7130: I agree the position suggests an overflo

[jira] [Resolved] (KAFKA-2933) Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment

2018-07-03 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2933. Resolution: Cannot Reproduce It's been a long time since we've seen this, so I will close.

[jira] [Created] (KAFKA-7128) Lagging high watermark can lead to committed data loss after ISR expansion

2018-07-02 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-7128: -- Summary: Lagging high watermark can lead to committed data loss after ISR expansion Key: KAFKA-7128 URL: https://issues.apache.org/jira/browse/KAFKA-7128 Project:

[jira] [Commented] (KAFKA-7028) super.users doesn't work with custom principals

2018-06-28 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16526922#comment-16526922 ] Jason Gustafson commented on KAFKA-7028: >From KIP-189, the intention was to alwa

[jira] [Resolved] (KAFKA-7091) AdminClient should handle FindCoordinatorResponse errors

2018-06-27 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7091. Resolution: Fixed > AdminClient should handle FindCoordinatorResponse errors >

[jira] [Commented] (KAFKA-7095) Low traffic consumer is not consuming messages after the offsets is deleted by Kafka

2018-06-26 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524432#comment-16524432 ] Jason Gustafson commented on KAFKA-7095: The easy thing to do is increase the off

[jira] [Commented] (KAFKA-7089) Extend `kafka-consumer-groups.sh` to show "beginning offsets"

2018-06-25 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16522556#comment-16522556 ] Jason Gustafson commented on KAFKA-7089: Yeah, I think we should have a short KIP

[jira] [Commented] (KAFKA-7092) Multiple topics (including __consumer_offsets) have not been cleaned for a few months

2018-06-25 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16522545#comment-16522545 ] Jason Gustafson commented on KAFKA-7092: Yes, you are probably hitting one of tho

[jira] [Commented] (KAFKA-7095) Low traffic consumer is not consuming messages after the offsets is deleted by Kafka

2018-06-25 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16522504#comment-16522504 ] Jason Gustafson commented on KAFKA-7095: See [KIP-211|https://cwiki.apache.org/c

[jira] [Resolved] (KAFKA-7067) ConnectRestApiTest fails assertion

2018-06-18 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7067. Resolution: Fixed > ConnectRestApiTest fails assertion > --

[jira] [Updated] (KAFKA-6975) AdminClient.deleteRecords() may cause replicas unable to fetch from beginning

2018-06-14 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6975: --- Fix Version/s: 1.1.1 > AdminClient.deleteRecords() may cause replicas unable to fetch from be

[jira] [Resolved] (KAFKA-6975) AdminClient.deleteRecords() may cause replicas unable to fetch from beginning

2018-06-14 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6975. Resolution: Fixed Fix Version/s: (was: 1.1.1) (was: 1.0.2)

[jira] [Resolved] (KAFKA-7050) Decrease consumer request timeout to 30s

2018-06-13 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7050. Resolution: Fixed > Decrease consumer request timeout to 30s >

[jira] [Updated] (KAFKA-7050) Decrease consumer request timeout to 30s

2018-06-12 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7050: --- Fix Version/s: 2.0.0 > Decrease consumer request timeout to 30s > ---

[jira] [Created] (KAFKA-7050) Decrease consumer request timeout to 30s

2018-06-12 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-7050: -- Summary: Decrease consumer request timeout to 30s Key: KAFKA-7050 URL: https://issues.apache.org/jira/browse/KAFKA-7050 Project: Kafka Issue Type: Improv

[jira] [Comment Edited] (KAFKA-6994) KafkaConsumer.poll throwing AuthorizationException timeout-dependent

2018-06-05 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16502631#comment-16502631 ] Jason Gustafson edited comment on KAFKA-6994 at 6/5/18 11:08 PM: --

[jira] [Commented] (KAFKA-6994) KafkaConsumer.poll throwing AuthorizationException timeout-dependent

2018-06-05 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16502631#comment-16502631 ] Jason Gustafson commented on KAFKA-6994: Yes, the consumer does not block to awai

[jira] [Comment Edited] (KAFKA-6994) KafkaConsumer.poll throwing AuthorizationException timeout-dependent

2018-06-05 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16502631#comment-16502631 ] Jason Gustafson edited comment on KAFKA-6994 at 6/5/18 11:08 PM: --

[jira] [Resolved] (KAFKA-6743) ConsumerPerformance fails to consume all messages on topics with large number of partitions

2018-06-02 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6743. Resolution: Fixed Fix Version/s: 2.0.0 > ConsumerPerformance fails to consume all me

[jira] [Updated] (KAFKA-6979) Add max.block.ms to consumer for default timeout behavior

2018-05-31 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6979: --- Component/s: consumer > Add max.block.ms to consumer for default timeout behavior > -

[jira] [Assigned] (KAFKA-6979) Add max.block.ms to consumer for default timeout behavior

2018-05-31 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-6979: -- Assignee: Dhruvil Shah (was: Jason Gustafson) > Add max.block.ms to consumer for defa

[jira] [Updated] (KAFKA-6979) Add max.block.ms to consumer for default timeout behavior

2018-05-31 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6979: --- Summary: Add max.block.ms to consumer for default timeout behavior (was: Add max.block.ms to

[jira] [Created] (KAFKA-6979) Add max.block.ms to consumer for default behavior

2018-05-31 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-6979: -- Summary: Add max.block.ms to consumer for default behavior Key: KAFKA-6979 URL: https://issues.apache.org/jira/browse/KAFKA-6979 Project: Kafka Issue Typ

[jira] [Resolved] (KAFKA-3834) Consumer should not block in poll on coordinator discovery

2018-05-30 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3834. Resolution: Fixed Fix Version/s: 2.0.0 Fixed by KIP-266 > Consumer should not block

[jira] [Resolved] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers

2018-05-30 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5065. Resolution: Fixed Fixed by KIP-266 > AbstractCoordinator.ensureCoordinatorReady() stuck in

[jira] [Resolved] (KAFKA-1894) Avoid long or infinite blocking in the consumer

2018-05-30 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-1894. Resolution: Fixed Fixed by KIP-266 (and many subsequent changes which gradually introduced

[jira] [Resolved] (KAFKA-2391) Blocking call such as position(), partitionsFor(), committed() and listTopics() should have a timeout

2018-05-30 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2391. Resolution: Fixed Fix Version/s: 2.0.0 Fixed by KIP-266 > Blocking call such as pos

[jira] [Resolved] (KAFKA-4879) KafkaConsumer.position may hang forever when deleting a topic

2018-05-30 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4879. Resolution: Fixed This is addressed by KIP-266. > KafkaConsumer.position may hang forever

[jira] [Resolved] (KAFKA-6608) Add TimeoutException to KafkaConsumer#position()

2018-05-30 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6608. Resolution: Fixed Fix Version/s: 2.0.0 > Add TimeoutException to KafkaConsumer#posit

[jira] [Resolved] (KAFKA-6916) AdminClient does not refresh metadata on broker failure

2018-05-29 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6916. Resolution: Fixed > AdminClient does not refresh metadata on broker failure > -

[jira] [Resolved] (KAFKA-5697) StreamThread.shutdown() need to interrupt the stream threads to break the loop

2018-05-26 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5697. Resolution: Fixed Fix Version/s: 2.0.0 > StreamThread.shutdown() need to interrupt th

[jira] [Resolved] (KAFKA-2951) Additional authorization test cases

2018-05-25 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2951. Resolution: Fixed Fix Version/s: 2.0.0 > Additional authorization test cases > --

[jira] [Commented] (KAFKA-6949) NoSuchElementException in ReplicaManager

2018-05-25 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16490869#comment-16490869 ] Jason Gustafson commented on KAFKA-6949: [~lindong] If you have time, can you take

[jira] [Created] (KAFKA-6949) NoSuchElementException in ReplicaManager

2018-05-25 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-6949: -- Summary: NoSuchElementException in ReplicaManager Key: KAFKA-6949 URL: https://issues.apache.org/jira/browse/KAFKA-6949 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-2061) Offer a --version flag to print the kafka version

2018-05-25 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2061. Resolution: Fixed Fix Version/s: 2.0.0 > Offer a --version flag to print the kafka ve

[jira] [Resolved] (KAFKA-6911) Incorrect check for keystore/truststore dynamic update

2018-05-24 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6911. Resolution: Fixed > Incorrect check for keystore/truststore dynamic update > ---

[jira] [Updated] (KAFKA-6868) BufferUnderflowException in client when querying consumer group information

2018-05-21 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6868: --- Affects Version/s: (was: 2.0.0) > BufferUnderflowException in client when querying consume

[jira] [Updated] (KAFKA-6868) BufferUnderflowException in client when querying consumer group information

2018-05-21 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6868: --- Fix Version/s: (was: 2.0.0) > BufferUnderflowException in client when querying consumer gr

[jira] [Commented] (KAFKA-6873) Broker is not returning data including requested offset

2018-05-21 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16482623#comment-16482623 ] Jason Gustafson commented on KAFKA-6873: If a fetch offset lands in the middle of

[jira] [Updated] (KAFKA-6917) Request handler deadlocks attempting to acquire group metadata lock

2018-05-18 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6917: --- Fix Version/s: 0.11.0.3 > Request handler deadlocks attempting to acquire group metadata lock

[jira] [Resolved] (KAFKA-6917) Request handler deadlocks attempting to acquire group metadata lock

2018-05-18 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6917. Resolution: Fixed > Request handler deadlocks attempting to acquire group metadata lock > --

[jira] [Assigned] (KAFKA-1543) Changing replication factor

2018-05-16 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-1543: -- Assignee: (was: Alexander Pakulov) > Changing replication factor >

[jira] [Resolved] (KAFKA-6394) Prevent misconfiguration of advertised listeners

2018-05-11 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6394. Resolution: Fixed Fix Version/s: 2.0.0 > Prevent misconfiguration of advertised liste

[jira] [Commented] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

2018-05-11 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16472117#comment-16472117 ] Jason Gustafson commented on KAFKA-6884: Thanks [~asasvari]. I think the assignmen

[jira] [Assigned] (KAFKA-6868) BufferUnderflowException in client when querying consumer group information

2018-05-10 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-6868: -- Assignee: Colin P. McCabe > BufferUnderflowException in client when querying consumer g

[jira] [Updated] (KAFKA-6868) BufferUnderflowException in client when querying consumer group information

2018-05-10 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6868: --- Priority: Blocker (was: Major) > BufferUnderflowException in client when querying consumer gr

[jira] [Resolved] (KAFKA-6893) Processors created after acceptor started which can cause in a brief refusal to accept connections

2018-05-10 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6893. Resolution: Fixed Fix Version/s: 1.1.1 > Processors created after acceptor started wh

[jira] [Commented] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

2018-05-10 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16470728#comment-16470728 ] Jason Gustafson commented on KAFKA-6884: [~asasvari] Yes, you are right. [~cmccabe

[jira] [Resolved] (KAFKA-6299) Fix AdminClient error handling when metadata changes

2018-05-09 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6299. Resolution: Fixed Fix Version/s: 2.0.0 > Fix AdminClient error handling when metadata

[jira] [Commented] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

2018-05-09 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469197#comment-16469197 ] Jason Gustafson commented on KAFKA-6884: [~asasvari] Thanks for picking this up! Y

[jira] [Resolved] (KAFKA-6292) KafkaConsumer ran into Unknown error fetching data for topic-partition caused by integer overflow in FileLogInputStream

2018-05-08 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6292. Resolution: Fixed > KafkaConsumer ran into Unknown error fetching data for topic-partition c

[jira] [Created] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

2018-05-08 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-6884: -- Summary: ConsumerGroupCommand should use new AdminClient Key: KAFKA-6884 URL: https://issues.apache.org/jira/browse/KAFKA-6884 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-6880) Zombie replicas must be fenced

2018-05-07 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6880: --- Description: Let's say we have three replicas for a partition: 1, 2 ,and 3. In epoch 0, broke

[jira] [Updated] (KAFKA-6880) Zombie replicas must be fenced

2018-05-07 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6880: --- Description: Let's say we have three replicas for a partition: 1, 2 ,and 3. In epoch 0, broke

[jira] [Created] (KAFKA-6880) Zombie replicas must be fenced

2018-05-07 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-6880: -- Summary: Zombie replicas must be fenced Key: KAFKA-6880 URL: https://issues.apache.org/jira/browse/KAFKA-6880 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-6879) Controller deadlock following session expiration

2018-05-07 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6879: --- Description: We have observed an apparent deadlock situation which occurs following a session

[jira] [Created] (KAFKA-6879) Controller deadlock following session expiration

2018-05-07 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-6879: -- Summary: Controller deadlock following session expiration Key: KAFKA-6879 URL: https://issues.apache.org/jira/browse/KAFKA-6879 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-6867) Typos in upgrade.html

2018-05-04 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6867. Resolution: Fixed > Typos in upgrade.html > - > > Key: K

[jira] [Resolved] (KAFKA-6857) LeaderEpochFileCache.endOffsetFor() should check for UNDEFINED_EPOCH explicitly

2018-05-04 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6857. Resolution: Fixed Fix Version/s: 1.1.1 1.0.2 2.0

[jira] [Resolved] (KAFKA-6854) Log cleaner fails with transaction markers that are deleted during clean

2018-05-03 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6854. Resolution: Fixed > Log cleaner fails with transaction markers that are deleted during clean

[jira] [Commented] (KAFKA-6774) Improve default groupId behavior in consumer

2018-04-30 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16459266#comment-16459266 ] Jason Gustafson commented on KAFKA-6774: [~vahid] The suggestion here would be to

[jira] [Resolved] (KAFKA-6810) Enable dynamic reconfiguration of SSL truststores

2018-04-30 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6810. Resolution: Fixed > Enable dynamic reconfiguration of SSL truststores >

[jira] [Resolved] (KAFKA-6778) DescribeConfigs does not return error for non-existent topic

2018-04-26 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6778. Resolution: Fixed Fix Version/s: 2.0.0 > DescribeConfigs does not return error for no

[jira] [Resolved] (KAFKA-3365) Add a documentation field for types and update doc generation

2018-04-18 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3365. Resolution: Fixed > Add a documentation field for types and update doc generation >

<    9   10   11   12   13   14   15   16   17   18   >