[jira] [Commented] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

2018-01-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16321832#comment-16321832 ] Matthias J. Sax commented on KAFKA-6378: Can you open a PR? If yes, please update the JavaDocs

[jira] [Issue Comment Deleted] (KAFKA-6441) FetchRequest populates buffer of size MinBytes, even if response is smaller

2018-01-10 Thread Ivan Babrou (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Babrou updated KAFKA-6441: --- Comment: was deleted (was: With 0.10.2.0 consumer API Sarama is able to get multiple messages in one

[jira] [Commented] (KAFKA-6441) FetchRequest populates buffer of size MinBytes, even if response is smaller

2018-01-10 Thread Ivan Babrou (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16321715#comment-16321715 ] Ivan Babrou commented on KAFKA-6441: With 0.10.2.0 consumer API Sarama is able to get multiple

[jira] [Commented] (KAFKA-6441) FetchRequest populates buffer of size MinBytes, even if response is smaller

2018-01-10 Thread Ivan Babrou (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16321716#comment-16321716 ] Ivan Babrou commented on KAFKA-6441: With 0.10.2.0 consumer API Sarama is able to get multiple

[jira] [Created] (KAFKA-6441) FetchRequest populates buffer of size MinBytes, even if response is smaller

2018-01-10 Thread Ivan Babrou (JIRA)
Ivan Babrou created KAFKA-6441: -- Summary: FetchRequest populates buffer of size MinBytes, even if response is smaller Key: KAFKA-6441 URL: https://issues.apache.org/jira/browse/KAFKA-6441 Project: Kafka

[jira] [Commented] (KAFKA-6265) GlobalKTable missing #queryableStoreName()

2018-01-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16321568#comment-16321568 ] ASF GitHub Bot commented on KAFKA-6265: --- ConcurrencyPractitioner opened a new pull request #4413:

[jira] [Commented] (KAFKA-6265) GlobalKTable missing #queryableStoreName()

2018-01-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16321551#comment-16321551 ] ASF GitHub Bot commented on KAFKA-6265: --- ConcurrencyPractitioner closed pull request #4412:

[jira] [Commented] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

2018-01-10 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16321393#comment-16321393 ] Ted Yu commented on KAFKA-6378: --- Here is the two line change : {code} diff --git

[jira] [Commented] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

2018-01-10 Thread Andy Bryant (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16321374#comment-16321374 ] Andy Bryant commented on KAFKA-6378: A sentinel value is ok where only a subset of the available

[jira] [Assigned] (KAFKA-6205) Have State Stores Restore Before Initializing Toplogy

2018-01-10 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-6205: -- Assignee: Bill Bejeck > Have State Stores Restore Before Initializing Toplogy >

[jira] [Assigned] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

2018-01-10 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-4969: -- Assignee: Bill Bejeck > State-store workload-aware StreamsPartitionAssignor >

[jira] [Commented] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

2018-01-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16321183#comment-16321183 ] ASF GitHub Bot commented on KAFKA-4969: --- bbejeck opened a new pull request #4410: KAFKA-4969:

[jira] [Commented] (KAFKA-4711) Change Default unclean.leader.election.enabled from True to False (KIP-106)

2018-01-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16321146#comment-16321146 ] ASF GitHub Bot commented on KAFKA-4711: --- junrao closed pull request #3567: KAFKA-4711: fix docs

[jira] [Updated] (KAFKA-6440) Expose Connect leader via REST

2018-01-10 Thread Ryan P (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan P updated KAFKA-6440: -- Description:

[jira] [Updated] (KAFKA-6440) Expose Connect leader via REST

2018-01-10 Thread Ryan P (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan P updated KAFKA-6440: -- Description:

[jira] [Commented] (KAFKA-6440) Expose Connect leader via REST

2018-01-10 Thread Ryan P (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16321028#comment-16321028 ] Ryan P commented on KAFKA-6440: --- [~rhauch] +1, editing description to accommodate this > Expose Connect

[jira] [Created] (KAFKA-6440) Expose Connect leader via REST

2018-01-10 Thread Ryan P (JIRA)
Ryan P created KAFKA-6440: - Summary: Expose Connect leader via REST Key: KAFKA-6440 URL: https://issues.apache.org/jira/browse/KAFKA-6440 Project: Kafka Issue Type: Improvement Components:

[jira] [Updated] (KAFKA-6440) Expose Connect leader via REST

2018-01-10 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6440: - Labels: needs-kip (was: ) > Expose Connect leader via REST > -- > >

[jira] [Updated] (KAFKA-6435) Application Reset Tool might delete incorrect internal topics

2018-01-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6435: - Labels: bug (was: ) > Application Reset Tool might delete incorrect internal topics >

[jira] [Updated] (KAFKA-6412) Improve synchronization in CachingKeyValueStore methods

2018-01-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6412: - Labels: (was: bug) > Improve synchronization in CachingKeyValueStore methods >

[jira] [Updated] (KAFKA-6412) Improve synchronization in CachingKeyValueStore methods

2018-01-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6412: - Labels: bug (was: ) > Improve synchronization in CachingKeyValueStore methods >

[jira] [Updated] (KAFKA-6437) Streams does not warn about missing input topics, but hangs

2018-01-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6437: - Labels: newbie (was: ) > Streams does not warn about missing input topics, but hangs >

[jira] [Commented] (KAFKA-6412) Improve synchronization in CachingKeyValueStore methods

2018-01-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16320898#comment-16320898 ] Guozhang Wang commented on KAFKA-6412: -- [~tedyu] way to start 2018 indeed :) > Improve

[jira] [Assigned] (KAFKA-6412) Improve synchronization in CachingKeyValueStore methods

2018-01-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-6412: Assignee: Ted Yu > Improve synchronization in CachingKeyValueStore methods >

[jira] [Commented] (KAFKA-6398) Non-aggregation KTable generation operator does not construct value getter correctly

2018-01-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16320888#comment-16320888 ] ASF GitHub Bot commented on KAFKA-6398: --- guozhangwang closed pull request #4384: KAFKA-6398: fix

[jira] [Commented] (KAFKA-6438) NSEE while concurrently creating and deleting a topic

2018-01-10 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16320694#comment-16320694 ] Ted Yu commented on KAFKA-6438: --- Two maps are accessed in updateMetadataRequestPartitionInfo():

[jira] [Commented] (KAFKA-6437) Streams does not warn about missing input topics, but hangs

2018-01-10 Thread Chris Schwarzfischer (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16320675#comment-16320675 ] Chris Schwarzfischer commented on KAFKA-6437: - Yep, I know it's by design and that doesn't

[jira] [Updated] (KAFKA-6438) NSEE while concurrently creating and deleting a topic

2018-01-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6438: --- Fix Version/s: 1.1.0 > NSEE while concurrently creating and deleting a topic >

[jira] [Updated] (KAFKA-6438) NSEE while concurrently creating and deleting a topic

2018-01-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6438: --- Labels: reliability (was: ) > NSEE while concurrently creating and deleting a topic >

[jira] [Updated] (KAFKA-6438) NSEE while concurrently creating and deleting a topic

2018-01-10 Thread Adam Kotwasinski (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adam Kotwasinski updated KAFKA-6438: Description: It appears that deleting a topic and creating it at the same time can cause

[jira] [Commented] (KAFKA-6437) Streams does not warn about missing input topics, but hangs

2018-01-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16320641#comment-16320641 ] Matthias J. Sax commented on KAFKA-6437: I cannot follow. What do you mean by "it handgs in the

[jira] [Commented] (KAFKA-3625) Move kafka-streams test fixtures into a published package

2018-01-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16320631#comment-16320631 ] Matthias J. Sax commented on KAFKA-3625: Thanks a lot for this feedback! This is super helpful!

[jira] [Comment Edited] (KAFKA-3625) Move kafka-streams test fixtures into a published package

2018-01-10 Thread Scott Davis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16320605#comment-16320605 ] Scott Davis edited comment on KAFKA-3625 at 1/10/18 4:45 PM: - FYI I just setup

[jira] [Commented] (KAFKA-3625) Move kafka-streams test fixtures into a published package

2018-01-10 Thread Scott Davis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16320605#comment-16320605 ] Scott Davis commented on KAFKA-3625: FYI I just setup some unit tests using the (not documented)

[jira] [Updated] (KAFKA-6439) "com.streamsets.pipeline.api.StageException: KAFKA_50 - Error writing data to the Kafka broker: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.Ne

2018-01-10 Thread srithar durairaj (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] srithar durairaj updated KAFKA-6439: Affects Version/s: 0.10.0.1 Environment: Ubuntu 64bit Description: We

[jira] [Created] (KAFKA-6439) We are using streamset to produce data into kafka topic (3 node cluster). We are facing following error frequently in production.

2018-01-10 Thread srithar durairaj (JIRA)
srithar durairaj created KAFKA-6439: --- Summary: We are using streamset to produce data into kafka topic (3 node cluster). We are facing following error frequently in production. Key: KAFKA-6439 URL:

[jira] [Commented] (KAFKA-6437) Streams does not warn about missing input topics, but hangs

2018-01-10 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16320487#comment-16320487 ] Bill Bejeck commented on KAFKA-6437: [~k1th] thanks for reporting. > Streams does not warn about

[jira] [Updated] (KAFKA-6437) Streams does not warn about missing input topics, but hangs

2018-01-10 Thread Chris Schwarzfischer (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Schwarzfischer updated KAFKA-6437: Issue Type: Improvement (was: Bug) > Streams does not warn about missing input

[jira] [Updated] (KAFKA-6437) Streams does not warn about missing input topics, but hangs

2018-01-10 Thread Chris Schwarzfischer (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Schwarzfischer updated KAFKA-6437: Description: *Case* Streams application with two input topics being used for a left

[jira] [Resolved] (KAFKA-2331) Kafka does not spread partitions in a topic among all consumers evenly

2018-01-10 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2331. -- Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported, please upgrade

[jira] [Resolved] (KAFKA-2329) Consumers balance fails when multiple consumers are started simultaneously.

2018-01-10 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2329. -- Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported, please upgrade

[jira] [Resolved] (KAFKA-2025) In multi-consumer setup - explicit commit, commits on all partitions

2018-01-10 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2025. -- Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported, please upgrade

[jira] [Updated] (KAFKA-5946) Give connector method parameter better name

2018-01-10 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5946: -- Labels: connector newbie usability (was: connector usability) > Give connector method parameter better name >

[jira] [Resolved] (KAFKA-1229) Reload broker config without a restart

2018-01-10 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1229. -- Resolution: Duplicate Resolving as duplicate of KIP-226/KAFKA-6240. Pls reopen of any concern. >

[jira] [Commented] (KAFKA-6412) Improve synchronization in CachingKeyValueStore methods

2018-01-10 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16320047#comment-16320047 ] Ted Yu commented on KAFKA-6412: --- I came up with the initial idea for this JIRA when sitting in hotel lobby

[jira] [Commented] (KAFKA-6412) Improve synchronization in CachingKeyValueStore methods

2018-01-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16320013#comment-16320013 ] ASF GitHub Bot commented on KAFKA-6412: --- dguy closed pull request #4372: KAFKA-6412 Improve

[jira] [Resolved] (KAFKA-6412) Improve synchronization in CachingKeyValueStore methods

2018-01-10 Thread Damian Guy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-6412. --- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request 4372

[jira] [Commented] (KAFKA-4029) SSL support for Connect REST API

2018-01-10 Thread Jakub Scholz (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16319960#comment-16319960 ] Jakub Scholz commented on KAFKA-4029: - [~rhauch] Yeah, I have something already. If you want I can

[jira] [Assigned] (KAFKA-5624) Unsafe use of expired sensors

2018-01-10 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-5624: Assignee: Manikumar > Unsafe use of expired sensors > - > >