[jira] [Commented] (KAFKA-8586) Source task producers silently fail to send records

2019-06-24 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16870869#comment-16870869 ] Ewen Cheslack-Postava commented on KAFKA-8586: -- `recordSent` call could prob

[jira] [Issue Comment Deleted] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

2019-06-24 Thread Francisco Juan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francisco Juan updated KAFKA-8335: -- Comment: was deleted (was: Hello [~boquan]) > Log cleaner skips Transactional mark and batch r

[jira] [Commented] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

2019-06-24 Thread Francisco Juan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16870881#comment-16870881 ] Francisco Juan commented on KAFKA-8335: --- Hello [~boquan] > Log cleaner skips Trans

[jira] [Comment Edited] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

2019-06-24 Thread Francisco Juan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16870892#comment-16870892 ] Francisco Juan edited comment on KAFKA-8335 at 6/24/19 7:44 AM: ---

[jira] [Commented] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

2019-06-24 Thread Francisco Juan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16870892#comment-16870892 ] Francisco Juan commented on KAFKA-8335: --- Hello [~boquan] I have applied your sugge

[jira] [Comment Edited] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

2019-06-24 Thread Francisco Juan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16870892#comment-16870892 ] Francisco Juan edited comment on KAFKA-8335 at 6/24/19 7:55 AM: ---

[jira] [Commented] (KAFKA-6793) Unnecessary warning log message

