[
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
>
[
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
[
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
[
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
[
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
>
[
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
[
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
[
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
[
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,
[
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
[
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
>
[
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
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
[
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
>
[
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
>
[
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
[
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
>
[
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
[
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
> --
>
>
[
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,
[
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
>
[
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
[
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
[
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
[
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
[
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]
[
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
[
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
>
[
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
>
[
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
[
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
>
[
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
[
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
[
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
>
[
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
>
[
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
> --
>
>
[
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
[
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
>
[
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
>
[
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
[
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
[
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
[
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...
[
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?
[
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
>
[
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
>
[
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:
[
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
[
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
[
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
[
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
>
[
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
>
[
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
[
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
[
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
[
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
>
[
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]
[
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
[
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
[
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
>
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
>
[
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
>
[
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
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:
80 matches
Mail list logo