[jira] [Updated] (KAFKA-8915) Unable to modify partition

2019-09-17 Thread Lee Dongjin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-8915: --- Summary: Unable to modify partition (was: 无法修改partition) > Unable to modify partition >

[jira] [Comment Edited] (KAFKA-8910) Incorrect javadoc at KafkaProducer.InterceptorCallback#onCompletion

2019-09-16 Thread Lee Dongjin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930619#comment-16930619 ] Lee Dongjin edited comment on KAFKA-8910 at 9/16/19 2:48 PM: - I reviewed the

[jira] [Updated] (KAFKA-8910) Incorrect javadoc at KafkaProducer.InterceptorCallback#onCompletion

2019-09-16 Thread Lee Dongjin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-8910: --- Summary: Incorrect javadoc at KafkaProducer.InterceptorCallback#onCompletion (was: Incorrect

[jira] [Updated] (KAFKA-8910) Incorrect javadoc at org.apache.kafka.clients.producer.KafkaProducer.InterceptorCallback#onCompletion

2019-09-16 Thread Lee Dongjin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-8910: --- Description: h1. Problem Javadoc for 

[jira] [Assigned] (KAFKA-8910) Incorrect javadoc at org.apache.kafka.clients.producer.KafkaProducer.InterceptorCallback#onCompletion

2019-09-16 Thread Lee Dongjin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-8910: -- Assignee: Lee Dongjin > Incorrect javadoc at >

[jira] [Updated] (KAFKA-8910) Incorrect javadoc at org.apache.kafka.clients.producer.KafkaProducer.InterceptorCallback#onCompletion

2019-09-16 Thread Lee Dongjin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-8910: --- Summary: Incorrect javadoc at

[jira] [Commented] (KAFKA-8910) Incorrect javadoc at org.apache.kafka.clients.producer.Callback

2019-09-16 Thread Lee Dongjin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930619#comment-16930619 ] Lee Dongjin commented on KAFKA-8910: I reviewed the problem, and it seems like the title and

[jira] [Commented] (KAFKA-7632) Allow fine-grained configuration for compression

2019-08-26 Thread Lee Dongjin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915922#comment-16915922 ] Lee Dongjin commented on KAFKA-7632: [~ckozak] The draft of two interface types are already

[jira] [Commented] (KAFKA-8832) We should limit the maximum size read by a fetch request on the kafka server.

2019-08-25 Thread Lee Dongjin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915214#comment-16915214 ] Lee Dongjin commented on KAFKA-8832: Hi [~LordChen], Since this issue includes public API changes,

[jira] [Updated] (KAFKA-8832) We should limit the maximum size read by a fetch request on the kafka server.

2019-08-25 Thread Lee Dongjin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-8832: --- Labels: needs-kip (was: ) > We should limit the maximum size read by a fetch request on the kafka

[jira] [Assigned] (KAFKA-8800) Flaky Test SaslScramSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

2019-08-14 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-8800: -- Assignee: Lee Dongjin > Flaky Test >

[jira] [Assigned] (KAFKA-8789) kafka-console-consumer timeout-ms setting behaves incorrectly with older client

2019-08-13 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-8789: -- Assignee: Lee Dongjin > kafka-console-consumer timeout-ms setting behaves incorrectly with

[jira] [Created] (KAFKA-8794) Provide Javadoc on DescribeLogDirsResult

2019-08-13 Thread Lee Dongjin (JIRA)
Lee Dongjin created KAFKA-8794: -- Summary: Provide Javadoc on DescribeLogDirsResult Key: KAFKA-8794 URL: https://issues.apache.org/jira/browse/KAFKA-8794 Project: Kafka Issue Type: Improvement

[jira] [Assigned] (KAFKA-8403) Suppress needs a Materialized variant

2019-08-09 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-8403: -- Assignee: Lee Dongjin > Suppress needs a Materialized variant >

[jira] [Assigned] (KAFKA-8453) AdminClient describeTopic should handle partition level errors

2019-07-15 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-8453: -- Assignee: Lee Dongjin > AdminClient describeTopic should handle partition level errors >

[jira] [Commented] (KAFKA-8507) Support --bootstrap-server in all command line tools

2019-07-14 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16884693#comment-16884693 ] Lee Dongjin commented on KAFKA-8507: [~hachikuji] [~ijuma]  I researched this issue last weekend

[jira] [Assigned] (KAFKA-8482) alterReplicaLogDirs should be better documented

2019-07-12 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-8482: -- Assignee: Lee Dongjin > alterReplicaLogDirs should be better documented >

[jira] [Commented] (KAFKA-8610) Don't use /bin/bash in scripts

2019-07-10 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881834#comment-16881834 ] Lee Dongjin commented on KAFKA-8610: Hi [~llamahunter], Here is the draft fix. Please have a test

