[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&focusedCommentId=16344494#comment-16344494 ] ASF GitHub Bot commented on KAFKA-4772: --- guozhangwang closed pull request #2704: KAF

[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&focusedCommentId=16344492#comment-16344492 ] ASF GitHub Bot commented on KAFKA-4772: --- guozhangwang closed pull request #2669: KAF

[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&focusedCommentId=16344493#comment-16344493 ] ASF GitHub Bot commented on KAFKA-4772: --- guozhangwang closed pull request #2703: KAF

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

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

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

[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&focusedCommentId=16344405#comment-16344405 ] Matthias J. Sax commented on KAFKA-3625: [~guozhang] I linked all relevant JIRAs a

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

[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&focusedCommentId=16344398#comment-16344398 ] Matthias J. Sax commented on KAFKA-5253: We should double check the new test artif

[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&focusedCommentId=16344374#comment-16344374 ] Matthias J. Sax commented on KAFKA-5824: [~dminkovsky] KIP-247 was merged today (K

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

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

[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-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&focusedCommentId=16344081#comment-16344081 ] Ted Yu commented on KAFKA-3184: --- bq. only do the checkpointing every N. flush calls This se

[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) 1.0

[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&focusedCommentId=16343898#comment-16343898 ] Konstantine Karantasis edited comment on KAFKA-6148 at 1/29/18 7:46 PM:

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

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

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

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

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

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

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

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

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

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

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

[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&focusedCommentId=16343864#comment-16343864 ] ASF GitHub Bot commented on KAFKA-6288: --- ewencp closed pull request #4481: KAFKA-628

[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&focusedCommentId=16343865#comment-16343865 ] ASF GitHub Bot commented on KAFKA-6288: --- kkonstantine opened a new pull request #448

[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&focusedCommentId=16343826#comment-16343826 ] Matthias J. Sax commented on KAFKA-6497: [~Pegerto] Thanks for filing this ticket.

[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&focusedCommentId=16343820#comment-16343820 ] Matthias J. Sax commented on KAFKA-6035: Thanks [~Yohan123] for being a team playe

[jira] [Assigned] (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:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6035: -- Assignee: Jeyhun Karimov > Avoid creating changelog topics for state stores that are di

[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: Improvem

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

Pegerto Fernandez created KAFKA-6497: Summary: streams#store ambiguous InvalidStateStoreException Key: KAFKA-6497 URL: https://issues.apache.org/jira/browse/KAFKA-6497 Project: Kafka Issu

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

[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&focusedCommentId=16343657#comment-16343657 ] Damian Guy commented on KAFKA-3955: --- [~ijuma] is this going to make it for 1.1? > Kafka

[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&focusedCommentId=16343653#comment-16343653 ] ASF GitHub Bot commented on KAFKA-6195: --- lepolac opened a new pull request #4485: KA

[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&focusedCommentId=16343515#comment-16343515 ] Randall Hauch commented on KAFKA-6484: -- This issue and KAFKA-6485 appear to be duplic

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

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

[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&focusedCommentId=16343372#comment-16343372 ] Ronald van de Kuil commented on KAFKA-6338: --- Oka, I raised RANGER-1964 > java.l

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

[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] [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&focusedCommentId=16343209#comment-16343209 ] Dmitriy Matveev commented on KAFKA-3410: We have faced the same problem. it's hap

[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&focusedCommentId=16343150#comment-16343150 ] Yu LIU edited comment on KAFKA-6446 at 1/29/18 9:59 AM: Hello, I h

[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&focusedCommentId=16343150#comment-16343150 ] Yu LIU commented on KAFKA-6446: --- Hello, I have a look at this and it appears that TRANSACTIO