[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417038#comment-16417038 ] Ionut-Maxim Margelatu commented on KAFKA-5882: -- We are encountering the same

[jira] [Updated] (KAFKA-6718) Rack Aware Replica Task Assignment for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Surana updated KAFKA-6718: - Description: |Machines in data centre are sometimes grouped in racks. Racks provide isolation as

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417158#comment-16417158 ] Ionut-Maxim Margelatu commented on KAFKA-5882: -- We have been able to consiste

[jira] [Commented] (KAFKA-6718) Rack Aware Replica Task Assignment for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417173#comment-16417173 ] Deepak Goyal commented on KAFKA-6718: - Meanwhile, please look at the PR: [https://gith

[jira] [Comment Edited] (KAFKA-6684) Support casting values with bytes schema to string

[ https://issues.apache.org/jira/browse/KAFKA-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406470#comment-16406470 ] Amit Sela edited comment on KAFKA-6684 at 3/28/18 1:32 PM: --- [~ha

[jira] [Created] (KAFKA-6724) ConsumerPerformance resets offsets on every startup

Alex Dunayevsky created KAFKA-6724: -- Summary: ConsumerPerformance resets offsets on every startup Key: KAFKA-6724 URL: https://issues.apache.org/jira/browse/KAFKA-6724 Project: Kafka Issue T

[jira] [Commented] (KAFKA-6724) ConsumerPerformance resets offsets on every startup

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

[jira] [Commented] (KAFKA-6716) discardChannel should be released in MockSelector#completeSend

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

[jira] [Updated] (KAFKA-6724) ConsumerPerformance resets offsets on every startup

[ https://issues.apache.org/jira/browse/KAFKA-6724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-6724: --- Reviewer: Alex Dunayevsky > ConsumerPerformance resets offsets on every startup >

[jira] [Updated] (KAFKA-6724) ConsumerPerformance resets offsets on every startup

[ https://issues.apache.org/jira/browse/KAFKA-6724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-6724: --- Reviewer: (was: Alex Dunayevsky) > ConsumerPerformance resets offsets on every startup > ---

[jira] [Commented] (KAFKA-6723) Separate "max.poll.record" for restore consumer and common consumer

[ https://issues.apache.org/jira/browse/KAFKA-6723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417697#comment-16417697 ] Boyang Chen commented on KAFKA-6723: [~mjsax]  [~guozhang] I haven't seen a concrete d

[jira] [Commented] (KAFKA-6598) Kafka to support using ETCD beside Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417741#comment-16417741 ] Ismael Juma commented on KAFKA-6598: This was discussed before when "KIP-30: Allow for

[jira] [Assigned] (KAFKA-5253) TopologyTestDriver must handle streams created with patterns

[ https://issues.apache.org/jira/browse/KAFKA-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadesh Adireddi reassigned KAFKA-5253: Assignee: Jagadesh Adireddi > TopologyTestDriver must handle streams created with p

[jira] [Updated] (KAFKA-6538) Enhance ByteStore exceptions with more context information

[ https://issues.apache.org/jira/browse/KAFKA-6538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6538: - Description: In KIP-182 we refactored all stores to by plain {{Bytes/byte[]}} stores and only hav

[jira] [Commented] (KAFKA-6642) Rack aware task assignment in kafka streams

[ https://issues.apache.org/jira/browse/KAFKA-6642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417805#comment-16417805 ] Guozhang Wang commented on KAFKA-6642: -- [~asurana] Thanks for creating this ticket, I

[jira] [Updated] (KAFKA-6376) Improve Streams metrics for skipped records

[ https://issues.apache.org/jira/browse/KAFKA-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-6376: Issue Type: Improvement (was: Bug) > Improve Streams metrics for skipped records >

[jira] [Resolved] (KAFKA-6724) ConsumerPerformance resets offsets on every startup

[ https://issues.apache.org/jira/browse/KAFKA-6724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6724. Resolution: Fixed Fix Version/s: 1.2.0 > ConsumerPerformance resets offsets on every

[jira] [Commented] (KAFKA-6724) ConsumerPerformance resets offsets on every startup

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

[jira] [Updated] (KAFKA-6376) Improve Streams metrics for skipped records

[ https://issues.apache.org/jira/browse/KAFKA-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-6376: Affects Version/s: (was: 1.0.0) 1.2.0 > Improve Streams metrics for skipp

[jira] [Commented] (KAFKA-6723) Separate "max.poll.record" for restore consumer and common consumer

[ https://issues.apache.org/jira/browse/KAFKA-6723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417856#comment-16417856 ] Guozhang Wang commented on KAFKA-6723: -- The proposal is to have a prefix for restore

[jira] [Commented] (KAFKA-6657) Add StreamsConfig prefix for different consumers

[ https://issues.apache.org/jira/browse/KAFKA-6657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417858#comment-16417858 ] Guozhang Wang commented on KAFKA-6657: -- Hello Siva, are you still working on this tic

[jira] [Updated] (KAFKA-6376) Improve Streams metrics for skipped records

[ https://issues.apache.org/jira/browse/KAFKA-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6376: --- Affects Version/s: (was: 1.2.0) 1.0.0 > Improve Streams metrics for

[jira] [Commented] (KAFKA-5253) TopologyTestDriver must handle streams created with patterns

[ https://issues.apache.org/jira/browse/KAFKA-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417896#comment-16417896 ] Jagadesh Adireddi commented on KAFKA-5253: -- Hi [~mjsax], I am new to Kafka cont

[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=16417922#comment-16417922 ] John Roesler commented on KAFKA-6474: - Hey [~h314to], I hope you're doing well. FYI,

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417926#comment-16417926 ] Guozhang Wang commented on KAFKA-5882: -- Thanks Vikas, Ionut-Maxim for reporting this

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417946#comment-16417946 ] Guozhang Wang commented on KAFKA-5882: -- Filed https://github.com/apache/kafka/pull/47

[jira] [Commented] (KAFKA-6713) Provide an easy way replace store with a custom one on High-Level Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-6713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417959#comment-16417959 ] Cemalettin Koç commented on KAFKA-6713: --- Hi [~guozhang],  For 1 and 2) I would lik

[jira] [Updated] (KAFKA-6684) Support casting values with bytes schema to string

[ https://issues.apache.org/jira/browse/KAFKA-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated KAFKA-6684: - Description: Casting from BYTES is not supported, which means that casting LogicalTypes is not supported.

[jira] [Updated] (KAFKA-6684) Support casting values with bytes schema to string

[ https://issues.apache.org/jira/browse/KAFKA-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated KAFKA-6684: - Description: Casting from BYTES is not supported, which means that casting LogicalTypes is not supported.

[jira] [Updated] (KAFKA-6684) Support casting values with bytes schema to string

[ https://issues.apache.org/jira/browse/KAFKA-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated KAFKA-6684: - Description: Casting from BYTES is not supported, which means that casting LogicalTypes is not supported.

[jira] [Updated] (KAFKA-6684) Support casting values with bytes schema to string

[ https://issues.apache.org/jira/browse/KAFKA-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated KAFKA-6684: - Description: Casting from BYTES is not supported, which means that casting LogicalTypes is not supported.

[jira] [Commented] (KAFKA-6376) Improve Streams metrics for skipped records

[ https://issues.apache.org/jira/browse/KAFKA-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418023#comment-16418023 ] John Roesler commented on KAFKA-6376: - Thread-level metric looks like it only counts t

[jira] [Comment Edited] (KAFKA-6376) Improve Streams metrics for skipped records

[ https://issues.apache.org/jira/browse/KAFKA-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418023#comment-16418023 ] John Roesler edited comment on KAFKA-6376 at 3/28/18 7:55 PM: --

[jira] [Commented] (KAFKA-6657) Add StreamsConfig prefix for different consumers

[ https://issues.apache.org/jira/browse/KAFKA-6657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418027#comment-16418027 ] siva santhalingam commented on KAFKA-6657: -- [~guozhang] I have not started on thi

[jira] [Comment Edited] (KAFKA-6376) Improve Streams metrics for skipped records

[ https://issues.apache.org/jira/browse/KAFKA-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418023#comment-16418023 ] John Roesler edited comment on KAFKA-6376 at 3/28/18 8:00 PM: --

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

[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418073#comment-16418073 ] Daniel Wojda commented on KAFKA-6437: - I would like to add my comment as a user of Kaf

[jira] [Commented] (KAFKA-6720) Inconsistent Kafka Streams behaviour when topic does not exist

[ https://issues.apache.org/jira/browse/KAFKA-6720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418077#comment-16418077 ] Daniel Wojda commented on KAFKA-6720: - [~johnma] Are you sure that this issue is resol

[jira] [Commented] (KAFKA-6720) Inconsistent Kafka Streams behaviour when topic does not exist

[ https://issues.apache.org/jira/browse/KAFKA-6720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418089#comment-16418089 ] Mariam John commented on KAFKA-6720: [~wojda] if you look at the resolved tag, it is m

[jira] [Commented] (KAFKA-6720) Inconsistent Kafka Streams behaviour when topic does not exist

[ https://issues.apache.org/jira/browse/KAFKA-6720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418090#comment-16418090 ] Daniel Wojda commented on KAFKA-6720: - My mistake [~johnma]. That makes sense. Thank y

[jira] [Commented] (KAFKA-6598) Kafka to support using ETCD beside Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418097#comment-16418097 ] Ismael Juma commented on KAFKA-6598: Here's a link:  https://lists.apache.org/thread.h

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418101#comment-16418101 ] Vikas Tikoo commented on KAFKA-5882: Guozhang Wang: Here's rest of the log trace -  {c

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418106#comment-16418106 ] Matthias J. Sax commented on KAFKA-5882: Changing the structure of the topology is

[jira] [Commented] (KAFKA-5253) TopologyTestDriver must handle streams created with patterns

[ https://issues.apache.org/jira/browse/KAFKA-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418111#comment-16418111 ] Matthias J. Sax commented on KAFKA-5253: Thanks for working on this. If the fix do

[jira] [Assigned] (KAFKA-6657) Add StreamsConfig prefix for different consumers

[ https://issues.apache.org/jira/browse/KAFKA-6657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-6657: Assignee: (was: siva santhalingam) > Add StreamsConfig prefix for different consumers >

[jira] [Resolved] (KAFKA-6723) Separate "max.poll.record" for restore consumer and common consumer

[ https://issues.apache.org/jira/browse/KAFKA-6723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6723. -- Resolution: Duplicate > Separate "max.poll.record" for restore consumer and common consumer > --

[jira] [Commented] (KAFKA-6723) Separate "max.poll.record" for restore consumer and common consumer

[ https://issues.apache.org/jira/browse/KAFKA-6723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418114#comment-16418114 ] Guozhang Wang commented on KAFKA-6723: -- Boyang, I'm going to mark this ticket as subs

[jira] [Commented] (KAFKA-6657) Add StreamsConfig prefix for different consumers

[ https://issues.apache.org/jira/browse/KAFKA-6657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418117#comment-16418117 ] Guozhang Wang commented on KAFKA-6657: -- Thanks [~sssanthalingam], I'm unassigning sin

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

[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418131#comment-16418131 ] Matthias J. Sax commented on KAFKA-6437: [~wojda] Thanks for follow up. With regar

[jira] [Commented] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException

[ https://issues.apache.org/jira/browse/KAFKA-6417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418143#comment-16418143 ] Chris Egerton commented on KAFKA-6417: -- [~cotedm] Alright, took another look at the C

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

[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418185#comment-16418185 ] Mariam John commented on KAFKA-6437: [~mjsax] what do you mean by partially available

[jira] [Commented] (KAFKA-6376) Improve Streams metrics for skipped records

[ https://issues.apache.org/jira/browse/KAFKA-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418195#comment-16418195 ] John Roesler commented on KAFKA-6376: - I have created a KIP to solve these issues:  ht

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

[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418207#comment-16418207 ] Matthias J. Sax commented on KAFKA-6437: I mean that some topics are available but

[jira] [Updated] (KAFKA-6376) Improve Streams metrics for skipped records

[ https://issues.apache.org/jira/browse/KAFKA-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6376: --- Labels: kip (was: needs-kip) > Improve Streams metrics for skipped records >

[jira] [Updated] (KAFKA-6376) Improve Streams metrics for skipped records

[ https://issues.apache.org/jira/browse/KAFKA-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6376: --- Description: Copy this from KIP-210 discussion thread: {quote} Note that currently we have tw

[jira] [Created] (KAFKA-6725) Indicate "isClosing" in the SinkTaskContext

Matt Farmer created KAFKA-6725: -- Summary: Indicate "isClosing" in the SinkTaskContext Key: KAFKA-6725 URL: https://issues.apache.org/jira/browse/KAFKA-6725 Project: Kafka Issue Type: New Feature

[jira] [Assigned] (KAFKA-6657) Add StreamsConfig prefix for different consumers

[ https://issues.apache.org/jira/browse/KAFKA-6657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-6657: -- Assignee: Boyang Chen > Add StreamsConfig prefix for different consumers >

[jira] [Commented] (KAFKA-6657) Add StreamsConfig prefix for different consumers

[ https://issues.apache.org/jira/browse/KAFKA-6657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418337#comment-16418337 ] Boyang Chen commented on KAFKA-6657: [~guozhang]thanks Guozhang! I will take a look at

[jira] [Commented] (KAFKA-6717) TopicPartition Assined twice to a consumer group for 2 consumer instances

[ https://issues.apache.org/jira/browse/KAFKA-6717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418435#comment-16418435 ] Ewen Cheslack-Postava commented on KAFKA-6717: -- Are both assigned the partiti

[jira] [Updated] (KAFKA-6706) NETWORK_EXCEPTION and REQUEST_TIMED_OUT in mirrormaker producer after 1.0 broker upgrade

[ https://issues.apache.org/jira/browse/KAFKA-6706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Shang updated KAFKA-6706: Priority: Blocker (was: Major) Description: We have 2 clusters A and B with 4 brokers each, we use m

[jira] [Updated] (KAFKA-6706) NETWORK_EXCEPTION and REQUEST_TIMED_OUT in mirrormaker producer after 1.0 broker upgrade

[ https://issues.apache.org/jira/browse/KAFKA-6706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Shang updated KAFKA-6706: Description: We have 2 clusters A and B with 4 brokers each, we use mirrormaker to replicate topics from A

[jira] [Updated] (KAFKA-6706) NETWORK_EXCEPTION and REQUEST_TIMED_OUT in mirrormaker producer after 1.0 broker upgrade

[ https://issues.apache.org/jira/browse/KAFKA-6706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Shang updated KAFKA-6706: Description: We have 2 clusters A and B with 4 brokers each, we use mirrormaker to replicate topics from A

[jira] [Commented] (KAFKA-5253) TopologyTestDriver must handle streams created with patterns

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