[jira] [Updated] (KAFKA-9322) Add `tail -n` feature for ConsoleConsumer

2019-12-19 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-9322: -- Description: When debugging, it will be convenient to quickly check the last N messages for a partition using

[jira] [Updated] (KAFKA-9322) Add `tail -n` feature for ConsoleConsumer

2019-12-19 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-9322: -- Description: When debugging, it will be convenient to quickly check the last N messages for a partition using

[jira] [Commented] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

2019-12-19 Thread Omkar Mestry (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000668#comment-17000668 ] Omkar Mestry commented on KAFKA-9259: - So should I work on KAFKA-9260 as this would solve the current

[jira] [Created] (KAFKA-9322) Add `tail -n` feature for ConsoleConsumer

2019-12-19 Thread huxihx (Jira)
huxihx created KAFKA-9322: - Summary: Add `tail -n` feature for ConsoleConsumer Key: KAFKA-9322 URL: https://issues.apache.org/jira/browse/KAFKA-9322 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-9317) Provide a group admin command to get group information or do some admin operation

2019-12-19 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000562#comment-17000562 ] huxihx commented on KAFKA-9317: --- Does `kafka-consumer-groups.sh` satisfy your requirement? > Provide a

[jira] [Commented] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic

2019-12-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000476#comment-17000476 ] Matthias J. Sax commented on KAFKA-7663: Well, there is no design yet, but I would assume that we

[jira] [Commented] (KAFKA-9314) Connect put() and poll() retries not conforming to KIP-298

2019-12-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000339#comment-17000339 ] ASF GitHub Bot commented on KAFKA-9314: --- ncliang commented on pull request #7857: KAFKA-9314: Apply

[jira] [Commented] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic

2019-12-19 Thread Levani Kokhreidze (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000278#comment-17000278 ] Levani Kokhreidze commented on KAFKA-7663: -- Hello Matthias, When

[jira] [Commented] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic

2019-12-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000252#comment-17000252 ] Matthias J. Sax commented on KAFKA-7663: Don't think we need a new parameter – if we call the

[jira] [Commented] (KAFKA-9321) StreamsBuilder table method overwrites the materialized parameter

2019-12-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000241#comment-17000241 ] Matthias J. Sax commented on KAFKA-9321: Btw: We plan to add `KStream#toTable()` operator via 

[jira] [Commented] (KAFKA-9321) StreamsBuilder table method overwrites the materialized parameter

2019-12-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000233#comment-17000233 ] Matthias J. Sax commented on KAFKA-9321: The behavior you describe is know and documented in the

[jira] [Resolved] (KAFKA-9321) StreamsBuilder table method overwrites the materialized parameter

2019-12-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9321. Resolution: Duplicate > StreamsBuilder table method overwrites the materialized parameter

[jira] [Assigned] (KAFKA-7317) Use collections subscription for main consumer to reduce metadata

2019-12-19 Thread Apurva Mehta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta reassigned KAFKA-7317: --- Assignee: Sophie Blee-Goldman > Use collections subscription for main consumer to reduce

[jira] [Updated] (KAFKA-9321) StreamsBuilder table method overwrites the materialized parameter

2019-12-19 Thread Stefan Bocutiu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Bocutiu updated KAFKA-9321: -- Description: One of the methods on the StreamsBuilder to create a KTable takes 3 arguments:

[jira] [Updated] (KAFKA-9321) StreamsBuilder table method overwrites the materialized parameter

2019-12-19 Thread Stefan Bocutiu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Bocutiu updated KAFKA-9321: -- Description: One of the methods on the StreamsBuilder to create a KTable takes 3 arguments:

[jira] [Created] (KAFKA-9321) StreamsBuilder table method overwrites the materialized parameter

2019-12-19 Thread Stefan Bocutiu (Jira)
Stefan Bocutiu created KAFKA-9321: - Summary: StreamsBuilder table method overwrites the materialized parameter Key: KAFKA-9321 URL: https://issues.apache.org/jira/browse/KAFKA-9321 Project: Kafka

[jira] [Resolved] (KAFKA-7251) Add support for TLS 1.3

2019-12-19 Thread Rajini Sivaram (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7251. --- Fix Version/s: 2.5.0 Reviewer: Manikumar Resolution: Fixed > Add support for

[jira] [Created] (KAFKA-9320) Enable TLSv1.3 by default and disable some of the older protocols

2019-12-19 Thread Rajini Sivaram (Jira)
Rajini Sivaram created KAFKA-9320: - Summary: Enable TLSv1.3 by default and disable some of the older protocols Key: KAFKA-9320 URL: https://issues.apache.org/jira/browse/KAFKA-9320 Project: Kafka

[jira] [Created] (KAFKA-9319) Run some system tests using TLSv1.3

2019-12-19 Thread Rajini Sivaram (Jira)
Rajini Sivaram created KAFKA-9319: - Summary: Run some system tests using TLSv1.3 Key: KAFKA-9319 URL: https://issues.apache.org/jira/browse/KAFKA-9319 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-9318) Kafka Connect. Add map entry value extraction SMT

2019-12-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1769#comment-1769 ] ASF GitHub Bot commented on KAFKA-9318: --- piotrsmolinski commented on pull request #7856:

[jira] [Resolved] (KAFKA-9316) ConsoleProducer help info not expose default properties

2019-12-19 Thread Manikumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-9316. -- Fix Version/s: 2.5.0 Resolution: Fixed Issue resolved by pull request 7854

[jira] [Created] (KAFKA-9318) Kafka Connect. Add map entry value extraction SMT

2019-12-19 Thread Piotr Smolinski (Jira)
Piotr Smolinski created KAFKA-9318: -- Summary: Kafka Connect. Add map entry value extraction SMT Key: KAFKA-9318 URL: https://issues.apache.org/jira/browse/KAFKA-9318 Project: Kafka Issue

[jira] [Comment Edited] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic

2019-12-19 Thread Levani Kokhreidze (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1663#comment-1663 ] Levani Kokhreidze edited comment on KAFKA-7663 at 12/19/19 11:03 AM: -

[jira] [Commented] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic

2019-12-19 Thread Levani Kokhreidze (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1663#comment-1663 ] Levani Kokhreidze commented on KAFKA-7663: -- Hello, I've stumbled upon this issue. I have a

[jira] [Comment Edited] (KAFKA-9049) TopicCommandWithAdminClientTest should use mocks

2019-12-19 Thread Jono Morris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999856#comment-16999856 ] Jono Morris edited comment on KAFKA-9049 at 12/19/19 9:06 AM: -- A number of

[jira] [Commented] (KAFKA-9049) TopicCommandWithAdminClientTest should use mocks

2019-12-19 Thread Jono Morris (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999856#comment-16999856 ] Jono Morris commented on KAFKA-9049: A number of the tests rely on having those brokers set up.  What

[jira] [Commented] (KAFKA-9317) Provide a group admin command to get group information or do some admin operation

2019-12-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999846#comment-16999846 ] ASF GitHub Bot commented on KAFKA-9317: --- maobaolong commented on pull request #7855: KAFKA-9317.

[jira] [Created] (KAFKA-9317) Provide a group admin command to get group information or do some admin operation

2019-12-19 Thread maobaolong (Jira)
maobaolong created KAFKA-9317: - Summary: Provide a group admin command to get group information or do some admin operation Key: KAFKA-9317 URL: https://issues.apache.org/jira/browse/KAFKA-9317 Project:

[jira] [Commented] (KAFKA-9300) Create a topic based on the specified brokers

2019-12-19 Thread huxihx (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999835#comment-16999835 ] huxihx commented on KAFKA-9300: --- I mean a new config deserves a KIP to have people discuss whether it