[jira] [Updated] (KAFKA-6605) Flatten SMT does not properly handle fields that are null

[ https://issues.apache.org/jira/browse/KAFKA-6605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michal Borowiecki updated KAFKA-6605: - Affects Version/s: 2.0.0 > Flatten SMT does not properly handle fields that are null > --

[jira] [Assigned] (KAFKA-6605) Flatten SMT does not properly handle fields that are null

[ https://issues.apache.org/jira/browse/KAFKA-6605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michal Borowiecki reassigned KAFKA-6605: Assignee: Michal Borowiecki > Flatten SMT does not properly handle fields that are

[jira] [Commented] (KAFKA-7434) DeadLetterQueueReporter throws NPE if transform throws NPE

[ https://issues.apache.org/jira/browse/KAFKA-7434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16629428#comment-16629428 ] Michal Borowiecki commented on KAFKA-7434: -- Submitted PR for trunk: [https://git

[jira] [Updated] (KAFKA-7434) DeadLetterQueueReporter throws NPE if transform throws NPE

[ https://issues.apache.org/jira/browse/KAFKA-7434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michal Borowiecki updated KAFKA-7434: - Description: A NPE thrown from a transform in a connector configured with errors.deadlet

[jira] [Updated] (KAFKA-7434) DeadLetterQueueReporter throws NPE if transform throws NPE

[ https://issues.apache.org/jira/browse/KAFKA-7434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michal Borowiecki updated KAFKA-7434: - Description: A NPE thrown from a transform in a connector configured with errors.deadlet

[jira] [Assigned] (KAFKA-7434) DeadLetterQueueReporter throws NPE if transform throws NPE

[ https://issues.apache.org/jira/browse/KAFKA-7434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michal Borowiecki reassigned KAFKA-7434: Assignee: Michal Borowiecki > DeadLetterQueueReporter throws NPE if transform thro

[jira] [Updated] (KAFKA-7434) DeadLetterQueueReporter throws NPE if transform throws NPE

[ https://issues.apache.org/jira/browse/KAFKA-7434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michal Borowiecki updated KAFKA-7434: - Description: A NPE thrown from a transform in a connector configured with errors.deadlet

[jira] [Created] (KAFKA-7434) DeadLetterQueueReporter throws NPE if transform throws NPE

Michal Borowiecki created KAFKA-7434: Summary: DeadLetterQueueReporter throws NPE if transform throws NPE Key: KAFKA-7434 URL: https://issues.apache.org/jira/browse/KAFKA-7434 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=16196720#comment-16196720 ] Michal Borowiecki commented on KAFKA-3410: -- Sadly, we were hit by this issue this

[jira] [Commented] (KAFKA-5233) Changes to punctuate semantics (KIP-138)

[ https://issues.apache.org/jira/browse/KAFKA-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16129556#comment-16129556 ] Michal Borowiecki commented on KAFKA-5233: -- Hi [~guozhang], I had a look at KStr

[jira] [Commented] (KAFKA-3514) Stream timestamp computation needs some further thoughts

[ https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106086#comment-16106086 ] Michal Borowiecki commented on KAFKA-3514: -- 1. and 2. make perfect sense to me an

[jira] [Created] (KAFKA-5677) Remove deprecated punctuate method

Michal Borowiecki created KAFKA-5677: Summary: Remove deprecated punctuate method Key: KAFKA-5677 URL: https://issues.apache.org/jira/browse/KAFKA-5677 Project: Kafka Issue Type: Task

[jira] [Comment Edited] (KAFKA-5233) Changes to punctuate semantics (KIP-138)

[ https://issues.apache.org/jira/browse/KAFKA-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106084#comment-16106084 ] Michal Borowiecki edited comment on KAFKA-5233 at 7/29/17 9:40 AM: -

[jira] [Commented] (KAFKA-5233) Changes to punctuate semantics (KIP-138)

[ https://issues.apache.org/jira/browse/KAFKA-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106084#comment-16106084 ] Michal Borowiecki commented on KAFKA-5233: -- Yes, my line of thinking was that alt

[jira] [Commented] (KAFKA-5584) Incorrect log size for topics larger than 2 GB

[ https://issues.apache.org/jira/browse/KAFKA-5584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085542#comment-16085542 ] Michal Borowiecki commented on KAFKA-5584: -- Was this a regression in 0.11.0.0 spe

[jira] [Comment Edited] (KAFKA-5546) Lost data when the leader is disconnected.

[ https://issues.apache.org/jira/browse/KAFKA-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071187#comment-16071187 ] Michal Borowiecki edited comment on KAFKA-5546 at 7/1/17 11:38 AM: -

[jira] [Comment Edited] (KAFKA-5546) Lost data when the leader is disconnected.

[ https://issues.apache.org/jira/browse/KAFKA-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071187#comment-16071187 ] Michal Borowiecki edited comment on KAFKA-5546 at 7/1/17 11:37 AM: -

[jira] [Commented] (KAFKA-5546) Lost data when the leader is disconnected.

[ https://issues.apache.org/jira/browse/KAFKA-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071187#comment-16071187 ] Michal Borowiecki commented on KAFKA-5546: -- Does your producer check if sending w

[jira] [Comment Edited] (KAFKA-4750) KeyValueIterator returns null values

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062770#comment-16062770 ] Michal Borowiecki edited comment on KAFKA-4750 at 6/26/17 8:42 AM: -

[jira] [Comment Edited] (KAFKA-4750) KeyValueIterator returns null values

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062770#comment-16062770 ] Michal Borowiecki edited comment on KAFKA-4750 at 6/26/17 8:42 AM: -

[jira] [Comment Edited] (KAFKA-4750) KeyValueIterator returns null values

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062770#comment-16062770 ] Michal Borowiecki edited comment on KAFKA-4750 at 6/26/17 8:33 AM: -

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062770#comment-16062770 ] Michal Borowiecki commented on KAFKA-4750: -- Deserialiser.deserialize javadoc says