[jira] [Closed] (KAFKA-9351) Higher count in destination cluster using Kafka MM2

2020-01-19 Thread Ryanne Dolan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan closed KAFKA-9351. --- > Higher count in destination cluster using Kafka MM2 >

[jira] [Resolved] (KAFKA-9351) Higher count in destination cluster using Kafka MM2

2020-01-19 Thread Ryanne Dolan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan resolved KAFKA-9351. - Resolution: Information Provided > Higher count in destination cluster using Kafka MM2 >

[jira] [Commented] (KAFKA-9351) Higher count in destination cluster using Kafka MM2

2020-01-19 Thread Nitish Goyal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019248#comment-17019248 ] Nitish Goyal commented on KAFKA-9351: - [~ryannedolan] Thanks for clarification and update   I am

[jira] [Comment Edited] (KAFKA-9351) Higher count in destination cluster using Kafka MM2

2020-01-19 Thread Nitish Goyal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019248#comment-17019248 ] Nitish Goyal edited comment on KAFKA-9351 at 1/20/20 6:14 AM: --

[jira] [Assigned] (KAFKA-9375) Add thread names to kafka connect threads

2020-01-19 Thread karan kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] karan kumar reassigned KAFKA-9375: -- Assignee: karan kumar > Add thread names to kafka connect threads >

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for In-memory stores of Streams

2020-01-19 Thread Ted Yu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019191#comment-17019191 ] Ted Yu commented on KAFKA-9455: --- Maybe we can also look at (profile) Maps from fastutil such as:

[jira] [Updated] (KAFKA-9322) Add `tail -n` feature for ConsoleConsumer

2020-01-19 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-9322: -- Labels: needs-kip (was: ) > Add `tail -n` feature for ConsoleConsumer >

[jira] [Commented] (KAFKA-9356) Potential data loss in InMemoryWindowStore and InMemorySessionStore

2020-01-19 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019177#comment-17019177 ] Guozhang Wang commented on KAFKA-9356: -- Thanks [~ableegoldman], I cannot find the exact ticket so

[jira] [Created] (KAFKA-9455) Consider using TreeMap for In-memory stores of Streams

2020-01-19 Thread Guozhang Wang (Jira)
Guozhang Wang created KAFKA-9455: Summary: Consider using TreeMap for In-memory stores of Streams Key: KAFKA-9455 URL: https://issues.apache.org/jira/browse/KAFKA-9455 Project: Kafka Issue

[jira] [Commented] (KAFKA-9142) topic __transaction_state disk space grows too big

2020-01-19 Thread panpan.liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019176#comment-17019176 ] panpan.liu commented on KAFKA-9142: --- [~guozhang] Yes. Before I restart broker, I found there is no

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

2020-01-19 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019171#comment-17019171 ] Guozhang Wang commented on KAFKA-8803: -- Hi [~rocketraman] [~panpan.liu] We are very actively working

[jira] [Commented] (KAFKA-9142) topic __transaction_state disk space grows too big

2020-01-19 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019170#comment-17019170 ] Guozhang Wang commented on KAFKA-9142: -- Thanks [~panpan.liu], by `recover to normal` did you mean

[jira] [Assigned] (KAFKA-9290) Update IQ related JavaDocs

2020-01-19 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-9290: --- Assignee: (was: highluck) > Update IQ related JavaDocs > -- > >

[jira] [Assigned] (KAFKA-9290) Update IQ related JavaDocs

2020-01-19 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-9290: --- Assignee: highluck > Update IQ related JavaDocs > -- > >

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

2020-01-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018886#comment-17018886 ] ASF GitHub Bot commented on KAFKA-7658: --- highluck commented on pull request #7985: KAFKA-7658: Add

[jira] [Commented] (KAFKA-9445) Allow fetching a key from a single partition rather than iterating over all the stores on an instance

2020-01-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018866#comment-17018866 ] ASF GitHub Bot commented on KAFKA-9445: --- brary commented on pull request #7984: [WIP: KAFKA-9445]

[jira] [Commented] (KAFKA-9142) topic __transaction_state disk space grows too big

2020-01-19 Thread panpan.liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018849#comment-17018849 ] panpan.liu commented on KAFKA-9142: --- I restart brokers one by one. And it recovery to normal.   >

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

2020-01-19 Thread panpan.liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018847#comment-17018847 ] panpan.liu edited comment on KAFKA-8803 at 1/19/20 9:33 AM: I have met the

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

2020-01-19 Thread panpan.liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018847#comment-17018847 ] panpan.liu edited comment on KAFKA-8803 at 1/19/20 9:32 AM: I have met the

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

2020-01-19 Thread panpan.liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018847#comment-17018847 ] panpan.liu edited comment on KAFKA-8803 at 1/19/20 9:30 AM: I have met the

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

2020-01-19 Thread panpan.liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018847#comment-17018847 ] panpan.liu commented on KAFKA-8803: --- I have met the same problem. kafka broker: 2.0.0 kafka