[jira] [Commented] (KAFKA-3184) Add Checkpoint for In-memory State Store

[ https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16344081#comment-16344081 ] Ted Yu commented on KAFKA-3184: --- bq. only do the checkpointing every N. flush calls This seems to be better

[jira] [Commented] (KAFKA-6288) Broken symlink interrupts scanning the plugin path

[ https://issues.apache.org/jira/browse/KAFKA-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16343865#comment-16343865 ] ASF GitHub Bot commented on KAFKA-6288: --- kkonstantine opened a new pull request #4481: KAFKA-6288:

[jira] [Updated] (KAFKA-6367) Fix StateRestoreListener To Use Correct Ending Offset

[ https://issues.apache.org/jira/browse/KAFKA-6367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6367: - Fix Version/s: (was: 1.0.1) 1.0.2 Moving from 1.0.1 to

[jira] [Updated] (KAFKA-3866) KerberosLogin refresh time bug and other improvements

[ https://issues.apache.org/jira/browse/KAFKA-3866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3866: - Fix Version/s: (was: 1.0.1) 1.0.2 Moving from 1.0.1 to

[jira] [Updated] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId

[ https://issues.apache.org/jira/browse/KAFKA-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-5503: - Fix Version/s: (was: 1.0.1) 1.0.2 Moving from 1.0.1 to

[jira] [Updated] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure

[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-5973: - Fix Version/s: (was: 1.0.1) 1.0.2 Moving from 1.0.1 to

[jira] [Updated] (KAFKA-6364) Add Second Check for End Offset During Restore

[ https://issues.apache.org/jira/browse/KAFKA-6364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6364: - Fix Version/s: (was: 1.0.1) 1.0.2 Moving from 1.0.1 to

[jira] [Updated] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics

[ https://issues.apache.org/jira/browse/KAFKA-4950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4950: - Fix Version/s: 1.0.2 > ConcurrentModificationException when iterating over Kafka

[jira] [Updated] (KAFKA-5975) No response when deleting topics and delete.topic.enable=false

[ https://issues.apache.org/jira/browse/KAFKA-5975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-5975: - Fix Version/s: (was: 1.0.1) 1.0.2 Moving from 1.0.1 to

[jira] [Updated] (KAFKA-6007) Connect can't validate against transforms in plugins.path

[ https://issues.apache.org/jira/browse/KAFKA-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6007: - Fix Version/s: (was: 1.0.1) 1.0.2 Moving from 1.0.1 to

[jira] [Created] (KAFKA-6498) Add RocksDB statistics via Streams metrics

Guozhang Wang created KAFKA-6498: Summary: Add RocksDB statistics via Streams metrics Key: KAFKA-6498 URL: https://issues.apache.org/jira/browse/KAFKA-6498 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-6288) Broken symlink interrupts scanning the plugin path

[ https://issues.apache.org/jira/browse/KAFKA-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16343864#comment-16343864 ] ASF GitHub Bot commented on KAFKA-6288: --- ewencp closed pull request #4481: KAFKA-6288: Broken

[jira] [Updated] (KAFKA-6148) ClassCastException in BigQuery connector

[ https://issues.apache.org/jira/browse/KAFKA-6148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6148: - Fix Version/s: (was: 1.0.1) 1.0.2 Moving from 1.0.1 to

[jira] [Comment Edited] (KAFKA-6148) ClassCastException in BigQuery connector

[ https://issues.apache.org/jira/browse/KAFKA-6148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16343898#comment-16343898 ] Konstantine Karantasis edited comment on KAFKA-6148 at 1/29/18 7:46 PM:

[jira] [Resolved] (KAFKA-6280) Allow for additional archive types to be loaded from plugin.path in Connect

[ https://issues.apache.org/jira/browse/KAFKA-6280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-6280. --- Resolution: Fixed Fix Version/s: (was: 1.1.0)

[jira] [Commented] (KAFKA-6497) streams#store ambiguous InvalidStateStoreException

[ https://issues.apache.org/jira/browse/KAFKA-6497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16343826#comment-16343826 ] Matthias J. Sax commented on KAFKA-6497: [~Pegerto] Thanks for filing this ticket. I am wondering

[jira] [Updated] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics

[ https://issues.apache.org/jira/browse/KAFKA-4950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4950: - Fix Version/s: (was: 1.0.1) Moving from 1.0.1 to 1.0.2 as this isn't ready

[jira] [Updated] (KAFKA-1923) Negative offsets in replication-offset-checkpoint file

[ https://issues.apache.org/jira/browse/KAFKA-1923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1923: - Fix Version/s: (was: 1.0.1) This seems to just be getting bumped from one

[jira] [Commented] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic

[ https://issues.apache.org/jira/browse/KAFKA-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16343820#comment-16343820 ] Matthias J. Sax commented on KAFKA-6035: Thanks [~Yohan123] for being a team player! Really

[jira] [Commented] (KAFKA-6446) KafkaProducer with transactionId endless waits when bootstrap server is down

[ https://issues.apache.org/jira/browse/KAFKA-6446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16343150#comment-16343150 ] Yu LIU commented on KAFKA-6446: --- Hello, I have a look at this and it appears that TRANSACTION_TIMEOUT_CONFIG

[jira] [Comment Edited] (KAFKA-6446) KafkaProducer with transactionId endless waits when bootstrap server is down

[ https://issues.apache.org/jira/browse/KAFKA-6446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16343150#comment-16343150 ] Yu LIU edited comment on KAFKA-6446 at 1/29/18 9:59 AM: Hello, I have a look at

[jira] [Commented] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16343209#comment-16343209 ] Dmitriy Matveev commented on KAFKA-3410: We have faced the same problem. it's happened like this, 

[jira] [Created] (KAFKA-6494) Extend ConfigCommand to update broker config using new AdminClient

Rajini Sivaram created KAFKA-6494: - Summary: Extend ConfigCommand to update broker config using new AdminClient Key: KAFKA-6494 URL: https://issues.apache.org/jira/browse/KAFKA-6494 Project: Kafka

[jira] [Created] (KAFKA-6495) Race condition when creating and deleting quickly topics may lead to metrics leak

Mickael Maison created KAFKA-6495: - Summary: Race condition when creating and deleting quickly topics may lead to metrics leak Key: KAFKA-6495 URL: https://issues.apache.org/jira/browse/KAFKA-6495

[jira] [Commented] (KAFKA-6338) java.lang.NoClassDefFoundError: org/apache/kafka/common/network/LoginType

[ https://issues.apache.org/jira/browse/KAFKA-6338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16343372#comment-16343372 ] Ronald van de Kuil commented on KAFKA-6338: --- Oka, I raised RANGER-1964 >

[jira] [Commented] (KAFKA-6484) 'ConsumerGroupCommand' performance optimization for old consumer describe group

[ https://issues.apache.org/jira/browse/KAFKA-6484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16343515#comment-16343515 ] Randall Hauch commented on KAFKA-6484: -- This issue and KAFKA-6485 appear to be duplicates; perhaps

[jira] [Resolved] (KAFKA-6484) 'ConsumerGroupCommand' performance optimization for old consumer describe group

[ https://issues.apache.org/jira/browse/KAFKA-6484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-6484. -- Resolution: Duplicate > 'ConsumerGroupCommand' performance optimization for old consumer

[jira] [Commented] (KAFKA-6496) NAT and Kafka

[ https://issues.apache.org/jira/browse/KAFKA-6496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16344420#comment-16344420 ] hanwei commented on KAFKA-6496: --- Do you mean that you start a vm using openstack, then you install kafka in

[jira] [Commented] (KAFKA-6451) Simplify KStreamReduce

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

[jira] [Resolved] (KAFKA-6451) Simplify KStreamReduce

[ https://issues.apache.org/jira/browse/KAFKA-6451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6451. -- Resolution: Fixed Fix Version/s: 1.1.0 > Simplify KStreamReduce > --

[jira] [Commented] (KAFKA-5824) Cannot write to key value store provided by ProcessorTopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16344374#comment-16344374 ] Matthias J. Sax commented on KAFKA-5824: [~dminkovsky] KIP-247 was merged today (KAFKA-3625). Does

[jira] [Commented] (KAFKA-3625) Move kafka-streams test fixtures into a published package

[ https://issues.apache.org/jira/browse/KAFKA-3625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16344405#comment-16344405 ] Matthias J. Sax commented on KAFKA-3625: [~guozhang] I linked all relevant JIRAs a could find to

[jira] [Commented] (KAFKA-5253) KStreamTestDriver must handle streams created with patterns

[ https://issues.apache.org/jira/browse/KAFKA-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16344398#comment-16344398 ] Matthias J. Sax commented on KAFKA-5253: We should double check the new test artifact, if it can

[jira] [Created] (KAFKA-6499) Avoid creating dummy checkpoint files with no state stores

Guozhang Wang created KAFKA-6499: Summary: Avoid creating dummy checkpoint files with no state stores Key: KAFKA-6499 URL: https://issues.apache.org/jira/browse/KAFKA-6499 Project: Kafka

[jira] [Commented] (KAFKA-4772) Exploit #peek to implement #print() and other methods

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

[jira] [Commented] (KAFKA-4772) Exploit #peek to implement #print() and other methods

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

[jira] [Created] (KAFKA-6500) Can not build aggregatedJavadoc

Pavel Timofeev created KAFKA-6500: - Summary: Can not build aggregatedJavadoc Key: KAFKA-6500 URL: https://issues.apache.org/jira/browse/KAFKA-6500 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-4772) Exploit #peek to implement #print() and other methods

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

[jira] [Created] (KAFKA-6496) NAT and Kafka

Ronald van de Kuil created KAFKA-6496: - Summary: NAT and Kafka Key: KAFKA-6496 URL: https://issues.apache.org/jira/browse/KAFKA-6496 Project: Kafka Issue Type: Improvement Affects

[jira] [Commented] (KAFKA-6195) DNS alias support for secured connections

[ https://issues.apache.org/jira/browse/KAFKA-6195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16343653#comment-16343653 ] ASF GitHub Bot commented on KAFKA-6195: --- lepolac opened a new pull request #4485: KAFKA-6195:

[jira] [Commented] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot

[ https://issues.apache.org/jira/browse/KAFKA-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16343657#comment-16343657 ] Damian Guy commented on KAFKA-3955: --- [~ijuma] is this going to make it for 1.1? > Kafka log recovery

[jira] [Resolved] (KAFKA-6079) Idempotent production for source connectors

[ https://issues.apache.org/jira/browse/KAFKA-6079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-6079. -- Resolution: Won't Fix Marking this as WONTFIX since it is *already possible since AK 0.11* to