[jira] [Commented] (KAFKA-6915) MirrorMaker: avoid duplicates when source cluster is unreachable for more than session.timeout.ms

[ https://issues.apache.org/jira/browse/KAFKA-6915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480190#comment-16480190 ] Fabien LD commented on KAFKA-6915: -- The above solution also works when MirrorMaker is use

[jira] [Created] (KAFKA-6915) MirrorMaker: avoid duplicates when source cluster is unreachable for more than session.timeout.ms

Fabien LD created KAFKA-6915: Summary: MirrorMaker: avoid duplicates when source cluster is unreachable for more than session.timeout.ms Key: KAFKA-6915 URL: https://issues.apache.org/jira/browse/KAFKA-6915

[jira] [Updated] (KAFKA-6903) Improve KTable's sending old value behavior

[ https://issues.apache.org/jira/browse/KAFKA-6903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6903: - Description: Today in KTable's internal implementation, if old values are needed in the down stre

[jira] [Updated] (KAFKA-6903) Improve KTable's sending old value behavior

[ https://issues.apache.org/jira/browse/KAFKA-6903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6903: - Description: Today in KTable's internal implementation, if old values are needed in the down stre

[jira] [Commented] (KAFKA-5609) Connect log4j should log to file by default

[ https://issues.apache.org/jira/browse/KAFKA-5609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479929#comment-16479929 ] ASF GitHub Bot commented on KAFKA-5609: --- asutosh936 closed pull request #4687: KAFKA

[jira] [Created] (KAFKA-6914) Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader

Sriram KS created KAFKA-6914: Summary: Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader Key: KAFKA-6914 URL: https://issues.apache.org/jira/browse/KAFKA-6914 Pro

[jira] [Commented] (KAFKA-6913) Add primitive numeric converters to Connect

[ https://issues.apache.org/jira/browse/KAFKA-6913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479860#comment-16479860 ] Randall Hauch commented on KAFKA-6913: -- I created [KIP-305|https://cwiki.apache.org/

[jira] [Commented] (KAFKA-6913) Add primitive numeric converters to Connect

[ https://issues.apache.org/jira/browse/KAFKA-6913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479859#comment-16479859 ] ASF GitHub Bot commented on KAFKA-6913: --- rhauch opened a new pull request #5034: KAF

[jira] [Updated] (KAFKA-6913) Add primitive numeric converters to Connect

[ https://issues.apache.org/jira/browse/KAFKA-6913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6913: - Labels: needs-kip (was: ) > Add primitive numeric converters to Connect > ---

[jira] [Commented] (KAFKA-6907) Not able to delete topic

[ https://issues.apache.org/jira/browse/KAFKA-6907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479809#comment-16479809 ] Matthias J. Sax commented on KAFKA-6907: Have you restarted both brokers after the

[jira] [Created] (KAFKA-6913) Add primitive numeric converters to Connect

Randall Hauch created KAFKA-6913: Summary: Add primitive numeric converters to Connect Key: KAFKA-6913 URL: https://issues.apache.org/jira/browse/KAFKA-6913 Project: Kafka Issue Type: Improve

[jira] [Resolved] (KAFKA-6729) KTable should use user source topics if possible and not create changelog topic

[ https://issues.apache.org/jira/browse/KAFKA-6729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6729. -- Resolution: Fixed > KTable should use user source topics if possible and not create changelog >

[jira] [Commented] (KAFKA-6729) KTable should use user source topics if possible and not create changelog topic

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

[jira] [Resolved] (KAFKA-6426) Kafka SASL/SCRAM authentication does not fail for incorrect username or password.

[ https://issues.apache.org/jira/browse/KAFKA-6426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6426. -- Resolution: Cannot Reproduce This looks like configuration issue. Please reopen if you think the issue s

[jira] [Resolved] (KAFKA-6682) Kafka reconnection after broker restart

[ https://issues.apache.org/jira/browse/KAFKA-6682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6682. -- Resolution: Duplicate Resolving this as duplicate of KAFKA-6260.  Please reopen if the issue still exis

[jira] [Updated] (KAFKA-6868) BufferUnderflowException in client when querying consumer group information

[ https://issues.apache.org/jira/browse/KAFKA-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6868: --- Fix Version/s: 2.0.0 > BufferUnderflowException in client when querying consumer group information > -

[jira] [Updated] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari updated KAFKA-6884: -- Description: Now that we have KIP-222, we should update ConsumerGroupCommand to use the new Admi

[jira] [Updated] (KAFKA-6841) Add support for wildcard suffixed ACLs

[ https://issues.apache.org/jira/browse/KAFKA-6841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piyush Vijay updated KAFKA-6841: Fix Version/s: (was: 1.1.1) (was: 1.0.2) 2.0.0 > Add s

[jira] [Commented] (KAFKA-6864) null is not passed to keyDeserialzer and valueDeserializer in Fetcher

[ https://issues.apache.org/jira/browse/KAFKA-6864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479145#comment-16479145 ] Mathias Kub commented on KAFKA-6864: [~mjsax] Yes I do, but my explanation was not eno

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479130#comment-16479130 ] Grégory R. commented on KAFKA-1194: --- This issue is reproduced with kafka 1.1.0 > The ka

[jira] [Commented] (KAFKA-6912) Add authorization tests for custom principal types

[ https://issues.apache.org/jira/browse/KAFKA-6912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479087#comment-16479087 ] ASF GitHub Bot commented on KAFKA-6912: --- rajinisivaram opened a new pull request #50

[jira] [Created] (KAFKA-6912) Add authorization tests for custom principal types

Rajini Sivaram created KAFKA-6912: - Summary: Add authorization tests for custom principal types Key: KAFKA-6912 URL: https://issues.apache.org/jira/browse/KAFKA-6912 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-6901) Kafka crashes when trying to delete segment when retetention time is reached

a/browse/KAFKA-6901 > Project: Kafka > Issue Type: Bug > Components: core, log >Affects Versions: 1.0.0, 1.1.0 > Environment: OS: Windows Server 2012 R2 >Reporter: Grégory R. >Priority: Major > Labe

[jira] [Updated] (KAFKA-6901) Kafka crashes when trying to delete segment when retetention time is reached

: core, log >Affects Versions: 1.0.0, 1.1.0 > Environment: OS: Windows Server 2012 R2 >Reporter: Grégory R. >Priority: Major > Labels: windows > Attachments: 20180517 - ProcessExplorer after the crash.png, 20180517

[jira] [Updated] (KAFKA-6901) Kafka crashes when trying to delete segment when retetention time is reached

og >Affects Versions: 1.0.0, 1.1.0 > Environment: OS: Windows Server 2012 R2 >Reporter: Grégory R. >Priority: Critical > Labels: windows > Attachments: 20180517 - ProcessExplorer after the crash.png, 20180517 > - Process

[jira] [Commented] (KAFKA-6901) Kafka crashes when trying to delete segment when retetention time is reached

s is locking the file but nothing. Before the crash: !20180517 - ProcessExplorer before the crash.png|width=573,height=287! After the crash: !20180517 - ProcessExplorer after the crash.png|width=605,height=317! * I updated kafka to the last version (kafka_2.11-1.1.0) but bug still here. >

[jira] [Updated] (KAFKA-6901) Kafka crashes when trying to delete segment when retetention time is reached

[ https://issues.apache.org/jira/browse/KAFKA-6901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grégory R. updated KAFKA-6901: -- Attachment: 20180517 - ProcessExplorer after the crash.png > Kafka crashes when trying to del

[jira] [Updated] (KAFKA-6901) Kafka crashes when trying to delete segment when retetention time is reached

[ https://issues.apache.org/jira/browse/KAFKA-6901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grégory R. updated KAFKA-6901: -- Attachment: 20180517 - ProcessExplorer before the crash.png > Kafka crashes when trying to del

[jira] [Commented] (KAFKA-6911) Incorrect check for keystore/truststore dynamic update

[ https://issues.apache.org/jira/browse/KAFKA-6911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16478831#comment-16478831 ] ASF GitHub Bot commented on KAFKA-6911: --- rajinisivaram opened a new pull request #50

[jira] [Created] (KAFKA-6911) Incorrect check for keystore/truststore dynamic update

Rajini Sivaram created KAFKA-6911: - Summary: Incorrect check for keystore/truststore dynamic update Key: KAFKA-6911 URL: https://issues.apache.org/jira/browse/KAFKA-6911 Project: Kafka Issue