[jira] [Assigned] (KAFKA-8610) Don't use /bin/bash in scripts

2019-07-10 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-8610: -- Assignee: Lee Dongjin > Don't use /bin/bash in scripts > -- > >

[jira] [Commented] (KAFKA-7869) Refactor RocksDBConfigSetter API to separate DBOptions and CFOptions

2019-07-01 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876071#comment-16876071 ] Lee Dongjin commented on KAFKA-7869: [~manish.c.ghildi...@gmail.com] As you can see in the linked PR,

[jira] [Updated] (KAFKA-8611) Make topic optional when using through() operations in DSL

2019-06-28 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-8611: --- Labels: needs-kip (was: ) > Make topic optional when using through() operations in DSL >

[jira] [Commented] (KAFKA-8546) Fix needed to avoid memory leak caused by JDK-6293787

2019-06-28 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16874713#comment-16874713 ] Lee Dongjin commented on KAFKA-8546: [~badai] Absolutely. I agree with that approach. Right, the

[jira] [Assigned] (KAFKA-8546) Call System#runFinalization to avoid memory leak caused by JDK-6293787

2019-06-20 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-8546: -- Assignee: Lee Dongjin > Call System#runFinalization to avoid memory leak caused by

[jira] [Commented] (KAFKA-8546) Call System#runFinalization to avoid memory leak caused by JDK-6293787

2019-06-20 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868844#comment-16868844 ] Lee Dongjin commented on KAFKA-8546: Hi [~badai], Here is the patch: [^KAFKA-8546.patch] I confirmed

[jira] [Updated] (KAFKA-8546) Call System#runFinalization to avoid memory leak caused by JDK-6293787

2019-06-20 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-8546: --- Attachment: KAFKA-8546.patch > Call System#runFinalization to avoid memory leak caused by

[jira] [Commented] (KAFKA-8546) Call System#runFinalization to avoid memory leak caused by JDK-6293787

2019-06-17 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16865734#comment-16865734 ] Lee Dongjin commented on KAFKA-8546: [~ijuma] I inspected this issue a little bit. Although [~badai]

[jira] [Commented] (KAFKA-8507) Support --bootstrap-server in all command line tools

2019-06-11 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16860611#comment-16860611 ] Lee Dongjin commented on KAFKA-8507: I reviewed the tools in `bin` and found that the out-of-date

[jira] [Assigned] (KAFKA-8316) Remove deprecated usage of Slf4jRequestLog, SslContextFactory

2019-05-03 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-8316: -- Assignee: Lee Dongjin > Remove deprecated usage of Slf4jRequestLog, SslContextFactory >

[jira] [Assigned] (KAFKA-8308) Update jetty for security vulnerability CVE-2019-10241

2019-05-03 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-8308: -- Assignee: Lee Dongjin > Update jetty for security vulnerability CVE-2019-10241 >

[jira] [Commented] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

2019-04-23 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824698#comment-16824698 ] Lee Dongjin commented on KAFKA-7996: [~bbejeck] [~mjsax] Sorry for the late reply. I just submitted

[jira] [Resolved] (KAFKA-7502) Cleanup KTable materialization logic in a single place

2019-03-31 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin resolved KAFKA-7502. Resolution: Fixed > Cleanup KTable materialization logic in a single place >

[jira] [Commented] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

2019-03-21 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798210#comment-16798210 ] Lee Dongjin commented on KAFKA-7996: [~bbejeck] Great. I will prepare the KIP. Thanks for your

[jira] [Commented] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

2019-03-11 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789769#comment-16789769 ] Lee Dongjin commented on KAFKA-7996: I double checked this issue, and found the following: 1. All of

[jira] [Updated] (KAFKA-7502) Cleanup KTable materialization logic in a single place

2019-03-05 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7502: --- Priority: Major (was: Minor) > Cleanup KTable materialization logic in a single place >

[jira] [Commented] (KAFKA-7992) Add a server start time metric

2019-03-03 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782717#comment-16782717 ] Lee Dongjin commented on KAFKA-7992: 'needs-kip' tag added. > Add a server start time metric >

[jira] [Updated] (KAFKA-7992) Add a server start time metric

2019-03-03 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7992: --- Labels: needs-kip (was: ) > Add a server start time metric > -- > >

[jira] [Commented] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

2019-03-02 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782468#comment-16782468 ] Lee Dongjin commented on KAFKA-7996: [~guozhang] [~mjsax] Sorry for being late. To sum up, the

[jira] [Assigned] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

2019-02-25 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-7996: -- Assignee: Lee Dongjin > KafkaStreams does not pass timeout when closing Producer >

[jira] [Updated] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

2019-02-25 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7996: --- Labels: needs-kip (was: ) > KafkaStreams does not pass timeout when closing Producer >

