[jira] [Resolved] (KAFKA-10229) Kafka stream dies for no apparent reason, no errors logged on client or server

2020-07-14 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta resolved KAFKA-10229. - Resolution: Invalid Not an issue with Kafka -- the code run by the stream was blocked. > Kafka

[jira] [Commented] (KAFKA-10229) Kafka stream dies for no apparent reason, no errors logged on client or server

2020-07-04 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151456#comment-17151456 ] Raman Gupta commented on KAFKA-10229: - [~guozhang] Its the latter case -- the app itself is running

[jira] [Updated] (KAFKA-10229) Kafka stream dies for no apparent reason, no errors logged on client or server

2020-07-02 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-10229: Summary: Kafka stream dies for no apparent reason, no errors logged on client or server (was:

[jira] [Created] (KAFKA-10229) Kafka stream dies when earlier shut down node leaves group, no errors logged on client

2020-07-02 Thread Raman Gupta (Jira)
Raman Gupta created KAFKA-10229: --- Summary: Kafka stream dies when earlier shut down node leaves group, no errors logged on client Key: KAFKA-10229 URL: https://issues.apache.org/jira/browse/KAFKA-10229

[jira] [Commented] (KAFKA-10007) Kafka consumer offset reset despite recent group activity

2020-05-27 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117760#comment-17117760 ] Raman Gupta commented on KAFKA-10007: - It certainly could be. I'm not certain KAFKA-9543 listed too

[jira] [Comment Edited] (KAFKA-10007) Kafka consumer offset reset despite recent group activity

2020-05-26 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117039#comment-17117039 ] Raman Gupta edited comment on KAFKA-10007 at 5/26/20, 8:59 PM: --- Just

[jira] [Commented] (KAFKA-10007) Kafka consumer offset reset despite recent group activity

2020-05-26 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117039#comment-17117039 ] Raman Gupta commented on KAFKA-10007: - Just happened to me again on a completely different 2.4.1

[jira] [Created] (KAFKA-10007) Kafka consumer offset reset despite recent group activity

2020-05-15 Thread Raman Gupta (Jira)
Raman Gupta created KAFKA-10007: --- Summary: Kafka consumer offset reset despite recent group activity Key: KAFKA-10007 URL: https://issues.apache.org/jira/browse/KAFKA-10007 Project: Kafka

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

2020-05-12 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105745#comment-17105745 ] Raman Gupta commented on KAFKA-8803: [~guozhang] No, you never mentioned that commit above AFAICS. >

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

2020-05-12 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta reopened KAFKA-8803: > Stream will not start due to TimeoutException: Timeout expired after > 6milliseconds while

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

2020-05-12 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105691#comment-17105691 ] Raman Gupta commented on KAFKA-8803: [~guozhang] Just ran into this problem again, with 2.4.1 + patch

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

2020-04-30 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: --- Fix Version/s: 2.4.2 2.3.2 > Stream will not start due to TimeoutException:

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

2020-04-06 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17076895#comment-17076895 ] Raman Gupta commented on KAFKA-8803: We are on 2.4.1 now, locally patched with the fix for

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

2020-03-18 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17062286#comment-17062286 ] Raman Gupta commented on KAFKA-8803: [~guozhang] I plan on upgrading to 2.4.1 (from 2.3.0) within the

[jira] [Comment Edited] (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=17057352#comment-17057352 ] Raman Gupta edited comment on KAFKA-8803 at 3/11/20, 8:20 PM: -- Here are the

[jira] [Updated] (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:all-tabpanel ] Raman Gupta updated KAFKA-8803: --- Attachment: logs-client-20200311.txt.gz logs-20200311.txt.gz > Stream will not start

[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=17057262#comment-17057262 ] Raman Gupta commented on KAFKA-8803: Thanks [~guozhang]. I'm a little confused by your response.

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

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

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-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-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-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] [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-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-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] [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] [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] [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] [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] [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] [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-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-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=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=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-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] [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] [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] [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] [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: --- Attachment: logs.txt.gz > 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-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] [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-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: --- 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] [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] [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] [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-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] [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 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] [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-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] [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] [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 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] [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 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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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:44 PM: - [~bchen225242]

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

  1   2   >