[jira] [Created] (KAFKA-7052) ExtractField SMT throws NPE - needs clearer error message

Robin Moffatt created KAFKA-7052: Summary: ExtractField SMT throws NPE - needs clearer error message Key: KAFKA-7052 URL: https://issues.apache.org/jira/browse/KAFKA-7052 Project: Kafka Issue

[jira] [Created] (KAFKA-7053) Spring Kafka SSL producers throwing TimeoutExceptions

Guido Josquin created KAFKA-7053: Summary: Spring Kafka SSL producers throwing TimeoutExceptions Key: KAFKA-7053 URL: https://issues.apache.org/jira/browse/KAFKA-7053 Project: Kafka Issue Typ

[jira] [Updated] (KAFKA-7053) Spring Kafka SSL producers throwing TimeoutExceptions

[ https://issues.apache.org/jira/browse/KAFKA-7053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guido Josquin updated KAFKA-7053: - Description: h1. Problem description Spring Kafka SSL producers are throwing timeouts when produ

[jira] [Commented] (KAFKA-7052) ExtractField SMT throws NPE - needs clearer error message

[ https://issues.apache.org/jira/browse/KAFKA-7052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510814#comment-16510814 ] Robin Moffatt commented on KAFKA-7052: -- Tested on Debezium 0.8 (AK 1.1.0) and Debezi

[jira] [Created] (KAFKA-7054) Kafka describe command should throw topic doesn't exist exception.

Manohar Vanam created KAFKA-7054: Summary: Kafka describe command should throw topic doesn't exist exception. Key: KAFKA-7054 URL: https://issues.apache.org/jira/browse/KAFKA-7054 Project: Kafka

[jira] [Commented] (KAFKA-7054) Kafka describe command should throw topic doesn't exist exception.

[ https://issues.apache.org/jira/browse/KAFKA-7054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510858#comment-16510858 ] Manohar Vanam commented on KAFKA-7054: -- I am not able to assign this issue to myself

[jira] [Updated] (KAFKA-7054) Kafka describe command should throw topic doesn't exist exception.

[ https://issues.apache.org/jira/browse/KAFKA-7054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manohar Vanam updated KAFKA-7054: - Description: If topic doesn't exist then Kafka describe command should throw topic doesn't exist

[jira] [Commented] (KAFKA-6614) kafka-streams to configure internal topics message.timestamp.type=CreateTime

[ https://issues.apache.org/jira/browse/KAFKA-6614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510897#comment-16510897 ] Meghana Gupta commented on KAFKA-6614: -- Hi, I'm new to contributing to Kafka. Can I

[jira] [Commented] (KAFKA-4113) Allow KTable bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510911#comment-16510911 ] Ben Stopford commented on KAFKA-4113: - Whilst I like the 'time-aligned' approach to l

[jira] [Commented] (KAFKA-7054) Kafka describe command should throw topic doesn't exist exception.

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

[jira] [Commented] (KAFKA-7048) NPE when creating connector

[ https://issues.apache.org/jira/browse/KAFKA-7048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511008#comment-16511008 ] Chia-Ping Tsai commented on KAFKA-7048: --- This issue almost destroys the connector o

[jira] [Commented] (KAFKA-7035) Kafka Processor's init() method sometimes is not called

[ https://issues.apache.org/jira/browse/KAFKA-7035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511063#comment-16511063 ] Antony Stubbs commented on KAFKA-7035: -- Call your punctuate processor from the close

[jira] [Updated] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

[ https://issues.apache.org/jira/browse/KAFKA-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikki Thean updated KAFKA-7055: --- Description: The Kafka Streams Processor API allows you to define a Topology and connect sources, pr

[jira] [Created] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

Nikki Thean created KAFKA-7055: -- Summary: Kafka Streams Processor API allows you to add sinks and processors without parent Key: KAFKA-7055 URL: https://issues.apache.org/jira/browse/KAFKA-7055 Project:

[jira] [Updated] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

[ https://issues.apache.org/jira/browse/KAFKA-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikki Thean updated KAFKA-7055: --- Description: The Kafka Streams Processor API allows you to define a Topology and connect sources, pr

[jira] [Commented] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

[ https://issues.apache.org/jira/browse/KAFKA-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511195#comment-16511195 ] Nikki Thean commented on KAFKA-7055: If project reviewers feel this is a reasonable a

[jira] [Updated] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

[ https://issues.apache.org/jira/browse/KAFKA-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikki Thean updated KAFKA-7055: --- Description: The Kafka Streams Processor API allows you to define a Topology and connect sources, pr

[jira] [Updated] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

[ https://issues.apache.org/jira/browse/KAFKA-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikki Thean updated KAFKA-7055: --- Description: The Kafka Streams Processor API allows you to define a Topology and connect sources, pr

[jira] [Updated] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

[ https://issues.apache.org/jira/browse/KAFKA-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikki Thean updated KAFKA-7055: --- Description: The Kafka Streams Processor API allows you to define a Topology and connect sources, pr

[jira] [Commented] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

[ https://issues.apache.org/jira/browse/KAFKA-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511202#comment-16511202 ] Nikki Thean commented on KAFKA-7055: Sorry about the inconsistent link format; Jira d

[jira] [Commented] (KAFKA-7007) Use JSON for /kafka-acl-extended-changes path

[ https://issues.apache.org/jira/browse/KAFKA-7007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511296#comment-16511296 ] Andy Coates commented on KAFKA-7007: Final design was not, as the Jira requested, to

[jira] [Assigned] (KAFKA-6614) kafka-streams to configure internal topics message.timestamp.type=CreateTime

[ https://issues.apache.org/jira/browse/KAFKA-6614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6614: -- Assignee: Meghana Gupta > kafka-streams to configure internal topics message.timestamp

[jira] [Commented] (KAFKA-6614) kafka-streams to configure internal topics message.timestamp.type=CreateTime

[ https://issues.apache.org/jira/browse/KAFKA-6614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511386#comment-16511386 ] Matthias J. Sax commented on KAFKA-6614: Thanks for your interest in contributing

[jira] [Created] (KAFKA-7056) Connect's new numeric converters should be in a different package

Randall Hauch created KAFKA-7056: Summary: Connect's new numeric converters should be in a different package Key: KAFKA-7056 URL: https://issues.apache.org/jira/browse/KAFKA-7056 Project: Kafka

[jira] [Commented] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

[ https://issues.apache.org/jira/browse/KAFKA-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511401#comment-16511401 ] Guozhang Wang commented on KAFKA-7055: -- [~nthean] Thanks for reporting the issue, an

[jira] [Updated] (KAFKA-7056) Connect's new numeric converters should be in a different package

[ https://issues.apache.org/jira/browse/KAFKA-7056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7056: - Description: KIP-305 added several new primitive converters, but placed them alongside {{StringC

[jira] [Comment Edited] (KAFKA-4113) Allow KTable bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510911#comment-16510911 ] Ben Stopford edited comment on KAFKA-4113 at 6/13/18 4:49 PM: -

[jira] [Commented] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

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

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

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

[jira] [Commented] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

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

[jira] [Updated] (KAFKA-6917) Request handler deadlocks attempting to acquire group metadata lock

[ https://issues.apache.org/jira/browse/KAFKA-6917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6917: --- Affects Version/s: (was: 1.0.1) 0.11.0.0 1.0.0 > Re

[jira] [Commented] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation

[ https://issues.apache.org/jira/browse/KAFKA-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511485#comment-16511485 ] ASF GitHub Bot commented on KAFKA-6906: --- mjsax closed pull request #5196: MINOR: co

[jira] [Commented] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

[ https://issues.apache.org/jira/browse/KAFKA-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511489#comment-16511489 ] Matthias J. Sax commented on KAFKA-7055: [~nthean] I just double checked the code

[jira] [Commented] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

[ https://issues.apache.org/jira/browse/KAFKA-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511496#comment-16511496 ] Nikki Thean commented on KAFKA-7055: [~mjsax] Absolutely! Re-running tests, then will

[jira] [Commented] (KAFKA-7037) delete topic command replaces '+' from the topic name which leads incorrect topic deletion

[ https://issues.apache.org/jira/browse/KAFKA-7037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511567#comment-16511567 ] Vahid Hashemian commented on KAFKA-7037: The reason is the {{--topic}} option als

[jira] [Commented] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

[ https://issues.apache.org/jira/browse/KAFKA-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511595#comment-16511595 ] Nikki Thean commented on KAFKA-7055: [~mjsax] [~guozhang] I may have screwed up the G

[jira] [Comment Edited] (KAFKA-7037) delete topic command replaces '+' from the topic name which leads incorrect topic deletion

[ https://issues.apache.org/jira/browse/KAFKA-7037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511567#comment-16511567 ] Vahid Hashemian edited comment on KAFKA-7037 at 6/13/18 7:58 PM: --

[jira] [Comment Edited] (KAFKA-7037) delete topic command replaces '+' from the topic name which leads incorrect topic deletion

[ https://issues.apache.org/jira/browse/KAFKA-7037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511567#comment-16511567 ] Vahid Hashemian edited comment on KAFKA-7037 at 6/13/18 7:58 PM: --

[jira] [Comment Edited] (KAFKA-7037) delete topic command replaces '+' from the topic name which leads incorrect topic deletion

[ https://issues.apache.org/jira/browse/KAFKA-7037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511567#comment-16511567 ] Vahid Hashemian edited comment on KAFKA-7037 at 6/13/18 7:58 PM: --

[jira] [Commented] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

[ https://issues.apache.org/jira/browse/KAFKA-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511616#comment-16511616 ] Matthias J. Sax commented on KAFKA-7055:  No worries. All good :) > Kafka Stream

[jira] [Commented] (KAFKA-6749) TopologyTestDriver fails when topoloy under test uses EXACTLY_ONCE

[ https://issues.apache.org/jira/browse/KAFKA-6749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511683#comment-16511683 ] ASF GitHub Bot commented on KAFKA-6749: --- mjsax closed pull request #4912: KAFKA-674

[jira] [Commented] (KAFKA-6860) NPE when reinitializeStateStores with eos enabled

[ https://issues.apache.org/jira/browse/KAFKA-6860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511726#comment-16511726 ] ASF GitHub Bot commented on KAFKA-6860: --- mjsax closed pull request #5187: KAFKA-686

[jira] [Commented] (KAFKA-6978) Make Streams Window retention time strict

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

[jira] [Commented] (KAFKA-7050) Decrease consumer request timeout to 30s

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

[jira] [Resolved] (KAFKA-7050) Decrease consumer request timeout to 30s

[ https://issues.apache.org/jira/browse/KAFKA-7050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7050. Resolution: Fixed > Decrease consumer request timeout to 30s >

[jira] [Commented] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file

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

[jira] [Updated] (KAFKA-7019) Reduction the contention between metadata update and metadata read operation

[ https://issues.apache.org/jira/browse/KAFKA-7019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7019: Description: Currently MetadataCache.updateCache() grabs a write lock in order to process the UpdateMetada

[jira] [Updated] (KAFKA-5235) GetOffsetShell: retrieve offsets for all given topics and partitions with single request to the broker

[ https://issues.apache.org/jira/browse/KAFKA-5235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5235: --- Labels: kip tool (was: tool) > GetOffsetShell: retrieve offsets for all given topics and partitions

[jira] [Commented] (KAFKA-5235) GetOffsetShell: retrieve offsets for all given topics and partitions with single request to the broker

[ https://issues.apache.org/jira/browse/KAFKA-5235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511854#comment-16511854 ] Ismael Juma commented on KAFKA-5235: KIP link: https://cwiki.apache.org/confluence/d

[jira] [Commented] (KAFKA-7019) Reduction the contention between metadata update and metadata read operation

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

[jira] [Commented] (KAFKA-7056) Connect's new numeric converters should be in a different package

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

[jira] [Commented] (KAFKA-7030) Add configuration to disable message down-conversion

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

[jira] [Updated] (KAFKA-5234) GetOffsetShell: retrieve offsets for multiple topics with single request

[ https://issues.apache.org/jira/browse/KAFKA-5234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5234: --- Fix Version/s: (was: 2.1.0) > GetOffsetShell: retrieve offsets for multiple topics with single re

[jira] [Resolved] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka

[ https://issues.apache.org/jira/browse/KAFKA-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3355. Resolution: Duplicate Fix Version/s: (was: 2.1.0) This will be done as part of KAFKA-523

[jira] [Resolved] (KAFKA-5234) GetOffsetShell: retrieve offsets for multiple topics with single request

[ https://issues.apache.org/jira/browse/KAFKA-5234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5234. Resolution: Duplicate Let's consolidate GetOffsetShell improvements under KAFKA-5235. > GetOffsetS

[jira] [Commented] (KAFKA-5235) GetOffsetShell: retrieve offsets for all given topics and partitions with single request to the broker

[ https://issues.apache.org/jira/browse/KAFKA-5235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511986#comment-16511986 ] Ismael Juma commented on KAFKA-5235: Note that https://github.com/apache/kafka/pull/5