[jira] [Created] (KAFKA-5093) Load only batch header when rebuilding producer ID map

Jason Gustafson created KAFKA-5093: -- Summary: Load only batch header when rebuilding producer ID map Key: KAFKA-5093 URL: https://issues.apache.org/jira/browse/KAFKA-5093 Project: Kafka Issu

[jira] [Updated] (KAFKA-5097) KafkaConsumer.poll throws IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-5097: --- Priority: Blocker (was: Critical) > KafkaConsumer.poll throws IllegalStateException > ---

[jira] [Resolved] (KAFKA-5097) KafkaConsumer.poll throws IllegalStateException

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

[jira] [Resolved] (KAFKA-5014) SSL Channel not ready but tcp is established and the server is hung will not sending metadata

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

[jira] [Created] (KAFKA-5106) Improve test coverage for broker CRC validation

Jason Gustafson created KAFKA-5106: -- Summary: Improve test coverage for broker CRC validation Key: KAFKA-5106 URL: https://issues.apache.org/jira/browse/KAFKA-5106 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-5106) Improve test coverage for broker CRC validation

[ https://issues.apache.org/jira/browse/KAFKA-5106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-5106: --- Description: Test cases should ensure that CRC errors are detected across all message formats

[jira] [Created] (KAFKA-5108) Add support for reading PID snapshot files to DumpLogSegments

Jason Gustafson created KAFKA-5108: -- Summary: Add support for reading PID snapshot files to DumpLogSegments Key: KAFKA-5108 URL: https://issues.apache.org/jira/browse/KAFKA-5108 Project: Kafka

[jira] [Commented] (KAFKA-4573) Producer sporadic timeout

[ https://issues.apache.org/jira/browse/KAFKA-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15798862#comment-15798862 ] Jason Gustafson commented on KAFKA-4573: [~maverick2202] Do you know if the under-

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15812429#comment-15812429 ] Jason Gustafson commented on KAFKA-4547: [~vahid] Thanks for looking into this. Th

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15812595#comment-15812595 ] Jason Gustafson commented on KAFKA-4547: I was thinking in addition to your sugges

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=15812595#comment-15812595 ] Jason Gustafson edited comment on KAFKA-4547 at 1/9/17 7:23 PM:

[jira] [Updated] (KAFKA-4426) Add consumer.close(timeout, unit) for graceful close with timeout

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

[jira] [Created] (KAFKA-4622) KafkaConsumer does not properly handle authorization errors from offset fetches

Jason Gustafson created KAFKA-4622: -- Summary: KafkaConsumer does not properly handle authorization errors from offset fetches Key: KAFKA-4622 URL: https://issues.apache.org/jira/browse/KAFKA-4622 Pro

[jira] [Updated] (KAFKA-4622) KafkaConsumer does not properly handle authorization errors from offset fetches

[ https://issues.apache.org/jira/browse/KAFKA-4622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4622: --- Fix Version/s: 0.10.2.0 > KafkaConsumer does not properly handle authorization errors from off

[jira] [Commented] (KAFKA-4622) KafkaConsumer does not properly handle authorization errors from offset fetches

[ https://issues.apache.org/jira/browse/KAFKA-4622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822022#comment-15822022 ] Jason Gustafson commented on KAFKA-4622: [~ewencp] Should be an easy fix, so I was

[jira] [Resolved] (KAFKA-4626) Add consumer close change to upgrade notes

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

[jira] [Updated] (KAFKA-4565) Separation of Internal and External traffic (KIP-103)

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

[jira] [Resolved] (KAFKA-4627) Intermittent test failure in consumer close test

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

[jira] [Updated] (KAFKA-4614) Long GC pause harming broker performance which is caused by mmap objects created for OffsetIndex

[ https://issues.apache.org/jira/browse/KAFKA-4614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4614: --- Fix Version/s: 0.10.2.0 > Long GC pause harming broker performance which is caused by mmap obj

[jira] [Created] (KAFKA-4631) Refresh consumer metadata more frequently for unknown subscribed topics

Jason Gustafson created KAFKA-4631: -- Summary: Refresh consumer metadata more frequently for unknown subscribed topics Key: KAFKA-4631 URL: https://issues.apache.org/jira/browse/KAFKA-4631 Project: Ka

[jira] [Updated] (KAFKA-4631) Refresh consumer metadata more frequently for unknown subscribed topics

[ https://issues.apache.org/jira/browse/KAFKA-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4631: --- Description: By default, the consumer refreshes metadata every 5 minutes. In testing, it can o

[jira] [Updated] (KAFKA-3853) Report offsets for empty groups in ConsumerGroupCommand

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

[jira] [Resolved] (KAFKA-4591) Create Topic Policy

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

[jira] [Commented] (KAFKA-4622) KafkaConsumer does not properly handle authorization errors from offset fetches

[ https://issues.apache.org/jira/browse/KAFKA-4622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823361#comment-15823361 ] Jason Gustafson commented on KAFKA-4622: One correction to the description: Topic

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

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

[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&focusedCommentId=15826790#comment-15826790 ] Jason Gustafson commented on KAFKA-4635: [~ijuma] I think I'm convinced we should

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

[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] [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. > OO

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

[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&focusedCommentId=15832255#comment-15832255 ] Jason Gustafson commented on KAFKA-4676: Logs from the consumer would also be help

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15832295#comment-15832295 ] Jason Gustafson commented on KAFKA-2000: It would be nice to get this fixed. The p

[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&focusedCommentId=15833747#comment-15833747 ] Jason Gustafson commented on KAFKA-4676: Can you provide full consumer logs please

[jira] [Created] (KAFKA-4693) Consumer subscription change during rebalance causes exception

Jason Gustafson created KAFKA-4693: -- Summary: Consumer subscription change during rebalance causes exception Key: KAFKA-4693 URL: https://issues.apache.org/jira/browse/KAFKA-4693 Project: Kafka

[jira] [Updated] (KAFKA-4693) Consumer subscription change during rebalance causes exception

[ https://issues.apache.org/jira/browse/KAFKA-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4693: --- Component/s: consumer > Consumer subscription change during rebalance causes exception > -

[jira] [Commented] (KAFKA-4631) Refresh consumer metadata more frequently for unknown subscribed topics

[ https://issues.apache.org/jira/browse/KAFKA-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838184#comment-15838184 ] Jason Gustafson commented on KAFKA-4631: Perhaps it is not critical since we got K

[jira] [Updated] (KAFKA-4631) Refresh consumer metadata more frequently for unknown subscribed topics

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

[jira] [Updated] (KAFKA-4631) Refresh consumer metadata more frequently for unknown subscribed topics

[ https://issues.apache.org/jira/browse/KAFKA-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4631: --- Component/s: consumer > Refresh consumer metadata more frequently for unknown subscribed topic

[jira] [Updated] (KAFKA-4698) `-target:jvm-1.7` in scalaCompileOptions seems to cause java.lang.VerifyError when loading kafka/client/ClientUtils

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

[jira] [Updated] (KAFKA-4597) Record metadata returned by producer doesn't consider log append time

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

[jira] [Created] (KAFKA-4699) Transient Failure PlaintextConsumerTest.testInterceptros

Jason Gustafson created KAFKA-4699: -- Summary: Transient Failure PlaintextConsumerTest.testInterceptros Key: KAFKA-4699 URL: https://issues.apache.org/jira/browse/KAFKA-4699 Project: Kafka Is

[jira] [Commented] (KAFKA-4699) Transient Failure PlaintextConsumerTest.testInterceptros

[ https://issues.apache.org/jira/browse/KAFKA-4699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15839364#comment-15839364 ] Jason Gustafson commented on KAFKA-4699: Actually, it is an assertion on the behav

[jira] [Updated] (KAFKA-4699) Transient Failure PlaintextConsumerTest.testInterceptros

[ https://issues.apache.org/jira/browse/KAFKA-4699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4699: --- Assignee: Ismael Juma (was: Jason Gustafson) > Transient Failure PlaintextConsumerTest.testIn

[jira] [Resolved] (KAFKA-4699) Transient Failure PlaintextConsumerTest.testInterceptros

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

[jira] [Created] (KAFKA-4704) Group coordinator cache loading fails if groupId is used first for consumer groups and then for simple consumer

Jason Gustafson created KAFKA-4704: -- Summary: Group coordinator cache loading fails if groupId is used first for consumer groups and then for simple consumer Key: KAFKA-4704 URL: https://issues.apache.org/jira/br

[jira] [Created] (KAFKA-4707) Transient failure FetchRequestTest.testBrokerRespectsPartitionsOrderAndSizeLimits

Jason Gustafson created KAFKA-4707: -- Summary: Transient failure FetchRequestTest.testBrokerRespectsPartitionsOrderAndSizeLimits Key: KAFKA-4707 URL: https://issues.apache.org/jira/browse/KAFKA-4707 P

[jira] [Created] (KAFKA-4708) Transient failure in BrokerApiVersionsCommandTest.checkBrokerApiVersionCommandOutput

Jason Gustafson created KAFKA-4708: -- Summary: Transient failure in BrokerApiVersionsCommandTest.checkBrokerApiVersionCommandOutput Key: KAFKA-4708 URL: https://issues.apache.org/jira/browse/KAFKA-4708

[jira] [Commented] (KAFKA-4704) Group coordinator cache loading fails if groupId is used first for consumer groups and then for simple consumer

[ https://issues.apache.org/jira/browse/KAFKA-4704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15843389#comment-15843389 ] Jason Gustafson commented on KAFKA-4704: [~onurkaraman] Interesting point. Unfortu

[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&focusedCommentId=15847751#comment-15847751 ] Jason Gustafson commented on KAFKA-4686: [~rodrigo.saramago] Thanks for the update

[jira] [Created] (KAFKA-4719) Timed out waiting for consumption in OffsetValidationTest.test_broker_failure

Jason Gustafson created KAFKA-4719: -- Summary: Timed out waiting for consumption in OffsetValidationTest.test_broker_failure Key: KAFKA-4719 URL: https://issues.apache.org/jira/browse/KAFKA-4719 Proje

[jira] [Commented] (KAFKA-4689) OffsetValidationTest fails validation with "Current position greater than the total number of consumed records"

[ https://issues.apache.org/jira/browse/KAFKA-4689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15848602#comment-15848602 ] Jason Gustafson commented on KAFKA-4689: Note I created KAFKA-4719 for the Timeout

[jira] [Updated] (KAFKA-4719) Timed out waiting for consumption in OffsetValidationTest.test_broker_failure

[ https://issues.apache.org/jira/browse/KAFKA-4719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4719: --- Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > Timed out waiting for consump

[jira] [Updated] (KAFKA-4728) KafkaConsumer#commitSync should clone its input

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

[jira] [Updated] (KAFKA-4728) KafkaConsumer#commitSync should clone its input

[ https://issues.apache.org/jira/browse/KAFKA-4728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4728: --- Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > KafkaConsumer#commitSync shou

[jira] [Commented] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created

[ https://issues.apache.org/jira/browse/KAFKA-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854712#comment-15854712 ] Jason Gustafson commented on KAFKA-2857: [~vahid] Sounds reasonable. At least we s

[jira] [Commented] (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&focusedCommentId=15854731#comment-15854731 ] Jason Gustafson commented on KAFKA-4739: [~neoeahit] Thanks for the report. Would

[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&focusedCommentId=15854731#comment-15854731 ] Jason Gustafson edited comment on KAFKA-4739 at 2/6/17 9:09 PM:

[jira] [Commented] (KAFKA-4740) Using new consumer API with a Deserializer that throws SerializationException can lead to infinite loop

[ https://issues.apache.org/jira/browse/KAFKA-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854780#comment-15854780 ] Jason Gustafson commented on KAFKA-4740: Thanks for the report. The intention of t

[jira] [Commented] (KAFKA-4740) Using new consumer API with a Deserializer that throws SerializationException can lead to infinite loop

[ https://issues.apache.org/jira/browse/KAFKA-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854791#comment-15854791 ] Jason Gustafson commented on KAFKA-4740: That said, one thing I realized looking a

[jira] [Commented] (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&focusedCommentId=15854894#comment-15854894 ] Jason Gustafson commented on KAFKA-4739: bq. An observation from our side: it look

[jira] [Commented] (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&focusedCommentId=15854923#comment-15854923 ] Jason Gustafson commented on KAFKA-4739: [~wushujames] Sounds a bit different. Not

[jira] [Commented] (KAFKA-4740) Using new consumer API with a Deserializer that throws SerializationException can lead to infinite loop

[ https://issues.apache.org/jira/browse/KAFKA-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854869#comment-15854869 ] Jason Gustafson commented on KAFKA-4740: Yeah, auto-commit is the case I was think

[jira] [Commented] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created

[ https://issues.apache.org/jira/browse/KAFKA-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855034#comment-15855034 ] Jason Gustafson commented on KAFKA-2857: Hmm, I thought we used the admin client f

[jira] [Commented] (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&focusedCommentId=15855098#comment-15855098 ] Jason Gustafson commented on KAFKA-4739: [~sagar8192] Unfortunately, there is no s

[jira] [Commented] (KAFKA-4740) Using new consumer API with a Deserializer that throws SerializationException can lead to infinite loop

[ https://issues.apache.org/jira/browse/KAFKA-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855122#comment-15855122 ] Jason Gustafson commented on KAFKA-4740: That's a good point. We'd have to first r

[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&focusedCommentId=15856379#comment-15856379 ] Jason Gustafson commented on KAFKA-4686: [~rodrigo.saramago] Are there no files wi

[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&focusedCommentId=15856412#comment-15856412 ] Jason Gustafson commented on KAFKA-4686: One additional question: which clients an

[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&focusedCommentId=15856522#comment-15856522 ] Jason Gustafson commented on KAFKA-4686: Can you try using DumpLogSegments on the

[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&focusedCommentId=15856592#comment-15856592 ] Jason Gustafson commented on KAFKA-4686: [~rodrigo.saramago] Thanks for the update

[jira] [Assigned] (KAFKA-4740) Using new consumer API with a Deserializer that throws SerializationException can lead to infinite loop

[ https://issues.apache.org/jira/browse/KAFKA-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-4740: -- Assignee: Sébastien Launay > Using new consumer API with a Deserializer that throws Ser

[jira] [Commented] (KAFKA-4746) Offsets can be committed for the offsets topic

[ https://issues.apache.org/jira/browse/KAFKA-4746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15858659#comment-15858659 ] Jason Gustafson commented on KAFKA-4746: I never thought of someone trying this, b

[jira] [Commented] (KAFKA-4746) Offsets can be committed for the offsets topic

[ https://issues.apache.org/jira/browse/KAFKA-4746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15858753#comment-15858753 ] Jason Gustafson commented on KAFKA-4746: Thanks. I was thinking of cases where you

[jira] [Resolved] (KAFKA-4749) fix join-time-max and sync-time-max MeasurableStat type

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

[jira] [Commented] (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&focusedCommentId=15860768#comment-15860768 ] Jason Gustafson commented on KAFKA-4739: [~neoeahit] Thanks for the update. These

[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&focusedCommentId=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&focusedCommentId=15860815#comment-15860815 ] Jason Gustafson commented on KAFKA-4753: Could scenario 1 be mitigated with a new

[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&focusedCommentId=15861571#comment-15861571 ] Jason Gustafson commented on KAFKA-4753: I guess the background thread unintention

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

Jason Gustafson created KAFKA-4758: -- Summary: Connect WorkerSinkTask is missing checks for NO_TIMESTAMP Key: KAFKA-4758 URL: https://issues.apache.org/jira/browse/KAFKA-4758 Project: Kafka I

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

[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] [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] [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: --- Fix Version/s: 0.10.2.0 > 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: --- 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: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull requ

[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&focusedCommentId=15866212#comment-15866212 ] Jason Gustafson commented on KAFKA-4159: [~sjdurfey] I've added you as a contribut

[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&focusedCommentId=15870458#comment-15870458 ] Jason Gustafson commented on KAFKA-4686: [~Ormod] Thanks. Do you recall if the top

[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&focusedCommentId=15870806#comment-15870806 ] Jason Gustafson commented on KAFKA-4686: I'm at a loss how this can happen. I trie

[jira] [Created] (KAFKA-4776) Implement graceful handling for improperly formed compressed message sets

Jason Gustafson created KAFKA-4776: -- Summary: Implement graceful handling for improperly formed compressed message sets Key: KAFKA-4776 URL: https://issues.apache.org/jira/browse/KAFKA-4776 Project:

[jira] [Resolved] (KAFKA-4777) Kafka client Heartbeat thread use all the cpu.

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

[jira] [Resolved] (KAFKA-4776) Implement graceful handling for improperly formed compressed message sets

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

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15876517#comment-15876517 ] Jason Gustafson commented on KAFKA-1935: I think this issue is poorly named. The c

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15876596#comment-15876596 ] Jason Gustafson commented on KAFKA-1935: NetworkClient already allows multiple in-

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15879020#comment-15879020 ] Jason Gustafson commented on KAFKA-1895: [~original-brownbear] How would you propo

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=15879020#comment-15879020 ] Jason Gustafson edited comment on KAFKA-1895 at 2/22/17 7:27 PM: ---

[jira] [Resolved] (KAFKA-4786) Transient test failure: ConsumerCoordinatorTest.testHeartbeatThreadClose

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

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15879418#comment-15879418 ] Jason Gustafson commented on KAFKA-1895: It's an interesting idea, but it's also a

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15879483#comment-15879483 ] Jason Gustafson commented on KAFKA-1895: I don't know, supporting two deserializer

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