[jira] [Created] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

2018-10-23 Thread JIRA
Sebastian Puzoń created KAFKA-7531: -- Summary: NPE NullPointerException at TransactionCoordinator handleEndTransaction Key: KAFKA-7531 URL: https://issues.apache.org/jira/browse/KAFKA-7531 Project: Ka

[jira] [Updated] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

2018-10-23 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7531: --- Fix Version/s: 2.0.2 2.1.1 > NPE NullPointerException at TransactionCoordinator ha

[jira] [Updated] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

2018-10-23 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7531: --- Priority: Critical (was: Major) > NPE NullPointerException at TransactionCoordinator handleEndTransa

[jira] [Created] (KAFKA-7532) Missing stringification in error message "Removed ArrayBuffer() from list of shutting down brokers. (kafka.controller.KafkaController)"

2018-10-23 Thread Andreas Kohn (JIRA)
Andreas Kohn created KAFKA-7532: --- Summary: Missing stringification in error message "Removed ArrayBuffer() from list of shutting down brokers. (kafka.controller.KafkaController)" Key: KAFKA-7532 URL: https://issues

[jira] [Updated] (KAFKA-7532) Missing stringification in error message "Removed ArrayBuffer() from list of shutting down brokers. (kafka.controller.KafkaController)"

2018-10-23 Thread Andreas Kohn (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andreas Kohn updated KAFKA-7532: Description: Messages I saw in my logs: {noformat} [2018-10-23 12:19:59,975] INFO [RequestSendThrea

[jira] [Created] (KAFKA-7534) Error during CachingKeyValueStore.flush may not allow RocksDB to close

2018-10-23 Thread Bill Bejeck (JIRA)
Bill Bejeck created KAFKA-7534: -- Summary: Error during CachingKeyValueStore.flush may not allow RocksDB to close Key: KAFKA-7534 URL: https://issues.apache.org/jira/browse/KAFKA-7534 Project: Kafka

[jira] [Updated] (KAFKA-7533) Kafka consumer does not poll after commit

2018-10-23 Thread Mikhail Nemenko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikhail Nemenko updated KAFKA-7533: --- Description: Hello,  I'm trying to fetch records after commit transaction. I used read commit

[jira] [Updated] (KAFKA-7533) Kafka consumer does not poll after commit

2018-10-23 Thread Mikhail Nemenko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikhail Nemenko updated KAFKA-7533: --- Attachment: log.txt > Kafka consumer does not poll after commit > ---

[jira] [Assigned] (KAFKA-7532) Missing stringification in error message "Removed ArrayBuffer() from list of shutting down brokers. (kafka.controller.KafkaController)"

2018-10-23 Thread Stanislav Kozlovski (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-7532: -- Assignee: Stanislav Kozlovski > Missing stringification in error message "Remo

[jira] [Commented] (KAFKA-7532) Missing stringification in error message "Removed ArrayBuffer() from list of shutting down brokers. (kafka.controller.KafkaController)"

2018-10-23 Thread Stanislav Kozlovski (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660821#comment-16660821 ] Stanislav Kozlovski commented on KAFKA-7532: Thanks for reporting this [~anko

[jira] [Commented] (KAFKA-7532) Missing stringification in error message "Removed ArrayBuffer() from list of shutting down brokers. (kafka.controller.KafkaController)"

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660825#comment-16660825 ] ASF GitHub Bot commented on KAFKA-7532: --- stanislavkozlovski opened a new pull reque

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

2018-10-23 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660868#comment-16660868 ] Sönke Liebau commented on KAFKA-7509: - Hi [~rhauch], wouldn't this take away the abil

[jira] [Created] (KAFKA-7535) KafkaConsumer doesn't report records-lag if isolation.level is read_committed

2018-10-23 Thread Alexey Vakhrenev (JIRA)
Alexey Vakhrenev created KAFKA-7535: --- Summary: KafkaConsumer doesn't report records-lag if isolation.level is read_committed Key: KAFKA-7535 URL: https://issues.apache.org/jira/browse/KAFKA-7535 Pro

[jira] [Resolved] (KAFKA-5824) Cannot write to key value store provided by ProcessorTopologyTestDriver

2018-10-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5824. Resolution: Won't Fix Resolving this, because `ProcessorTopologyTestDriver` is an internal

[jira] [Commented] (KAFKA-7529) Kafka Connect JDBC doesn't push new records to Kafka Topic unless the connector is restarted

2018-10-23 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-7529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16661078#comment-16661078 ] Sönke Liebau commented on KAFKA-7529: - Hi [~kivaturi], I am fairly certain that there

[jira] [Updated] (KAFKA-7536) TopologyTestDriver cannot pre-populate GlobalKTable

2018-10-23 Thread Dmitry Minkovsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Minkovsky updated KAFKA-7536: Affects Version/s: 2.0.0 Component/s: streams > TopologyTestDriver cannot pre-pop

[jira] [Created] (KAFKA-7536) TopologyTestDriver cannot pre-populate GlobalKTable

2018-10-23 Thread Dmitry Minkovsky (JIRA)
Dmitry Minkovsky created KAFKA-7536: --- Summary: TopologyTestDriver cannot pre-populate GlobalKTable Key: KAFKA-7536 URL: https://issues.apache.org/jira/browse/KAFKA-7536 Project: Kafka Issue

[jira] [Updated] (KAFKA-7536) TopologyTestDriver cannot pre-populate GlobalKTable

2018-10-23 Thread Dmitry Minkovsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Minkovsky updated KAFKA-7536: Description: I have a GlobalKTable that's defined as {code} GlobalKTable userIdsByEmail =

[jira] [Updated] (KAFKA-5403) Transactions system test should dedup consumed messages by offset

2018-10-23 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5403: Fix Version/s: (was: 2.1.0) > Transactions system test should dedup consumed messages by offset > -

[jira] [Updated] (KAFKA-4690) IllegalStateException using DeleteTopicsRequest when delete.topic.enable=false

2018-10-23 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4690: Fix Version/s: (was: 2.1.0) > IllegalStateException using DeleteTopicsRequest when delete.topic.enable=

[jira] [Updated] (KAFKA-6045) All access to log should fail if log is closed

2018-10-23 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6045: Fix Version/s: (was: 2.1.0) > All access to log should fail if log is closed >

[jira] [Updated] (KAFKA-5857) Excessive heap usage on controller node during reassignment

2018-10-23 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5857: Fix Version/s: (was: 2.1.0) > Excessive heap usage on controller node during reassignment > ---

[jira] [Updated] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

2018-10-23 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7481: Fix Version/s: (was: 2.1.0) > Consider options for safer upgrade of offset commit value schema > --

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

2018-10-23 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16661482#comment-16661482 ] Dong Lin commented on KAFKA-7481: - I removed 2.1.0 tag so that release.py would generate

[jira] [Commented] (KAFKA-7536) TopologyTestDriver cannot pre-populate GlobalKTable

2018-10-23 Thread Dmitry Minkovsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16661490#comment-16661490 ] Dmitry Minkovsky commented on KAFKA-7536: - Remarkable that https://issues.apache.

[jira] [Commented] (KAFKA-7534) Error during CachingKeyValueStore.flush may not allow RocksDB to close

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16661522#comment-16661522 ] ASF GitHub Bot commented on KAFKA-7534: --- bbejeck opened a new pull request #5833: K

[jira] [Updated] (KAFKA-7536) TopologyTestDriver cannot pre-populate GlobalKTable

2018-10-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7536: --- Priority: Minor (was: Major) > TopologyTestDriver cannot pre-populate GlobalKTable > ---

[jira] [Commented] (KAFKA-7536) TopologyTestDriver cannot pre-populate GlobalKTable

2018-10-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16661564#comment-16661564 ] Matthias J. Sax commented on KAFKA-7536: Thanks for reporting this. Closing the o

[jira] [Commented] (KAFKA-7536) TopologyTestDriver cannot pre-populate GlobalKTable

2018-10-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16661567#comment-16661567 ] Matthias J. Sax commented on KAFKA-7536: Another workaround might be, to disable

[jira] [Commented] (KAFKA-7510) KStreams RecordCollectorImpl leaks data to logs on error

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16661665#comment-16661665 ] ASF GitHub Bot commented on KAFKA-7510: --- forficate opened a new pull request #5834:

[jira] [Assigned] (KAFKA-7535) KafkaConsumer doesn't report records-lag if isolation.level is read_committed

2018-10-23 Thread lambdaliu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lambdaliu reassigned KAFKA-7535: Assignee: lambdaliu > KafkaConsumer doesn't report records-lag if isolation.level is read_committe

[jira] [Commented] (KAFKA-7535) KafkaConsumer doesn't report records-lag if isolation.level is read_committed

2018-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16661786#comment-16661786 ] ASF GitHub Bot commented on KAFKA-7535: --- lambdaliu opened a new pull request #5835:

[jira] [Commented] (KAFKA-7535) KafkaConsumer doesn't report records-lag if isolation.level is read_committed

2018-10-23 Thread lambdaliu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16661789#comment-16661789 ] lambdaliu commented on KAFKA-7535: -- bug introduced from this [PR|https://github.com/apac