[jira] [Commented] (KAFKA-7690) Change disk allocation policy for multiple partitions on a broker when topic is created

[ https://issues.apache.org/jira/browse/KAFKA-7690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723772#comment-16723772 ] huxihx commented on KAFKA-7690: --- [~yuhaiyang] As for the size-based strategy, it's difficult to estimate 

[jira] [Commented] (KAFKA-7732) Kafka broker lag metrics is more than 0, but no partitions are under replicated

[ https://issues.apache.org/jira/browse/KAFKA-7732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723760#comment-16723760 ] huxihx commented on KAFKA-7732: --- The fix does not cover the metric you mentioned. > Kafka broker lag

[jira] [Commented] (KAFKA-7746) sasl.jaas.config dynamic broker configuration does not accept "=" in value

[ https://issues.apache.org/jira/browse/KAFKA-7746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723750#comment-16723750 ] Manikumar commented on KAFKA-7746: -- Can you try below format? {code} bin/kafka-configs.sh

[jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

[ https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723718#comment-16723718 ] Justin Jack commented on KAFKA-7641: Thanks for offering help on this feature. We are already working

[jira] [Created] (KAFKA-7750) Hjson support in kafka connect

Manjeet Duhan created KAFKA-7750: Summary: Hjson support in kafka connect Key: KAFKA-7750 URL: https://issues.apache.org/jira/browse/KAFKA-7750 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-7749) confluent does not provide option to set consumer properties at connector level

Manjeet Duhan created KAFKA-7749: Summary: confluent does not provide option to set consumer properties at connector level Key: KAFKA-7749 URL: https://issues.apache.org/jira/browse/KAFKA-7749

[jira] [Commented] (KAFKA-7690) Change disk allocation policy for multiple partitions on a broker when topic is created

[ https://issues.apache.org/jira/browse/KAFKA-7690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723593#comment-16723593 ] haiyangyu commented on KAFKA-7690: -- If there are no partitions of target topic, it is still size-based

[jira] [Updated] (KAFKA-7741) Bad dependency via SBT

[ https://issues.apache.org/jira/browse/KAFKA-7741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7741: Component/s: KafkaConnect > Bad dependency via SBT > -- > >

[jira] [Commented] (KAFKA-7741) Bad dependency via SBT

[ https://issues.apache.org/jira/browse/KAFKA-7741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723514#comment-16723514 ] John Roesler commented on KAFKA-7741: - Hi [~sachabarber], Thanks for the report. I've not seen this

[jira] [Created] (KAFKA-7748) Add wall clock TimeDefinition for suppression of intermediate events

Jonathan Gordon created KAFKA-7748: -- Summary: Add wall clock TimeDefinition for suppression of intermediate events Key: KAFKA-7748 URL: https://issues.apache.org/jira/browse/KAFKA-7748 Project:

[jira] [Created] (KAFKA-7747) Consumer should check for truncation after leader changes

Jason Gustafson created KAFKA-7747: -- Summary: Consumer should check for truncation after leader changes Key: KAFKA-7747 URL: https://issues.apache.org/jira/browse/KAFKA-7747 Project: Kafka

[jira] [Commented] (KAFKA-7738) Track partition leader epochs in client metadata

[ https://issues.apache.org/jira/browse/KAFKA-7738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723351#comment-16723351 ] ASF GitHub Bot commented on KAFKA-7738: --- mumrah opened a new pull request #6045: KAFKA-7738 Track

[jira] [Created] (KAFKA-7746) sasl.jaas.config dynamic broker configuration does not accept "=" in value

Tom Scott created KAFKA-7746: Summary: sasl.jaas.config dynamic broker configuration does not accept "=" in value Key: KAFKA-7746 URL: https://issues.apache.org/jira/browse/KAFKA-7746 Project: Kafka

[jira] [Commented] (KAFKA-7297) Both read/write access to Log.segments should be protected by lock

[ https://issues.apache.org/jira/browse/KAFKA-7297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723236#comment-16723236 ] Dong Lin commented on KAFKA-7297: - [~ijuma] Hmm.. I think we may have different understanding. Jun

[jira] [Commented] (KAFKA-7703) KafkaConsumer.position may return a wrong offset after "seekToEnd" is called

[ https://issues.apache.org/jira/browse/KAFKA-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723159#comment-16723159 ] Viktor Somogyi commented on KAFKA-7703: --- [~rsivaram], [~hachikuji] I see you modified that part of

[jira] [Comment Edited] (KAFKA-7703) KafkaConsumer.position may return a wrong offset after "seekToEnd" is called

[ https://issues.apache.org/jira/browse/KAFKA-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723156#comment-16723156 ] Viktor Somogyi edited comment on KAFKA-7703 at 12/17/18 4:55 PM: -

[jira] [Commented] (KAFKA-7703) KafkaConsumer.position may return a wrong offset after "seekToEnd" is called

[ https://issues.apache.org/jira/browse/KAFKA-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723156#comment-16723156 ] Viktor Somogyi commented on KAFKA-7703: --- [~zsxwing], [~dongjoon], I've looked into the issue and it

[jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format

[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723125#comment-16723125 ] ASF GitHub Bot commented on KAFKA-3522: --- mjsax opened a new pull request #6044: [WIP: DO NOT MERGE]

[jira] [Assigned] (KAFKA-7243) Add unit integration tests to validate metrics in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-7243: -- Assignee: (was: Mariam John) > Add unit integration tests to validate metrics in Kafka

[jira] [Commented] (KAFKA-7243) Add unit integration tests to validate metrics in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723121#comment-16723121 ] Mariam John commented on KAFKA-7243: Done.  > Add unit integration tests to validate metrics in

[jira] [Commented] (KAFKA-6812) Async ConsoleProducer exits with 0 status even after data loss

[ https://issues.apache.org/jira/browse/KAFKA-6812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723056#comment-16723056 ] Kamal Kang commented on KAFKA-6812: --- [~enether] - I added

[jira] [Updated] (KAFKA-7745) Kafka Connect doesn't create tombstone record for tasks of deleted connector

[ https://issues.apache.org/jira/browse/KAFKA-7745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Pustovetov updated KAFKA-7745: - Description: *Test case* # Create a connector: {noformat} curl -i -XPOST -H

[jira] [Updated] (KAFKA-7745) Kafka Connect doesn't create tombstone record for tasks of deleted connector

[ https://issues.apache.org/jira/browse/KAFKA-7745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Pustovetov updated KAFKA-7745: - Description: *Test case* # Create a connector: {noformat} curl -i -XPOST -H

[jira] [Created] (KAFKA-7745) Kafka Connect doesn't create tombstone record for tasks of deleted connector

Andrey Pustovetov created KAFKA-7745: Summary: Kafka Connect doesn't create tombstone record for tasks of deleted connector Key: KAFKA-7745 URL: https://issues.apache.org/jira/browse/KAFKA-7745

[jira] [Updated] (KAFKA-7745) Kafka Connect doesn't create tombstone record for tasks of deleted connector

[ https://issues.apache.org/jira/browse/KAFKA-7745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Pustovetov updated KAFKA-7745: - Description: *Test case* # Create a connector: {noformat} curl -i -XPOST -H

[jira] [Commented] (KAFKA-7461) Connect Values converter should have coverage of logical types

[ https://issues.apache.org/jira/browse/KAFKA-7461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723010#comment-16723010 ] Andrew Schofield commented on KAFKA-7461: - This one has been dormant for a while now. Unless

[jira] [Commented] (KAFKA-7691) Encypt-then-MAC Delegation token metadata

[ https://issues.apache.org/jira/browse/KAFKA-7691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722993#comment-16722993 ] ASF GitHub Bot commented on KAFKA-7691: --- asasvari opened a new pull request #6040: KAFKA-7691;

[jira] [Created] (KAFKA-7744) Type in java

Andrii Abramov created KAFKA-7744: - Summary: Type in java Key: KAFKA-7744 URL: https://issues.apache.org/jira/browse/KAFKA-7744 Project: Kafka Issue Type: Bug Components:

[jira] [Updated] (KAFKA-7743) "pure virtual method called" error message thrown for unit tests which PASS

[ https://issues.apache.org/jira/browse/KAFKA-7743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7743: --- Affects Version/s: (was: 2.0.2) (was: 2.1.1)

[jira] [Updated] (KAFKA-7743) "pure virtual method called" error message thrown for unit tests which PASS

[ https://issues.apache.org/jira/browse/KAFKA-7743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7743: --- Component/s: streams > "pure virtual method called" error message thrown for unit tests

[jira] [Created] (KAFKA-7743) "pure virtual method called" error message thrown for unit tests which PASS

Sarvesh Tamba created KAFKA-7743: Summary: "pure virtual method called" error message thrown for unit tests which PASS Key: KAFKA-7743 URL: https://issues.apache.org/jira/browse/KAFKA-7743 Project:

[jira] [Commented] (KAFKA-7293) Merge followed by groupByKey/join might violate co-partioning

[ https://issues.apache.org/jira/browse/KAFKA-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722943#comment-16722943 ] Matthias J. Sax commented on KAFKA-7293: >From my understanding, nothing would happen (ie, no

[jira] [Updated] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean (Windows OS)

[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6647: --- Labels: (was: streams) > KafkaStreams.cleanUp creates .lock file in directory its trying

[jira] [Commented] (KAFKA-7432) API Method on Kafka Streams for processing chunks/batches of data

[ https://issues.apache.org/jira/browse/KAFKA-7432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722855#comment-16722855 ] sam commented on KAFKA-7432: [~Yohan123] This ticket is not really for "microbatching", perhaps you could

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722842#comment-16722842 ] Wei Zhang commented on KAFKA-4477: -- How do you resolve the bug?  I met the similar issue.    Kafka

[jira] [Commented] (KAFKA-7717) Enable security configs in kafka.tools.EndToEndLatency

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

[jira] [Commented] (KAFKA-7742) DelegationTokenCache#hmacIdCache entry is not cleared when a token is removed using removeToken(String tokenId) API.

[ https://issues.apache.org/jira/browse/KAFKA-7742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722817#comment-16722817 ] ASF GitHub Bot commented on KAFKA-7742: --- satishd opened a new pull request #6037: KAFKA-7742: Fixed