[jira] [Commented] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777147#comment-16777147 ] Matthias J. Sax commented on KAFKA-7996: [~guozhang] This is marked as "needs-kip", but I am

[jira] [Commented] (KAFKA-6794) Support for incremental replica reassignment

[ https://issues.apache.org/jira/browse/KAFKA-6794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777149#comment-16777149 ] GEORGE LI commented on KAFKA-6794: -- Hi, [~viktorsomogyi], When I rebalance the whole cluster, I

[jira] [Assigned] (KAFKA-1) The log4j appender still uses the SyncProducer API

[ https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-1: --- Assignee: (was: Matthias J. Sax) > The log4j appender still uses the SyncProducer API >

[jira] [Assigned] (KAFKA-1) The log4j appender still uses the SyncProducer API

[ https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-1: --- Assignee: Matthias J. Sax > The log4j appender still uses the SyncProducer API >

[jira] [Updated] (KAFKA-7967) Kafka Streams: some values in statestore rollback to old value

[ https://issues.apache.org/jira/browse/KAFKA-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7967: - Component/s: streams > Kafka Streams: some values in statestore rollback to old value >

[jira] [Commented] (KAFKA-7997) Replace SaslAuthenticate request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-7997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777151#comment-16777151 ] ASF GitHub Bot commented on KAFKA-7997: --- mimaison commented on pull request #6324: KAFKA-7997: Use

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777234#comment-16777234 ] ASF GitHub Bot commented on KAFKA-7895: --- vvcephei commented on pull request #6325: KAFKA-7895: fix

[jira] [Commented] (KAFKA-6794) Support for incremental replica reassignment

[ https://issues.apache.org/jira/browse/KAFKA-6794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777257#comment-16777257 ] GEORGE LI commented on KAFKA-6794: -- Hi [~viktorsomogyi], I think this "Incremental Reassignment" is

[jira] [Comment Edited] (KAFKA-6794) Support for incremental replica reassignment

[ https://issues.apache.org/jira/browse/KAFKA-6794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777149#comment-16777149 ] GEORGE LI edited comment on KAFKA-6794 at 2/25/19 7:56 PM: --- Hi,

[jira] [Assigned] (KAFKA-7976) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable

[ https://issues.apache.org/jira/browse/KAFKA-7976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-7976: -- Assignee: Stanislav Kozlovski > Flaky Test

[jira] [Commented] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777298#comment-16777298 ] Patrik Kleindl commented on KAFKA-7996: --- >From a "user" perspective, if something is called a

[jira] [Created] (KAFKA-7999) Flaky Test ExampleConnectIntegrationTest#testProduceConsumeConnector

Matthias J. Sax created KAFKA-7999: -- Summary: Flaky Test ExampleConnectIntegrationTest#testProduceConsumeConnector Key: KAFKA-7999 URL: https://issues.apache.org/jira/browse/KAFKA-7999 Project:

[jira] [Updated] (KAFKA-6824) Flaky Test DynamicBrokerReconfigurationTest#testAddRemoveSslListener

[ https://issues.apache.org/jira/browse/KAFKA-6824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6824: --- Summary: Flaky Test DynamicBrokerReconfigurationTest#testAddRemoveSslListener (was: Flaky

[jira] [Updated] (KAFKA-7957) Flaky Test DynamicBrokerReconfigurationTest#testMetricsReporterUpdate

[ https://issues.apache.org/jira/browse/KAFKA-7957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7957: --- Summary: Flaky Test DynamicBrokerReconfigurationTest#testMetricsReporterUpdate (was: Flaky

[jira] [Commented] (KAFKA-7988) Flaky Test DynamicBrokerReconfigurationTest#testThreadPoolResize

[ https://issues.apache.org/jira/browse/KAFKA-7988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777176#comment-16777176 ] Matthias J. Sax commented on KAFKA-7988: Failed again:

[jira] [Commented] (KAFKA-6582) Partitions get underreplicated, with a single ISR, and doesn't recover. Other brokers do not take over and we need to manually restart the broker.

[ https://issues.apache.org/jira/browse/KAFKA-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777441#comment-16777441 ] Sebastian Schmitz commented on KAFKA-6582: -- So far after 24 hours no issue yet... But I think

[jira] [Commented] (KAFKA-7970) Missing topic causes service shutdown without exception

[ https://issues.apache.org/jira/browse/KAFKA-7970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777523#comment-16777523 ] Guozhang Wang commented on KAFKA-7970: -- Hi [~JonnyHeavey], I've checked the source code after talked

[jira] [Commented] (KAFKA-7971) Producer in Streams environment

[ https://issues.apache.org/jira/browse/KAFKA-7971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777528#comment-16777528 ] Guozhang Wang commented on KAFKA-7971: -- I see: you have some logic which is not really data-driven

[jira] [Created] (KAFKA-8001) Fetch from future replica stalls when local replica becomes a leader

Anna Povzner created KAFKA-8001: --- Summary: Fetch from future replica stalls when local replica becomes a leader Key: KAFKA-8001 URL: https://issues.apache.org/jira/browse/KAFKA-8001 Project: Kafka

[jira] [Updated] (KAFKA-8002) Replica reassignment to new log dir may not complete if future and current replicas segment files have different base offsets

[ https://issues.apache.org/jira/browse/KAFKA-8002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-8002: --- Priority: Critical (was: Major) > Replica reassignment to new log dir may not complete if

[jira] [Updated] (KAFKA-8001) Fetch from future replica stalls when local replica becomes a leader

[ https://issues.apache.org/jira/browse/KAFKA-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-8001: --- Priority: Critical (was: Major) > Fetch from future replica stalls when local replica

[jira] [Commented] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777426#comment-16777426 ] ASF GitHub Bot commented on KAFKA-7918: --- ableegoldman commented on pull request #6327: KAFKA-7918:

[jira] [Commented] (KAFKA-7845) Kafka clients do not re-resolve ips when a broker is replaced.

[ https://issues.apache.org/jira/browse/KAFKA-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777502#comment-16777502 ] Jennifer Thompson commented on KAFKA-7845: -- We just deployed Kafka 2.1.1 (Confluent 5.1.2), and

[jira] [Created] (KAFKA-8002) Replica reassignment to new log dir may not complete if future and current replicas segment files have different base offsets

Anna Povzner created KAFKA-8002: --- Summary: Replica reassignment to new log dir may not complete if future and current replicas segment files have different base offsets Key: KAFKA-8002 URL:

[jira] [Resolved] (KAFKA-7845) Kafka clients do not re-resolve ips when a broker is replaced.

[ https://issues.apache.org/jira/browse/KAFKA-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jennifer Thompson resolved KAFKA-7845. -- Resolution: Fixed Fix Version/s: 2.1.1 > Kafka clients do not re-resolve ips

[jira] [Commented] (KAFKA-7970) Missing topic causes service shutdown without exception

[ https://issues.apache.org/jira/browse/KAFKA-7970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777524#comment-16777524 ] Guozhang Wang commented on KAFKA-7970: -- As for now, I'd suggest maybe you can grep on the client

[jira] [Commented] (KAFKA-7845) Kafka clients do not re-resolve ips when a broker is replaced.

[ https://issues.apache.org/jira/browse/KAFKA-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777537#comment-16777537 ] Ismael Juma commented on KAFKA-7845: Thanks for confirming! > Kafka clients do not re-resolve ips

[jira] [Commented] (KAFKA-7970) Missing topic causes service shutdown without exception

[ https://issues.apache.org/jira/browse/KAFKA-7970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777504#comment-16777504 ] Matthias J. Sax commented on KAFKA-7970: [~JonnyHeavey], [~or] Thanks for the input. I double

[jira] [Commented] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777521#comment-16777521 ] Matthias J. Sax commented on KAFKA-7996: > As the current behavior does not conform to this it

[jira] [Commented] (KAFKA-7967) Kafka Streams: some values in statestore rollback to old value

[ https://issues.apache.org/jira/browse/KAFKA-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777517#comment-16777517 ] Guozhang Wang commented on KAFKA-7967: -- It is likely to because of the same issue as in

[jira] [Commented] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777646#comment-16777646 ] Patrik Kleindl commented on KAFKA-7996: --- You are right, I must haven taken a wrong turn somewhere.

[jira] [Comment Edited] (KAFKA-7967) Kafka Streams: some values in statestore rollback to old value

[ https://issues.apache.org/jira/browse/KAFKA-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777571#comment-16777571 ] Ziming Dong edited comment on KAFKA-7967 at 2/26/19 4:34 AM: - [~guozhang],

[jira] [Commented] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0

[ https://issues.apache.org/jira/browse/KAFKA-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777630#comment-16777630 ] Jonathan Gordon commented on KAFKA-7652: I tested out with trunk on Feb 22 (commit 

[jira] [Commented] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777550#comment-16777550 ] ASF GitHub Bot commented on KAFKA-7918: --- ableegoldman commented on pull request #6328: KAFKA-7918:

[jira] [Commented] (KAFKA-7967) Kafka Streams: some values in statestore rollback to old value

[ https://issues.apache.org/jira/browse/KAFKA-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777571#comment-16777571 ] Ziming Dong commented on KAFKA-7967: [~guozhang], since the value rollback to an old value which is

[jira] [Comment Edited] (KAFKA-7967) Kafka Streams: some values in statestore rollback to old value

[ https://issues.apache.org/jira/browse/KAFKA-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777571#comment-16777571 ] Ziming Dong edited comment on KAFKA-7967 at 2/26/19 4:31 AM: - [~guozhang],

[jira] [Commented] (KAFKA-7186) Controller uses too much memory when sending out UpdateMetadataRequest that can cause OutOfMemoryError

[ https://issues.apache.org/jira/browse/KAFKA-7186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777623#comment-16777623 ] ASF GitHub Bot commented on KAFKA-7186: --- hzxa21 commented on pull request #5519: KAFKA-7186: Avoid

[jira] [Commented] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777554#comment-16777554 ] ASF GitHub Bot commented on KAFKA-7918: --- guozhangwang commented on pull request #6293: KAFKA-7918:

[jira] [Created] (KAFKA-7998) Windows Quickstart script fails

Dieter De Paepe created KAFKA-7998: -- Summary: Windows Quickstart script fails Key: KAFKA-7998 URL: https://issues.apache.org/jira/browse/KAFKA-7998 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-7268) Review Handling Crypto Rules and update ECCN page if needed

[ https://issues.apache.org/jira/browse/KAFKA-7268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777089#comment-16777089 ] Rajini Sivaram commented on KAFKA-7268: --- [~bayard] Thank you! > Review Handling Crypto Rules and

[jira] [Created] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

Patrik Kleindl created KAFKA-7996: - Summary: KafkaStreams does not pass timeout when closing Producer Key: KAFKA-7996 URL: https://issues.apache.org/jira/browse/KAFKA-7996 Project: Kafka

[jira] [Commented] (KAFKA-6794) Support for incremental replica reassignment

[ https://issues.apache.org/jira/browse/KAFKA-6794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776694#comment-16776694 ] Viktor Somogyi-Vass commented on KAFKA-6794: hey [~sql_consulting], thanks for sharing this.

[jira] [Created] (KAFKA-7997) Replace SaslAuthenticate request/response with automated protocol

Mickael Maison created KAFKA-7997: - Summary: Replace SaslAuthenticate request/response with automated protocol Key: KAFKA-7997 URL: https://issues.apache.org/jira/browse/KAFKA-7997 Project: Kafka

[jira] [Commented] (KAFKA-7268) Review Handling Crypto Rules and update ECCN page if needed

[ https://issues.apache.org/jira/browse/KAFKA-7268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776780#comment-16776780 ] Rajini Sivaram commented on KAFKA-7268: --- Thanks [~bayard] I have updated the source URLs to use

[jira] [Commented] (KAFKA-5453) Controller may miss requests sent to the broker when zk session timeout happens.

[ https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776957#comment-16776957 ] Viktor Somogyi-Vass commented on KAFKA-5453: Just wanted to add: I'll chase the proposal in

[jira] [Commented] (KAFKA-7922) Returned authorized operations in describe responses (KIP-430)

[ https://issues.apache.org/jira/browse/KAFKA-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777005#comment-16777005 ] ASF GitHub Bot commented on KAFKA-7922: --- omkreddy commented on pull request #6322: KAFKA-7922:

[jira] [Resolved] (KAFKA-7268) Review Handling Crypto Rules and update ECCN page if needed

[ https://issues.apache.org/jira/browse/KAFKA-7268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henri Yandell resolved KAFKA-7268. -- Resolution: Fixed > Review Handling Crypto Rules and update ECCN page if needed >

[jira] [Updated] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7996: --- Labels: needs-kip (was: ) > KafkaStreams does not pass timeout when closing Producer >

[jira] [Commented] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777037#comment-16777037 ] ASF GitHub Bot commented on KAFKA-7996: --- dongjinleekr commented on pull request #6323: KAFKA-7996:

[jira] [Commented] (KAFKA-7268) Review Handling Crypto Rules and update ECCN page if needed

[ https://issues.apache.org/jira/browse/KAFKA-7268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777033#comment-16777033 ] Henri Yandell commented on KAFKA-7268: -- Thanks - published. > Review Handling Crypto Rules and

[jira] [Assigned] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-7996: -- Assignee: Lee Dongjin > KafkaStreams does not pass timeout when closing Producer >