[jira] [Created] (KAFKA-7143) Cannot use KafkaConsumer with Kotlin coroutines due to Thread id check

2018-07-09 Thread Raman Gupta (JIRA)
Raman Gupta created KAFKA-7143: -- Summary: Cannot use KafkaConsumer with Kotlin coroutines due to Thread id check Key: KAFKA-7143 URL: https://issues.apache.org/jira/browse/KAFKA-7143 Project: Kafka

[jira] [Updated] (KAFKA-7143) Cannot use KafkaConsumer with Kotlin coroutines due to various issues

2018-07-10 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-7143: --- Summary: Cannot use KafkaConsumer with Kotlin coroutines due to various issues (was: Cannot use

[jira] [Updated] (KAFKA-7143) Cannot use KafkaConsumer with Kotlin coroutines due to various issues

2018-07-10 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-7143: --- Description: I am using a new KafkaConsumer via Kotlin. My application makes use of Kotlin

[jira] [Updated] (KAFKA-7143) Cannot use KafkaConsumer with Kotlin coroutines due to various issues

2018-07-10 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-7143: --- Description: I am using a new KafkaConsumer via Kotlin. My application makes use of Kotlin

[jira] [Updated] (KAFKA-7143) Cannot use KafkaConsumer with Kotlin coroutines due to various issues

2018-07-10 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-7143: --- Description: I am using a new KafkaConsumer via Kotlin. My application makes use of Kotlin

[jira] [Updated] (KAFKA-7143) Cannot use KafkaConsumer with Kotlin coroutines due to various issues

2018-07-10 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-7143: --- Description: I am using a new KafkaConsumer via Kotlin. My application makes use of Kotlin

[jira] [Updated] (KAFKA-7143) Cannot use KafkaConsumer with Kotlin coroutines due to various issues

2018-07-11 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-7143: --- Description: I am using a new KafkaConsumer via Kotlin. My application makes use of Kotlin

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

2018-07-09 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16537264#comment-16537264 ] Raman Gupta commented on KAFKA-4740: Reading through the other linked issues and github pull

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

2018-07-09 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16537274#comment-16537274 ] Raman Gupta commented on KAFKA-4740: I'm still a little confused about how this should work though:

[jira] [Comment Edited] (KAFKA-6817) UnknownProducerIdException when writing messages with old timestamps

2019-05-16 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841464#comment-16841464 ] Raman Gupta edited comment on KAFKA-6817 at 5/16/19 3:30 PM: - Same problem

[jira] [Commented] (KAFKA-6817) UnknownProducerIdException when writing messages with old timestamps

2019-05-16 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841464#comment-16841464 ] Raman Gupta commented on KAFKA-6817: Same problem here, with a stream that is intended to migrate

[jira] [Created] (KAFKA-8650) Streams does not work as expected with auto.offset.reset=none

2019-07-10 Thread Raman Gupta (JIRA)
Raman Gupta created KAFKA-8650: -- Summary: Streams does not work as expected with auto.offset.reset=none Key: KAFKA-8650 URL: https://issues.apache.org/jira/browse/KAFKA-8650 Project: Kafka

[jira] [Updated] (KAFKA-8797) BufferUnderflowException: Error reading field 'version' from consumer

2019-08-13 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8797: --- Affects Version/s: 2.3.0 > BufferUnderflowException: Error reading field 'version' from consumer >

[jira] [Updated] (KAFKA-8797) BufferUnderflowException: Error reading field 'version' from consumer

2019-08-13 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8797: --- Component/s: consumer > BufferUnderflowException: Error reading field 'version' from consumer >

[jira] [Updated] (KAFKA-8789) kafka-console-consumer timeout-ms setting behaves incorrectly with newer client

2019-08-13 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8789: --- Summary: kafka-console-consumer timeout-ms setting behaves incorrectly with newer client (was:

[jira] [Resolved] (KAFKA-8789) kafka-avro-console-consumer works with 2.0.x, but not 2.3.x

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta resolved KAFKA-8789. Resolution: Invalid UPDATE: The error message may be coming from the schema registry, which would

[jira] [Comment Edited] (KAFKA-8789) kafka-avro-console-consumer works with 2.0.x, but not 2.3.x

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905343#comment-16905343 ] Raman Gupta edited comment on KAFKA-8789 at 8/12/19 4:16 PM: - UPDATE: The

[jira] [Comment Edited] (KAFKA-8789) kafka-avro-console-consumer works with 2.0.x, but not 2.3.x

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905343#comment-16905343 ] Raman Gupta edited comment on KAFKA-8789 at 8/12/19 4:16 PM: - UPDATE: The

[jira] [Reopened] (KAFKA-8789) kafka-avro-console-consumer works with 2.0.x, but not 2.3.x

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta reopened KAFKA-8789: > kafka-avro-console-consumer works with 2.0.x, but not 2.3.x >

[jira] [Updated] (KAFKA-8789) kafka-avro-console-consumer works with 2.0.x, but not 2.3.x

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8789: --- Description: I have a topic with about 20,000 events in it. When I run the following tools command

[jira] [Updated] (KAFKA-8789) kafka-console-consumer performance regression

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8789: --- Summary: kafka-console-consumer performance regression (was: kafka-avro-console-consumer works with

[jira] [Comment Edited] (KAFKA-8789) kafka-console-consumer performance regression

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905343#comment-16905343 ] Raman Gupta edited comment on KAFKA-8789 at 8/12/19 7:03 PM: - UPDATE: The

[jira] [Created] (KAFKA-8789) kafka-avro-console-consumer works with confluent 5.0.3, but not 5.3.0

2019-08-12 Thread Raman Gupta (JIRA)
Raman Gupta created KAFKA-8789: -- Summary: kafka-avro-console-consumer works with confluent 5.0.3, but not 5.3.0 Key: KAFKA-8789 URL: https://issues.apache.org/jira/browse/KAFKA-8789 Project: Kafka

[jira] [Updated] (KAFKA-8789) kafka-avro-console-consumer works with 2.0.x, but not 2.3.x

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8789: --- Summary: kafka-avro-console-consumer works with 2.0.x, but not 2.3.x (was:

[jira] [Comment Edited] (KAFKA-8789) kafka-avro-console-consumer works with 2.0.x, but not 2.3.x

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905343#comment-16905343 ] Raman Gupta edited comment on KAFKA-8789 at 8/12/19 5:06 PM: - UPDATE: The

[jira] [Created] (KAFKA-8797) BufferUnderflowException: Error reading field 'version' from consumer

2019-08-13 Thread Raman Gupta (JIRA)
Raman Gupta created KAFKA-8797: -- Summary: BufferUnderflowException: Error reading field 'version' from consumer Key: KAFKA-8797 URL: https://issues.apache.org/jira/browse/KAFKA-8797 Project: Kafka

[jira] [Updated] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-16 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8803: --- Attachment: screenshot-1.png > Stream will not start due to TimeoutException: Timeout expired after

[jira] [Updated] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-16 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8803: --- Description: One streams app is consistently failing at startup with the following exception:

[jira] [Updated] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-16 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8803: --- Description: One streams app is consistently failing at startup with the following exception:

[jira] [Commented] (KAFKA-8766) Allow a custom offset policy for Kafka Streams applications

2019-08-16 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909316#comment-16909316 ] Raman Gupta commented on KAFKA-8766: See KAFKA-8650 for related discussion. > Allow a custom offset

[jira] [Updated] (KAFKA-8793) StickyTaskAssignor throws java.lang.ArithmeticException

2019-08-13 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8793: --- Description: Occassionally when starting a streams consumer that uses the static consumer group

[jira] [Created] (KAFKA-8793) StickyTaskAssignor throws java.lang.ArithmeticException

2019-08-13 Thread Raman Gupta (JIRA)
Raman Gupta created KAFKA-8793: -- Summary: StickyTaskAssignor throws java.lang.ArithmeticException Key: KAFKA-8793 URL: https://issues.apache.org/jira/browse/KAFKA-8793 Project: Kafka Issue

[jira] [Comment Edited] (KAFKA-8789) kafka-console-consumer performance regression

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905510#comment-16905510 ] Raman Gupta edited comment on KAFKA-8789 at 8/12/19 7:23 PM: - I'm reopening

[jira] [Updated] (KAFKA-8789) kafka-console-consumer needs bigger timeout-ms setting in order to work

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8789: --- Summary: kafka-console-consumer needs bigger timeout-ms setting in order to work (was:

[jira] [Comment Edited] (KAFKA-8789) kafka-console-consumer needs bigger timeout-ms setting in order to work

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905510#comment-16905510 ] Raman Gupta edited comment on KAFKA-8789 at 8/12/19 7:49 PM: - I'm reopening

[jira] [Comment Edited] (KAFKA-8789) kafka-console-consumer performance regression

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905510#comment-16905510 ] Raman Gupta edited comment on KAFKA-8789 at 8/12/19 7:22 PM: - I'm reopening

[jira] [Commented] (KAFKA-8789) kafka-console-consumer performance regression

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905510#comment-16905510 ] Raman Gupta commented on KAFKA-8789: I'm reopening this. The problem does not appear to be with the

[jira] [Comment Edited] (KAFKA-8789) kafka-console-consumer timeout-ms setting behaves incorrectly with older client

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905510#comment-16905510 ] Raman Gupta edited comment on KAFKA-8789 at 8/12/19 11:11 PM: -- The problem

[jira] [Issue Comment Deleted] (KAFKA-8789) kafka-console-consumer timeout-ms setting behaves incorrectly with older client

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8789: --- Comment: was deleted (was: And the same behavior for the regular console consumer: {code:java}

[jira] [Comment Edited] (KAFKA-8789) kafka-console-consumer timeout-ms setting behaves incorrectly with older client

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905510#comment-16905510 ] Raman Gupta edited comment on KAFKA-8789 at 8/12/19 11:09 PM: -- I'm reopening

[jira] [Commented] (KAFKA-8789) kafka-console-consumer needs bigger timeout-ms setting in order to work

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905652#comment-16905652 ] Raman Gupta commented on KAFKA-8789: And the same behavior for the regular console consumer:

[jira] [Updated] (KAFKA-8789) kafka-console-consumer timeout-ms setting behaves incorrectly with older client

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8789: --- Description: I have a topic with about 20,000 events in it, running on a Kafka 2.3.0 broker. When I

[jira] [Issue Comment Deleted] (KAFKA-8789) kafka-console-consumer timeout-ms setting behaves incorrectly with older client

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8789: --- Comment: was deleted (was: UPDATE: The error message may be coming from the schema registry, which

[jira] [Updated] (KAFKA-8789) kafka-console-consumer timeout-ms setting behaves incorrectly with older client

2019-08-12 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8789: --- Summary: kafka-console-consumer timeout-ms setting behaves incorrectly with older client (was:

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911022#comment-16911022 ] Raman Gupta commented on KAFKA-8803: [~bbejeck] I have attached the logs of all the broker processes,

[jira] [Updated] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8803: --- Description: One streams app is consistently failing at startup with the following exception:

[jira] [Updated] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8803: --- Attachment: logs.txt.gz > Stream will not start due to TimeoutException: Timeout expired after >

[jira] [Comment Edited] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911022#comment-16911022 ] Raman Gupta edited comment on KAFKA-8803 at 8/20/19 6:07 AM: - [~bbejeck] I

[jira] [Comment Edited] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911022#comment-16911022 ] Raman Gupta edited comment on KAFKA-8803 at 8/20/19 6:06 AM: - [~bbejeck] I

[jira] [Comment Edited] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911022#comment-16911022 ] Raman Gupta edited comment on KAFKA-8803 at 8/20/19 6:06 AM: - [~bbejeck] I

[jira] [Created] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-14 Thread Raman Gupta (JIRA)
Raman Gupta created KAFKA-8803: -- Summary: Stream will not start due to TimeoutException: Timeout expired after 6milliseconds while awaiting InitProducerId Key: KAFKA-8803 URL:

[jira] [Comment Edited] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911420#comment-16911420 ] Raman Gupta edited comment on KAFKA-8803 at 8/20/19 2:43 PM: - You're right, I

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911420#comment-16911420 ] Raman Gupta commented on KAFKA-8803: You're right, I had the incorrect issue reference. I meant issue

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-26 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915946#comment-16915946 ] Raman Gupta commented on KAFKA-8803: [~bbejeck] Any updates on this? The stream still won't start. >

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-30 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16919744#comment-16919744 ] Raman Gupta commented on KAFKA-8803: [~bbejeck] I'll try that but one thing that seems odd to me: why

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-30 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16919838#comment-16919838 ] Raman Gupta commented on KAFKA-8803: Changing the `max.block.ms` configuration did seem to fix the

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-30 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16919877#comment-16919877 ] Raman Gupta commented on KAFKA-8803: [~bbejeck] Hmm, I was just looking over the logs again. I

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-30 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16920004#comment-16920004 ] Raman Gupta commented on KAFKA-8803: [~bbejeck] If you want to close it go ahead, however, I don't

[jira] [Commented] (KAFKA-8793) StickyTaskAssignor throws java.lang.ArithmeticException

2019-08-30 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16920011#comment-16920011 ] Raman Gupta commented on KAFKA-8793: [~guozhang] Unfortunately my logs have rolled over and I don't

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-29 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16918695#comment-16918695 ] Raman Gupta commented on KAFKA-8803: Thanks [~bbejeck]. Currently the stream is in the same state so

[jira] [Updated] (KAFKA-8922) Failed to get end offsets for topic partitions of global store

2019-09-18 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8922: --- Description: I have a Kafka stream that fails with this error on startup every time: {code}

[jira] [Created] (KAFKA-8922) Failed to get end offsets for topic partitions of global store

2019-09-18 Thread Raman Gupta (Jira)
Raman Gupta created KAFKA-8922: -- Summary: Failed to get end offsets for topic partitions of global store Key: KAFKA-8922 URL: https://issues.apache.org/jira/browse/KAFKA-8922 Project: Kafka

[jira] [Updated] (KAFKA-8922) Failed to get end offsets for topic partitions of global store

2019-09-18 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8922: --- Description: I have a Kafka stream that fails with this error on startup every time: {code}

[jira] [Resolved] (KAFKA-8922) Failed to get end offsets for topic partitions of global store

2019-09-18 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta resolved KAFKA-8922. Resolution: Invalid Closing as the error had nothing to do with streams -- just general broker

[jira] [Created] (KAFKA-8773) Static membership protocol borks on re-used group id

2019-08-08 Thread Raman Gupta (JIRA)
Raman Gupta created KAFKA-8773: -- Summary: Static membership protocol borks on re-used group id Key: KAFKA-8773 URL: https://issues.apache.org/jira/browse/KAFKA-8773 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-8773) Static membership protocol borks on re-used group id

2019-08-08 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8773: --- Description: I am using the new static group membership protocol in 2.3.0. I have a situation in

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

2019-07-18 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16888543#comment-16888543 ] Raman Gupta commented on KAFKA-7190: I want to mention another case in which this happened. I'm not

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

2019-07-23 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891537#comment-16891537 ] Raman Gupta commented on KAFKA-7190: [~mjsax] [~guozhang] I want to point out that the behavior I saw

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

2019-07-23 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891537#comment-16891537 ] Raman Gupta edited comment on KAFKA-7190 at 7/24/19 2:30 AM: - [~mjsax]

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

2019-07-24 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891992#comment-16891992 ] Raman Gupta commented on KAFKA-7190: > Did you override message.timestamp.difference.max.ms? No. >

[jira] [Commented] (KAFKA-8650) Streams does not work as expected with auto.offset.reset=none

2019-07-15 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885640#comment-16885640 ] Raman Gupta commented on KAFKA-8650: There is also a related API change / improvement that I believe

[jira] [Created] (KAFKA-8715) Static consumer cannot join group due to ERROR in broker

2019-07-25 Thread Raman Gupta (JIRA)
Raman Gupta created KAFKA-8715: -- Summary: Static consumer cannot join group due to ERROR in broker Key: KAFKA-8715 URL: https://issues.apache.org/jira/browse/KAFKA-8715 Project: Kafka Issue

[jira] [Updated] (KAFKA-8715) Static consumer cannot join group due to ERROR in broker

2019-07-25 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8715: --- Description: A streams consumer using a static group instance id is unable to join the group due to

[jira] [Updated] (KAFKA-8715) Static consumer cannot join group due to ERROR in broker

2019-07-25 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8715: --- Description: A streams consumer using a static group instance id is unable to join the group due to

[jira] [Comment Edited] (KAFKA-8715) Static consumer cannot join group due to ERROR in broker

2019-07-25 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893117#comment-16893117 ] Raman Gupta edited comment on KAFKA-8715 at 7/25/19 8:44 PM: - [~bchen225242]

[jira] [Commented] (KAFKA-8715) Static consumer cannot join group due to ERROR in broker

2019-07-25 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893117#comment-16893117 ] Raman Gupta commented on KAFKA-8715: [~bchen225242] No it isn't happening all the time.

[jira] [Comment Edited] (KAFKA-8715) Static consumer cannot join group due to ERROR in broker

2019-07-25 Thread Raman Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893117#comment-16893117 ] Raman Gupta edited comment on KAFKA-8715 at 7/25/19 8:45 PM: - [~bchen225242]

[jira] [Created] (KAFKA-8966) Stream state does not transition to RUNNING on client, broker consumer group shows RUNNING

2019-10-01 Thread Raman Gupta (Jira)
Raman Gupta created KAFKA-8966: -- Summary: Stream state does not transition to RUNNING on client, broker consumer group shows RUNNING Key: KAFKA-8966 URL: https://issues.apache.org/jira/browse/KAFKA-8966

[jira] [Updated] (KAFKA-8966) Stream state does not transition to RUNNING on client, broker consumer group shows RUNNING

2019-10-01 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8966: --- Description: I have a Kafka stream that has been running fine until recently. The new behavior I

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-12-09 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991711#comment-16991711 ] Raman Gupta commented on KAFKA-8803: [~guozhang] Yes, the state is indefinite until the brokers are

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-12-10 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993219#comment-16993219 ] Raman Gupta commented on KAFKA-8803: [~guozhang] As per the OP, broker is 2.3.0 (with a patch for

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-12-06 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16990054#comment-16990054 ] Raman Gupta commented on KAFKA-8803: [~bchen225242] I see the pull request adds a retry. That is fine

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-10-21 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16956165#comment-16956165 ] Raman Gupta commented on KAFKA-8803: [~guozhang] I've provided all the logs, including broker side,

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-10-19 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16955262#comment-16955262 ] Raman Gupta commented on KAFKA-8803: And now suddenly I have this same problem again... this is

[jira] [Comment Edited] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-10-19 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16955393#comment-16955393 ] Raman Gupta edited comment on KAFKA-8803 at 10/20/19 5:34 AM: -- [~bbejeck]

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-10-20 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16955404#comment-16955404 ] Raman Gupta commented on KAFKA-8803: I've restarted my entire Kafka cluster, one node at a time, and

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-10-19 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16955393#comment-16955393 ] Raman Gupta commented on KAFKA-8803: [~bbejeck] Now the error is happening again, for two different

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-11-19 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977577#comment-16977577 ] Raman Gupta commented on KAFKA-8803: We had this problem again today, and checked on each node

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-11-27 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983584#comment-16983584 ] Raman Gupta commented on KAFKA-8803: [~bchen225242] actually only one eos app is affected (but

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-11-28 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984248#comment-16984248 ] Raman Gupta commented on KAFKA-8803: [~bchen225242] IIRC, it seems to happen randomly to specific

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2020-01-23 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022192#comment-17022192 ] Raman Gupta commented on KAFKA-8803: [~oleksii.boiko]'s last message inspired me to check for

[jira] [Comment Edited] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2020-01-27 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022192#comment-17022192 ] Raman Gupta edited comment on KAFKA-8803 at 1/27/20 9:52 PM: -

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2020-01-15 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016128#comment-17016128 ] Raman Gupta commented on KAFKA-8803: This happened to me again today. Recycling 3 of 4 brokers fixed

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2020-01-15 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016236#comment-17016236 ] Raman Gupta commented on KAFKA-8803: Looks like this is not just a dev-ops issue, from what I'm

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2020-01-16 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17017311#comment-17017311 ] Raman Gupta commented on KAFKA-8803: Is it possible this is related in the opposite direction? i.e.

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2020-01-16 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17017287#comment-17017287 ] Raman Gupta commented on KAFKA-8803: Very very strange. Following up on my last message, after a

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2020-01-17 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018259#comment-17018259 ] Raman Gupta commented on KAFKA-8803: And it happened again today with the same stream. Offsets were /

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2020-03-11 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057281#comment-17057281 ] Raman Gupta commented on KAFKA-8803: [~guozhang] FYI we had this happen again today, and this time I

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2020-03-11 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057191#comment-17057191 ] Raman Gupta commented on KAFKA-8803: Any progress on this? Still happening regularly for us. >

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2020-03-11 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057262#comment-17057262 ] Raman Gupta commented on KAFKA-8803: Thanks [~guozhang]. I'm a little confused by your response.

  1   2   >