[jira] [Assigned] (KAFKA-7920) Do not permit zstd use until inter.broker.protocol.version is updated to 2.1

2019-02-12 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-7920: -- Assignee: Lee Dongjin > Do not permit zstd use until inter.broker.protocol.version is updated

[jira] [Commented] (KAFKA-7917) Streams store cleanup: collapse layers

2019-02-11 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16765551#comment-16765551 ] Lee Dongjin commented on KAFKA-7917: [~vvcephei] Thanks for creating the issue. I also have been

[jira] [Commented] (KAFKA-7911) Add Timezone Support for Windowed Aggregations

2019-02-10 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16764389#comment-16764389 ] Lee Dongjin commented on KAFKA-7911: Understood. Thank you roe your response. Let's continue

[jira] [Comment Edited] (KAFKA-7911) Add Timezone Support for Windowed Aggregations

2019-02-10 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16764346#comment-16764346 ] Lee Dongjin edited comment on KAFKA-7911 at 2/10/19 8:45 AM: - [~mjsax] So...

[jira] [Commented] (KAFKA-7911) Add Timezone Support for Windowed Aggregations

2019-02-10 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16764346#comment-16764346 ] Lee Dongjin commented on KAFKA-7911: [~mjsax] So... something like the following is needed. Right?

[jira] [Assigned] (KAFKA-7293) Merge followed by groupByKey/join might violate co-partioning

2019-02-04 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-7293: -- Assignee: Lee Dongjin > Merge followed by groupByKey/join might violate co-partioning >

[jira] [Assigned] (KAFKA-7896) Add some Log4J Kafka Properties for Producing to Secured Brokers

2019-02-04 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-7896: -- Assignee: Rohan Desai > Add some Log4J Kafka Properties for Producing to Secured Brokers >

[jira] [Commented] (KAFKA-7896) Add some Log4J Kafka Properties for Producing to Secured Brokers

2019-02-04 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16759731#comment-16759731 ] Lee Dongjin commented on KAFKA-7896: Here is the PR: 

[jira] [Commented] (KAFKA-7293) Merge followed by groupByKey/join might violate co-partioning

2019-02-02 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16759019#comment-16759019 ] Lee Dongjin commented on KAFKA-7293: [~mjsax] So... in short, if all input {{KStreams}} given to

[jira] [Updated] (KAFKA-7884) Docs for message.format.version and log.message.format.version show invalid (corrupt?) "valid values"

2019-01-31 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7884: --- Fix Version/s: 2.1.1 2.2.0 > Docs for message.format.version and

[jira] [Assigned] (KAFKA-7884) Docs for message.format.version and log.message.format.version show invalid (corrupt?) "valid values"

2019-01-30 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-7884: -- Assignee: Lee Dongjin > Docs for message.format.version and log.message.format.version show

[jira] [Updated] (KAFKA-7840) Documentation for cleanup.policy is out of date

2019-01-26 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7840: --- Fix Version/s: 2.1.1 2.2.0 > Documentation for cleanup.policy is out of date >

[jira] [Resolved] (KAFKA-7840) Documentation for cleanup.policy is out of date

2019-01-26 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin resolved KAFKA-7840. Resolution: Fixed > Documentation for cleanup.policy is out of date >

[jira] [Commented] (KAFKA-7782) cleanup policy for offsets topic should be configurable

2019-01-24 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16751289#comment-16751289 ] Lee Dongjin commented on KAFKA-7782: {quote}It's is by design that the cleanup policy should not be

[jira] [Commented] (KAFKA-7782) cleanup policy for offsets topic should be configurable

2019-01-21 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16747984#comment-16747984 ] Lee Dongjin commented on KAFKA-7782: [~guozhang] [~hachikuji] Is this a bug, or configuring cleanup

[jira] [Commented] (KAFKA-7840) Documentation for cleanup.policy is out of date

2019-01-21 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16747922#comment-16747922 ] Lee Dongjin commented on KAFKA-7840: [~mjsax] [~ijuma] This issue should be included in 2.2.0 and

[jira] [Assigned] (KAFKA-7840) Documentation for cleanup.policy is out of date

2019-01-21 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-7840: -- Assignee: Lee Dongjin > Documentation for cleanup.policy is out of date >

[jira] [Commented] (KAFKA-7808) AdminClient#describeTopics should not throw InvalidTopicException if topic name is not found

2019-01-11 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16741133#comment-16741133 ] Lee Dongjin commented on KAFKA-7808: [~cmccabe] Could you mark this topic as resolved? [~guozhang] 

[jira] [Updated] (KAFKA-7808) AdminClient#describeTopics should not throw InvalidTopicException if topic name is not found

2019-01-11 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7808: --- Summary: AdminClient#describeTopics should not throw InvalidTopicException if topic name is not