2019-06-24 Thread Patrik Kleindl (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16870899#comment-16870899 ] Patrik Kleindl commented on KAFKA-6793: --- Just to bump this, as discussed in [https

[jira] [Commented] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

2019-06-24 Thread Weichu Liu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16870907#comment-16870907 ] Weichu Liu commented on KAFKA-8335: --- [~francisco.juan] On our cluster, after upgrading,

[jira] [Created] (KAFKA-8591) NPE when reloading connector configuration using WorkerConfigTransformer

2019-06-24 Thread Nacho Munoz (JIRA)
Nacho Munoz created KAFKA-8591: -- Summary: NPE when reloading connector configuration using WorkerConfigTransformer Key: KAFKA-8591 URL: https://issues.apache.org/jira/browse/KAFKA-8591 Project: Kafka

[jira] [Commented] (KAFKA-8591) NPE when reloading connector configuration using WorkerConfigTransformer

2019-06-24 Thread Nacho Munoz (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1687#comment-1687 ] Nacho Munoz commented on KAFKA-8591: A PR has been opened to address this issue -  [h

[jira] [Updated] (KAFKA-8591) NPE when reloading connector configuration using WorkerConfigTransformer

2019-06-24 Thread Nacho Munoz (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nacho Munoz updated KAFKA-8591: --- Description: When a connector uses a ConfigProvider and sets a given TTL in the returned ConfigData,

[jira] [Created] (KAFKA-8592) Broker Dynamic Configuration fails to resolve variables as per KIP-421

2019-06-24 Thread TEJAL ADSUL (JIRA)
TEJAL ADSUL created KAFKA-8592: -- Summary: Broker Dynamic Configuration fails to resolve variables as per KIP-421 Key: KAFKA-8592 URL: https://issues.apache.org/jira/browse/KAFKA-8592 Project: Kafka

[jira] [Commented] (KAFKA-8592) Broker Dynamic Configuration fails to resolve variables as per KIP-421

2019-06-24 Thread TEJAL ADSUL (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16871409#comment-16871409 ] TEJAL ADSUL commented on KAFKA-8592: Code Review: [https://github.com/apache/kafka/pu

[jira] [Created] (KAFKA-8593) Provide a JSON Array Serde for serializing a List to a JSON Array and vice versa

2019-06-24 Thread Oliver Weiler (JIRA)
Oliver Weiler created KAFKA-8593: Summary: Provide a JSON Array Serde for serializing a List to a JSON Array and vice versa Key: KAFKA-8593 URL: https://issues.apache.org/jira/browse/KAFKA-8593 Projec

[jira] [Commented] (KAFKA-8593) Provide a JSON Array Serde for serializing a List to a JSON Array and vice versa

2019-06-24 Thread Oliver Weiler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16871439#comment-16871439 ] Oliver Weiler commented on KAFKA-8593: -- If this feature would be considered, I would

[jira] [Commented] (KAFKA-8586) Source task producers silently fail to send records

2019-06-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16871481#comment-16871481 ] ASF GitHub Bot commented on KAFKA-8586: --- C0urante commented on pull request #6993:

[jira] [Commented] (KAFKA-8590) Replace TxnOffsetCommitRequest request/response with automated protocol

2019-06-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16871641#comment-16871641 ] ASF GitHub Bot commented on KAFKA-8590: --- abbccdda commented on pull request #6994:

[jira] [Commented] (KAFKA-8593) Provide a JSON Array Serde for serializing a List to a JSON Array and vice versa

2019-06-24 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16871716#comment-16871716 ] John Roesler commented on KAFKA-8593: - Hey [~oweiler], Just to be sure, it looks lik

[jira] [Commented] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

2019-06-24 Thread Patrik Kleindl (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16871773#comment-16871773 ] Patrik Kleindl commented on KAFKA-7509: --- Not related to Connect but giving this a b

[jira] [Comment Edited] (KAFKA-6793) Unnecessary warning log message

2019-06-24 Thread Patrik Kleindl (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16870899#comment-16870899 ] Patrik Kleindl edited comment on KAFKA-6793 at 6/24/19 8:58 PM: ---

[jira] [Created] (KAFKA-8594) Add Kafka Streams compatibility test for Kafka 2.3.0

2019-06-24 Thread Colin P. McCabe (JIRA)
Colin P. McCabe created KAFKA-8594: -- Summary: Add Kafka Streams compatibility test for Kafka 2.3.0 Key: KAFKA-8594 URL: https://issues.apache.org/jira/browse/KAFKA-8594 Project: Kafka Issue

[jira] [Updated] (KAFKA-8594) Add Kafka Streams compatibility test for Kafka 2.3.0

2019-06-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8594: --- Component/s: streams > Add Kafka Streams compatibility test for Kafka 2.3.0 > ---

[jira] [Commented] (KAFKA-8574) EOS race condition during task transition leads to LocalStateStore truncation in Kafka Streams 2.0.1

2019-06-24 Thread William Greer (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16871837#comment-16871837 ] William Greer commented on KAFKA-8574: -- Looking at the code more I think the race co

[jira] [Assigned] (KAFKA-8594) Add Kafka Streams compatibility test for Kafka 2.3.0

2019-06-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8594: -- Assignee: Matthias J. Sax > Add Kafka Streams compatibility test for Kafka 2.3.0 > ---

[jira] [Updated] (KAFKA-8594) Add Kafka Streams compatibility test for Kafka 2.3.0

2019-06-24 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-8594: --- Affects Version/s: 2.4.0 Fix Version/s: 2.4.0 > Add Kafka Streams compatibility test

[jira] [Created] (KAFKA-8595) Support SerDe of Decimals in JSON that are not HEX encoded

2019-06-24 Thread Almog Gavra (JIRA)
Almog Gavra created KAFKA-8595: -- Summary: Support SerDe of Decimals in JSON that are not HEX encoded Key: KAFKA-8595 URL: https://issues.apache.org/jira/browse/KAFKA-8595 Project: Kafka Issue Ty

[jira] [Commented] (KAFKA-8242) Exception in ReplicaFetcher blocks replication of all other partitions

2019-06-24 Thread Dhruvil Shah (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872002#comment-16872002 ] Dhruvil Shah commented on KAFKA-8242: - I believe this is addressed by  [https://cwiki

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

2019-06-24 Thread Omkar Mestry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872006#comment-16872006 ] Omkar Mestry commented on KAFKA-7245: - [~mjsax] I have updated the status of  [KIP -

[jira] [Commented] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

2019-06-24 Thread Francisco Juan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872013#comment-16872013 ] Francisco Juan commented on KAFKA-8335: --- I'm seeing this problem only in some parti