[jira] [Assigned] (KAFKA-7808) AdminClient#describeTopics should not throw InvalidTopicException if topic name is not found

2019-01-11 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-7808: -- Assignee: Lee Dongjin > AdminClient#describeTopics should not throw InvalidTopicException if

[jira] [Commented] (KAFKA-7808) AdminClient#describeTopics should not throw InvalidTopicException if topic name is not found

2019-01-11 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740449#comment-16740449 ] Lee Dongjin commented on KAFKA-7808: Here is the PR: https://github.com/apache/kafka/pull/6124 >

[jira] [Updated] (KAFKA-7808) AdminClient#describeTopics should not throw InvalidTopicException if topic name is not found

2019-01-11 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7808: --- Description: In AdminClient#describeTopics, we have the following logic: {code:java} if

[jira] [Commented] (KAFKA-7632) Allow fine-grained configuration for compression

2019-01-06 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16735275#comment-16735275 ] Lee Dongjin commented on KAFKA-7632: The title was changed following the discussion of

[jira] [Updated] (KAFKA-7632) Allow fine-grained configuration for compression

2019-01-06 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7632: --- Summary: Allow fine-grained configuration for compression (was: Add producer option to adjust

[jira] [Updated] (KAFKA-7632) Add producer option to adjust compression level

2018-11-16 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7632: --- Description: The compression level for ZSTD is currently set to use the default level (3), which is

[jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd

2018-11-16 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7632: --- Description: The compression level for ZSTD is currently set to use the default level (3), which is

[jira] [Updated] (KAFKA-7632) Add producer option to adjust compression level

2018-11-16 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7632: --- Summary: Add producer option to adjust compression level (was: Add option to kafka broker config to

[jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd

2018-11-16 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7632: --- Description: The compression level for ZSTD is currently set to use the default level (3), which is

[jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd

2018-11-16 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7632: --- Fix Version/s: (was: 2.1.0) 2.2.0 > Add option to kafka broker config to

[jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd

2018-11-16 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7632: --- Component/s: (was: core) clients > Add option to kafka broker config to adjust

[jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd

2018-11-16 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7632: --- Priority: Major (was: Trivial) > Add option to kafka broker config to adjust compression level for

[jira] [Assigned] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd

2018-11-16 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-7632: -- Assignee: Lee Dongjin > Add option to kafka broker config to adjust compression level for

[jira] [Commented] (KAFKA-7549) Old ProduceRequest with zstd compression does not return error to client

2018-11-09 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681617#comment-16681617 ] Lee Dongjin commented on KAFKA-7549: [~lindong] Well, it seems like the ProduceRequest was not

[jira] [Commented] (KAFKA-7549) Old ProduceRequest with zstd compression does not return error to client

2018-11-05 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676115#comment-16676115 ] Lee Dongjin commented on KAFKA-7549: [~ijuma]  [~hachikuji] Ping! > Old ProduceRequest with zstd

[jira] [Commented] (KAFKA-7549) Old ProduceRequest with zstd compression does not return error to client

2018-10-26 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16665396#comment-16665396 ] Lee Dongjin commented on KAFKA-7549: [~ijuma] I reviewed the problem. Here is the result: The KIP

[jira] [Commented] (KAFKA-7549) Old ProduceRequest with zstd compression does not return error to client

2018-10-25 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16663865#comment-16663865 ] Lee Dongjin commented on KAFKA-7549: [~ijuma] No problem. Let me have a look. > Old ProduceRequest

[jira] [Assigned] (KAFKA-7549) Old ProduceRequest with zstd compression does not return error to client

2018-10-25 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-7549: -- Assignee: Lee Dongjin > Old ProduceRequest with zstd compression does not return error to

[jira] [Assigned] (KAFKA-7123) Documentation: broken link http://confluent.io/docs/current/kafka-rest/docs/intro.html

2018-06-30 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-7123: -- Assignee: Lee Dongjin > Documentation: broken link >

[jira] [Commented] (KAFKA-7123) Documentation: broken link http://confluent.io/docs/current/kafka-rest/docs/intro.html

2018-06-30 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528905#comment-16528905 ] Lee Dongjin commented on KAFKA-7123: Fixed. > Documentation: broken link >

[jira] [Updated] (KAFKA-6993) Fix defective documentations for KStream/KTable methods

2018-06-05 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-6993: --- Summary: Fix defective documentations for KStream/KTable methods (was: Defective documentations for

[jira] [Created] (KAFKA-6993) Defective documentations for KStream/KTable methods

2018-06-05 Thread Lee Dongjin (JIRA)
Lee Dongjin created KAFKA-6993: -- Summary: Defective documentations for KStream/KTable methods Key: KAFKA-6993 URL: https://issues.apache.org/jira/browse/KAFKA-6993 Project: Kafka Issue Type: