[jira] [Resolved] (KAFKA-12371) MirrorMaker 2.0 documentation is incorrect

2021-04-22 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12371. Resolution: Duplicate > MirrorMaker 2.0 documentation is incorr

[jira] [Resolved] (KAFKA-12529) kafka-configs.sh does not work while changing the sasl jaas configurations.

2021-04-22 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12529. Resolution: Duplicate see KAFKA-12530 > kafka-configs.sh does not work while chang

[jira] [Resolved] (KAFKA-12528) kafka-configs.sh does not work while changing the sasl jaas configurations.

2021-04-22 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12528. Resolution: Duplicate see KAFKA-12530 > kafka-configs.sh does not work while chang

[jira] [Created] (KAFKA-12708) Rewrite org.apache.kafka.test.Microbenchmarks by JMH

2021-04-22 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12708: -- Summary: Rewrite org.apache.kafka.test.Microbenchmarks by JMH Key: KAFKA-12708 URL: https://issues.apache.org/jira/browse/KAFKA-12708 Project: Kafka

[jira] [Resolved] (KAFKA-12655) CVE-2021-28165 - Upgrade jetty to 9.4.39

2021-04-13 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12655. Fix Version/s: 3.0.0 Resolution: Fixed > CVE-2021-28165 - Upgrade jetty to 9.4

[jira] [Resolved] (KAFKA-12611) Fix using random payload in ProducerPerformance incorrectly

2021-04-13 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12611. Fix Version/s: 3.0.0 Resolution: Fixed > Fix using random payl

[jira] [Created] (KAFKA-12662) add unit test for ProducerPerformance

2021-04-13 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12662: -- Summary: add unit test for ProducerPerformance Key: KAFKA-12662 URL: https://issues.apache.org/jira/browse/KAFKA-12662 Project: Kafka Issue Type

[jira] [Created] (KAFKA-12661) ConfigEntry#equal does not compare other fields when value is NOT null

2021-04-12 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12661: -- Summary: ConfigEntry#equal does not compare other fields when value is NOT null Key: KAFKA-12661 URL: https://issues.apache.org/jira/browse/KAFKA-12661 Project

[jira] [Created] (KAFKA-12627) Unify MemoryPool and BufferSupplier

2021-04-06 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12627: -- Summary: Unify MemoryPool and BufferSupplier Key: KAFKA-12627 URL: https://issues.apache.org/jira/browse/KAFKA-12627 Project: Kafka Issue Type: Task

Re: Re: [DISCUSS] KIP-706: Add method "Producer#produce" to return CompletionStage instead of Future

2021-04-06 Thread Chia-Ping Tsai
ionStage) open a room to us to implement more powerful custom CompletionStage. On 2021/04/02 01:38:12, Chia-Ping Tsai wrote: > hi Tom, > > thanks for all your suggestions! > > > 2. I'm not sure that having separate Builder.topic() and .partition() > > methods is better t

[jira] [Resolved] (KAFKA-10769) Remove JoinGroupRequest#containsValidPattern as it is duplicate to Topic#containsValidPattern

2021-04-06 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-10769. Fix Version/s: 3.0.0 Resolution: Fixed > Remove JoinGroupRequ

[jira] [Resolved] (KAFKA-12384) Flaky Test ListOffsetsRequestTest.testResponseIncludesLeaderEpoch

2021-04-06 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12384. Fix Version/s: 3.0.0 Resolution: Fixed > Flaky T

Re: Re: [DISCUSS] KIP-706: Add method "Producer#produce" to return CompletionStage instead of Future

2021-04-06 Thread Chia-Ping Tsai
ree on the grace period as part of > this KIP. Maybe 3 releases (~1 year) is a good target? > > Ismael > > On Thu, Apr 1, 2021, 6:39 PM Chia-Ping Tsai wrote: > > > > Deprecating `send` is going to be extremely disruptive to all existing > > > users (if you use -Werr

Re: Re: [DISCUSS] KIP-706: Add method "Producer#produce" to return CompletionStage instead of Future

2021-04-01 Thread Chia-Ping Tsai
rom > it. After a grace period (3 releases), we can consider deprecating. > Thoughts? > > Ismael > > On Tue, Mar 30, 2021 at 8:50 PM Chia-Ping Tsai wrote: > > > hi, > > > > I have updated KIP according to my latest response. I will start vote > > thread nex

Re: Re: [DISCUSS] KIP-706: Add method "Producer#produce" to return CompletionStage instead of Future

2021-04-01 Thread Chia-Ping Tsai
dea ProducerRecord would presumably gain a target() method > (and we could deprecate topic()), and if not I suppose ProducerRecord would > gain a topicId() method, and exactly one of topic() and topicId() would > return null, which isn't terribly nice. > > Hopefully at least some of t

[jira] [Resolved] (KAFKA-12587) Remove KafkaPrincipal#fromString for 3.0

2021-04-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12587. Resolution: Fixed > Remove KafkaPrincipal#fromString for

[jira] [Created] (KAFKA-12587) Remove KafkaPrincipal#fromString

2021-03-30 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12587: -- Summary: Remove KafkaPrincipal#fromString Key: KAFKA-12587 URL: https://issues.apache.org/jira/browse/KAFKA-12587 Project: Kafka Issue Type: Task

Re: Re: [DISCUSS] KIP-706: Add method "Producer#produce" to return CompletionStage instead of Future

2021-03-30 Thread Chia-Ping Tsai
hi, I have updated KIP according to my latest response. I will start vote thread next week if there is no more comments :) Best Regards, Chia-Ping On 2021/01/31 05:39:17, Chia-Ping Tsai wrote: > It seems to me changing the input type might make complicate the migration > from depr

Re: [VOTE] KIP-707: The future of KafkaFuture

2021-03-30 Thread Chia-Ping Tsai
Thanks for this KIP. +1 (binding) On 2021/03/29 15:34:55, Tom Bentley wrote: > Hi, > > I'd like to start a vote on KIP-707, which proposes to add > KafkaFuture.toCompletionStage(), deprecate KafkaFuture.Function and make a > couple of other minor cosmetic changes. > >

Re: Gradle error - aggregatedJavadoc depending on "compileJava"

2021-03-24 Thread Chia-Ping Tsai
hi Alexandre, please take a look at https://github.com/apache/kafka/pull/10386. We are going to fix that error. Thanks for your report. On 2021/03/10 14:07:08, Alexandre Dupriez wrote: > Hi Community, > > I tried to build Kafka from trunk on my environment today (2021, March > 10th) and it

Re: [DISCUSS] KIP-723: Add socket.tcp.no.delay property to Kafka Config

2021-03-21 Thread Chia-Ping Tsai
hi Andrei Thanks for this find and KIP. Two questions is left. 1) Is there significant side effect if we disable it? For example, does it cause higher latency in your cluster? If there is no obvious side effect, could we disable it by default? 2) As you mentioned that most packets belong to

[jira] [Resolved] (KAFKA-10697) Remove ProduceResponse.responses

2021-03-18 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-10697. Fix Version/s: 3.0.0 Resolution: Fixed > Remove ProduceResponse.respon

[jira] [Resolved] (KAFKA-12454) Add ERROR logging on kafka-log-dirs when given brokerIds do not exist in current kafka cluster

2021-03-18 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12454. Resolution: Fixed > Add ERROR logging on kafka-log-dirs when given brokerIds

Re: [ANNOUNCE] New committer: Tom Bentley

2021-03-17 Thread Chia-Ping Tsai
Congratulations!!! On 2021/03/15 17:59:56, Mickael Maison wrote: > Hi all, > > The PMC for Apache Kafka has invited Tom Bentley as a committer, and > we are excited to announce that he accepted! > > Tom first contributed to Apache Kafka in June 2017 and has been > actively contributing since

[jira] [Resolved] (KAFKA-12442) Upgrade ZSTD JNI from 1.4.8-4 to 1.4.9-1

2021-03-11 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12442. Fix Version/s: 3.0.0 Resolution: Fixed > Upgrade ZSTD JNI from 1.4.8-4 to 1.4.

Re: Re: [DISCUSS] KIP-706: Add method "Producer#produce" to return CompletionStage instead of Future

2021-03-10 Thread Chia-Ping Tsai
make noise again. I hope this KIP can join 3.0 party :) On 2021/01/31 05:39:17, Chia-Ping Tsai wrote: > It seems to me changing the input type might make complicate the migration > from deprecated send method to new API. > > Personally, I prefer to introduce a interface called

[jira] [Created] (KAFKA-12410) Remove FetchResponse#of

2021-03-04 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12410: -- Summary: Remove FetchResponse#of Key: KAFKA-12410 URL: https://issues.apache.org/jira/browse/KAFKA-12410 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-12387) Avoid unnecessary copy of FetchResponse data in handleFetchRequest

2021-02-27 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12387: -- Summary: Avoid unnecessary copy of FetchResponse data in handleFetchRequest Key: KAFKA-12387 URL: https://issues.apache.org/jira/browse/KAFKA-12387 Project

[jira] [Created] (KAFKA-12385) Remove FetchResponse#responseData

2021-02-27 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12385: -- Summary: Remove FetchResponse#responseData Key: KAFKA-12385 URL: https://issues.apache.org/jira/browse/KAFKA-12385 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-12350) document about refresh.topics.interval.seconds default value is not right

2021-02-24 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12350. Resolution: Fixed > document about refresh.topics.interval.seconds default va

Re: [DISCUSS] Apache Kafka 3.0.0 release

2021-02-24 Thread Chia-Ping Tsai
Thanks for taking over this hard job! +1 On 2021/02/23 08:02:09, Konstantine Karantasis wrote: > Hi all, > > Given that we seem to reach an agreement that the feature release after the > upcoming 2.8.0 will be 3.0.0, I'd like to volunteer to be the release > manager for the Apache Kafka 3.0.0

[jira] [Resolved] (KAFKA-12273) InterBrokerSendThread#pollOnce throws FatalExitError even though it is shutdown correctly

2021-02-22 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12273. Resolution: Fixed > InterBrokerSendThread#pollOnce throws FatalExitError even tho

[jira] [Created] (KAFKA-12356) Drain the existing requests when shutdowning InterBrokerSendThread

2021-02-22 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12356: -- Summary: Drain the existing requests when shutdowning InterBrokerSendThread Key: KAFKA-12356 URL: https://issues.apache.org/jira/browse/KAFKA-12356 Project

Re: [DISCUSS] Apache Kafka 2.8.0 release

2021-02-22 Thread Chia-Ping Tsai
hi John, There is a PR (https://github.com/apache/kafka/pull/10024) fixing following test error. 14:00:28 Execution failed for task ':core:test'. 14:00:28 > Process 'Gradle Test Executor 24' finished with non-zero exit value 1 14:00:28 This problem might be caused by incorrect test process

[jira] [Resolved] (KAFKA-12335) Upgrade junit from 5.7.0 to 5.7.1

2021-02-19 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12335. Fix Version/s: 3.0.0 Resolution: Fixed > Upgrade junit from 5.7.0 to 5.

[jira] [Created] (KAFKA-12339) Starting new connector cluster with new internal topics is unstable due to UnknownTopicOrPartitionException

2021-02-18 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12339: -- Summary: Starting new connector cluster with new internal topics is unstable due to UnknownTopicOrPartitionException Key: KAFKA-12339 URL: https://issues.apache.org/jira

[jira] [Created] (KAFKA-12335) Upgrade junit from 5.7.0 to 5.7.1

2021-02-17 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12335: -- Summary: Upgrade junit from 5.7.0 to 5.7.1 Key: KAFKA-12335 URL: https://issues.apache.org/jira/browse/KAFKA-12335 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-10885) Refactor MemoryRecordsBuilderTest/MemoryRecordsTest to avoid a lot of (unnecessary) ignored test cases

2021-02-17 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-10885. Resolution: Fixed > Refactor MemoryRecordsBuilderTest/MemoryRecordsTest to avoid a

Re: Re: [VOTE] KIP-695: Improve Streams Time Synchronization

2021-02-17 Thread Chia-Ping Tsai
ecessarily low-level config option to confuse > users. And there is no change in the behavior of any > existinng API to break users' programs. > > I have implemented this end-to-end in a preview PR: > https://github.com/apache/kafka/pull/10137 > > If this proposal sounds

Re: [DISCUSS] Apache Kafka 2.6.2 release

2021-02-12 Thread Chia-Ping Tsai
hi Sophie I just cherry-pick a commit to 2.6 (see https://github.com/apache/kafka/pull/10098) It fixes a bug in auto-generated protocol so I push the fix to all active branches. Best Regards, Chia-Ping On 2021/01/27 22:43:41, Sophie Blee-Goldman wrote: > Hi all, > > I'd like to volunteer

[jira] [Resolved] (KAFKA-12321) the comparison function for uuid type should be 'equals' rather than '=='

2021-02-12 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12321. Resolution: Fixed > the comparison function for uuid type should be 'equals' rather t

Re: Re: [VOTE] KIP-695: Improve Streams Time Synchronization

2021-02-11 Thread Chia-Ping Tsai
Thanks, all! > > > > > > > > > > It seems that the config I proposed is a solution that > > > > > everyone can be happy with, so I will go ahead with a PR to > > > > > fix that. > > > > > > > > > > I'll upda

[jira] [Created] (KAFKA-12321) the comparison function for uuid type should be 'equals' rather than '=='

2021-02-10 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12321: -- Summary: the comparison function for uuid type should be 'equals' rather than '==' Key: KAFKA-12321 URL: https://issues.apache.org/jira/browse/KAFKA-12321

Re: Re: [DISCUSS] KIP-706: Add method "Producer#produce" to return CompletionStage instead of Future

2021-02-09 Thread Chia-Ping Tsai
Ping for more discussion :) On 2021/01/31 05:39:17, Chia-Ping Tsai wrote: > It seems to me changing the input type might make complicate the migration > from deprecated send method to new API. > > Personally, I prefer to introduce a interface called “SendRecord” to replace >

[jira] [Resolved] (KAFKA-10834) Remove redundant type casts in Connect

2021-02-08 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-10834. Fix Version/s: 2.8.0 Resolution: Fixed > Remove redundant type casts in Conn

[jira] [Resolved] (KAFKA-10835) Replace Runnable and Callable overrides with lambdas in Connect

2021-02-08 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-10835. Fix Version/s: 2.8.0 Resolution: Fixed > Replace Runnable and Callable overri

[jira] [Created] (KAFKA-12311) The decoder in DumpLogSegments can't access properties

2021-02-08 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12311: -- Summary: The decoder in DumpLogSegments can't access properties Key: KAFKA-12311 URL: https://issues.apache.org/jira/browse/KAFKA-12311 Project: Kafka

[jira] [Created] (KAFKA-12309) The revocation algorithm produces uneven distributions

2021-02-07 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12309: -- Summary: The revocation algorithm produces uneven distributions Key: KAFKA-12309 URL: https://issues.apache.org/jira/browse/KAFKA-12309 Project: Kafka

Re: [VOTE] KIP-695: Improve Streams Time Synchronization

2021-02-04 Thread Chia-Ping Tsai
a new > > pollForRecordsOrMetadata(Duration) method could be overloading poll() to > > take an additional parameter which controlled whether an early return with > > empty records was allowed. Or a `poll(PollOptions)`. In the long run it > > could be a mistake to include in the met

Re: [VOTE] KIP-695: Improve Streams Time Synchronization

2021-02-03 Thread Chia-Ping Tsai
Thanks for your sharing Matthias. I agree that is indeed an anti-pattern to assume poll() returns data or not. However, I check all usages of poll() in code base. There is an interesting use case - poll(a bigger timeout) - it implies that callers want to block poll()(forever) unless there are

[DISCUSS] KIP-711 Deprecate org.apache.kafka.streams.errors.BrokerNotFoundException

2021-02-03 Thread Chia-Ping Tsai
Dear All, I'd like to start discuss thread for KIP-711 (https://cwiki.apache.org/confluence/x/3hJRCg) It's been 3 years since 234ec8a gets rid of usage of BrokerNotFoundException. Hence, it is time to deprecate BrokerNotFoundException. Best Regards, Chia-Ping

[jira] [Created] (KAFKA-12281) Deprecate org.apache.kafka.streams.errors.BrokerNotFoundException

2021-02-03 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12281: -- Summary: Deprecate org.apache.kafka.streams.errors.BrokerNotFoundException Key: KAFKA-12281 URL: https://issues.apache.org/jira/browse/KAFKA-12281 Project: Kafka

[jira] [Created] (KAFKA-12273) InterBrokerSendThread#pollOnce throws FatalExitError even though it is shutdown correctly

2021-02-02 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12273: -- Summary: InterBrokerSendThread#pollOnce throws FatalExitError even though it is shutdown correctly Key: KAFKA-12273 URL: https://issues.apache.org/jira/browse/KAFKA-12273

Re: Re: [DISCUSS] KIP-706: Add method "Producer#produce" to return CompletionStage instead of Future

2021-01-30 Thread Chia-Ping Tsai
uld align with the longer term > plan for the AdminClient that returns KafkaFuture today. > > Ismael > > On Sat, Jan 30, 2021 at 11:40 AM Chia-Ping Tsai wrote: > > > I'd like to merge KIP-706 to KIP-691 as it can bring a comprehensive > > design for both new API

Re: Re: [DISCUSS] KIP-706: Add method "Producer#produce" to return CompletionStage instead of Future

2021-01-30 Thread Chia-Ping Tsai
t;> > (i.e. topic or partition). This would get around the need to use a > >> new > >> >> > verb. For example: > >> >> > > >> >> > CompletionStage send(String topic, Message message); > >> >> > CompletionStage se

Re: [DISCUSS] KIP-691: Transactional Producer Exception Handling

2021-01-30 Thread Chia-Ping Tsai
> a richer return type. Let me know if you are good with this, and whether > Chia-Ping is also happy here :) sure. I'd like to join this bigger party :) On 2021/01/30 01:03:57, Boyang Chen wrote: > This is a great proposal Jason, I already integrated KIP-691 with KIP-706 > template to provide

Re: [DISCUSS] KIP-706: Add method "Producer#produce" to return CompletionStage instead of Future

2021-01-30 Thread Chia-Ping Tsai
ust > looking to help define the error contract for the new API. > > -Jason > > On Sat, Jan 30, 2021 at 8:39 AM Ismael Juma wrote: > > > Are we saying that we won't pursue this KIP in favor of the other one? > > > > Ismael > > > > On Sat, Jan 30, 2021

Re: [DISCUSS] KIP-706: Add method "Producer#produce" to return CompletionStage instead of Future

2021-01-30 Thread Chia-Ping Tsai
uld avoid > the redundancy when people choose the common "producer" variable name. > > producer.transmit > > instead of > > producer.produce > > A couple alternatives might be `write` or `append`. I'm happy with > `produce` as well, but curious if others hav

[jira] [Created] (KAFKA-12245) fix flay org.apache.kafka.clients.consumer.internals.FetcherTest.testEarlierOffsetResetArrivesLate

2021-01-28 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12245: -- Summary: fix flay org.apache.kafka.clients.consumer.internals.FetcherTest.testEarlierOffsetResetArrivesLate Key: KAFKA-12245 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Resolved] (KAFKA-10658) ErrantRecordReporter.report always return completed future even though the record is not sent to DLQ topic yet

2021-01-27 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-10658. Fix Version/s: 2.6.2 2.7.1 2.8.0 Resolution

[jira] [Resolved] (KAFKA-12206) o.a.k.common.Uuid should implement Comparable

2021-01-26 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12206. Fix Version/s: 2.8.0 Assignee: Colin McCabe Resolution: Fixed

[jira] [Resolved] (KAFKA-12233) Align the length passed to FileChannel by `FileRecords.writeTo`

2021-01-26 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12233. Fix Version/s: 2.8.0 Resolution: Fixed > Align the length passed to FileChan

[DISCUSS] KIP-706: Add method "Producer#produce" to return CompletionStage instead of Future

2021-01-20 Thread Chia-Ping Tsai
Dear all, I'd like to start the discussion thread for KIP-706: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=100829459 KIP-706 is proposing to introduce new API "CompletionStage produce(record)" to Producer. Kafka users can leverage CompletionStage to write asynchronous

[jira] [Created] (KAFKA-12227) Return CompletableFuture from KafkaProducer.send

2021-01-20 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12227: -- Summary: Return CompletableFuture from KafkaProducer.send Key: KAFKA-12227 URL: https://issues.apache.org/jira/browse/KAFKA-12227 Project: Kafka Issue

[jira] [Resolved] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

2021-01-19 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-8460. --- Fix Version/s: 2.8.0 Resolution: Fixed > Flaky Test PlaintextConsumerT

[jira] [Resolved] (KAFKA-12195) Fix synchronization issue happening in KafkaStreams (related to flaky AdjustStreamThreadCountTest)

2021-01-19 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12195. Fix Version/s: 2.8.0 Resolution: Fixed > Fix synchronization issue happen

[jira] [Resolved] (KAFKA-12221) remove PowerMock from connect-json module and connect-transforms module

2021-01-18 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12221. Resolution: Fixed > remove PowerMock from connect-json module and connect-transfo

[jira] [Created] (KAFKA-12221) remove PowerMock from connect-json module and connect-transforms module

2021-01-18 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12221: -- Summary: remove PowerMock from connect-json module and connect-transforms module Key: KAFKA-12221 URL: https://issues.apache.org/jira/browse/KAFKA-12221 Project

[jira] [Created] (KAFKA-12220) Replace PowerMock by Mockito

2021-01-18 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12220: -- Summary: Replace PowerMock by Mockito Key: KAFKA-12220 URL: https://issues.apache.org/jira/browse/KAFKA-12220 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-12218) Upgrade Junit to 5.8+

2021-01-17 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12218: -- Summary: Upgrade Junit to 5.8+ Key: KAFKA-12218 URL: https://issues.apache.org/jira/browse/KAFKA-12218 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-12217) Apply the new features of Junit 5.8 to code base

2021-01-17 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12217: -- Summary: Apply the new features of Junit 5.8 to code base Key: KAFKA-12217 URL: https://issues.apache.org/jira/browse/KAFKA-12217 Project: Kafka Issue

[jira] [Resolved] (KAFKA-12191) SslTransportTls12Tls13Test can replace 'assumeTrue' by (junit 5) conditional test

2021-01-14 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12191. Fix Version/s: 2.8.0 Resolution: Fixed > SslTransportTls12Tls13Test can repl

[jira] [Resolved] (KAFKA-12189) ShellTest can replace 'assumeTrue' by (junit 5) conditional test

2021-01-14 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12189. Fix Version/s: 2.8.0 Resolution: Fixed > ShellTest can replace 'assumeT

[jira] [Resolved] (KAFKA-12203) Migrate connect:mirror-client module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12203. Fix Version/s: 2.8.0 Resolution: Fixed > Migrate connect:mirror-client mod

[jira] [Created] (KAFKA-12201) Migrate connect:basic-auth-extensio module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12201: -- Summary: Migrate connect:basic-auth-extensio module to JUnit 5 Key: KAFKA-12201 URL: https://issues.apache.org/jira/browse/KAFKA-12201 Project: Kafka

[jira] [Created] (KAFKA-12203) Migrate connect:mirror-client module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12203: -- Summary: Migrate connect:mirror-client module to JUnit 5 Key: KAFKA-12203 URL: https://issues.apache.org/jira/browse/KAFKA-12203 Project: Kafka Issue

[jira] [Created] (KAFKA-12199) Migrate connect:runtime module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12199: -- Summary: Migrate connect:runtime module to JUnit 5 Key: KAFKA-12199 URL: https://issues.apache.org/jira/browse/KAFKA-12199 Project: Kafka Issue Type

[jira] [Created] (KAFKA-12202) Migrate connect:mirror module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12202: -- Summary: Migrate connect:mirror module to JUnit 5 Key: KAFKA-12202 URL: https://issues.apache.org/jira/browse/KAFKA-12202 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-12200) Migrate connect:file module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12200: -- Summary: Migrate connect:file module to JUnit 5 Key: KAFKA-12200 URL: https://issues.apache.org/jira/browse/KAFKA-12200 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-12197) Migrate connect:transforms module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12197: -- Summary: Migrate connect:transforms module to JUnit 5 Key: KAFKA-12197 URL: https://issues.apache.org/jira/browse/KAFKA-12197 Project: Kafka Issue Type

[jira] [Created] (KAFKA-12198) Migrate connect:json module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12198: -- Summary: Migrate connect:json module to JUnit 5 Key: KAFKA-12198 URL: https://issues.apache.org/jira/browse/KAFKA-12198 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-12196) Migrate connect:api module to JUnit 5

2021-01-14 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12196: -- Summary: Migrate connect:api module to JUnit 5 Key: KAFKA-12196 URL: https://issues.apache.org/jira/browse/KAFKA-12196 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-12195) Fix synchronization issue happening in KafkaStreams (related to flaky AdjustStreamThreadCountTest)

2021-01-14 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12195: -- Summary: Fix synchronization issue happening in KafkaStreams (related to flaky AdjustStreamThreadCountTest) Key: KAFKA-12195 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Resolved] (KAFKA-12171) Migrate streams:test-utils module to JUnit 5

2021-01-13 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12171. Fix Version/s: 2.8.0 Resolution: Fixed > Migrate streams:test-utils mod

[jira] [Created] (KAFKA-12191) SslTransportTls12Tls13Test can replace 'assumeTrue' by (junit 5) conditional test

2021-01-13 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12191: -- Summary: SslTransportTls12Tls13Test can replace 'assumeTrue' by (junit 5) conditional test Key: KAFKA-12191 URL: https://issues.apache.org/jira/browse/KAFKA-12191

[jira] [Created] (KAFKA-12189) ShellTest can replace 'assumeTrue' by (junit 5) conditional test

2021-01-13 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12189: -- Summary: ShellTest can replace 'assumeTrue' by (junit 5) conditional test Key: KAFKA-12189 URL: https://issues.apache.org/jira/browse/KAFKA-12189 Project: Kafka

[jira] [Created] (KAFKA-12188) Improve SaslAuthenticatorTest.checkClientConnection

2021-01-13 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12188: -- Summary: Improve SaslAuthenticatorTest.checkClientConnection Key: KAFKA-12188 URL: https://issues.apache.org/jira/browse/KAFKA-12188 Project: Kafka

[jira] [Created] (KAFKA-12187) replace assertTrue(obj instanceof X) by assertInstanceOf when we update to JUnit 5.8

2021-01-13 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12187: -- Summary: replace assertTrue(obj instanceof X) by assertInstanceOf when we update to JUnit 5.8 Key: KAFKA-12187 URL: https://issues.apache.org/jira/browse/KAFKA-12187

[jira] [Resolved] (KAFKA-12172) Migrate streams:examples module to JUnit 5

2021-01-13 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12172. Fix Version/s: 2.8.0 Resolution: Fixed > Migrate streams:examples module to JU

[jira] [Created] (KAFKA-12175) Migrate generator module to JUnit 5

2021-01-11 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12175: -- Summary: Migrate generator module to JUnit 5 Key: KAFKA-12175 URL: https://issues.apache.org/jira/browse/KAFKA-12175 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-12173) Migrate streams:streams-scala module to JUnit 5

2021-01-11 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12173: -- Summary: Migrate streams:streams-scala module to JUnit 5 Key: KAFKA-12173 URL: https://issues.apache.org/jira/browse/KAFKA-12173 Project: Kafka Issue

[jira] [Created] (KAFKA-12172) Migrate streams:examples module to JUnit 5

2021-01-11 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12172: -- Summary: Migrate streams:examples module to JUnit 5 Key: KAFKA-12172 URL: https://issues.apache.org/jira/browse/KAFKA-12172 Project: Kafka Issue Type

[jira] [Created] (KAFKA-12171) Migrate streams:test-utils module to JUnit 5

2021-01-10 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-12171: -- Summary: Migrate streams:test-utils module to JUnit 5 Key: KAFKA-12171 URL: https://issues.apache.org/jira/browse/KAFKA-12171 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-12156) Document consequences of single threaded response handling

2021-01-10 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12156. Fix Version/s: 2.8.0 Reviewer: Chia-Ping Tsai Resolution: Fixed

[jira] [Resolved] (KAFKA-10878) testReadWhenOptionalDataMissingAtTheEndIsNotTolerated/testReadWithMissingNonOptionalExtraDataAtTheEnd should check the error message

2021-01-09 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-10878. Fix Version/s: 2.8.0 Reviewer: Chia-Ping Tsai Resolution: Fixed

[jira] [Resolved] (KAFKA-10887) Migrate log4j-appender module to JUnit 5

2021-01-09 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-10887. Fix Version/s: 2.8.0 Reviewer: Chia-Ping Tsai Resolution: Fixed > Migr

[jira] [Resolved] (KAFKA-10893) Increase target_messages_per_sec of ReplicaScaleTest to reduce the run time

2021-01-04 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-10893. Fix Version/s: 2.8.0 Resolution: Fixed > Increase target_messages_per_

[jira] [Resolved] (KAFKA-10768) Make ByteBufferInputStream.read(byte[], int, int) to follow the contract

2021-01-02 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-10768. Fix Version/s: 2.8.0 Resolution: Fixed > Make ByteBufferInputStream.read(b

[jira] [Created] (KAFKA-10893) Increase target_messages_per_sec of ReplicaScaleTest to reduce the run time

2020-12-30 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-10893: -- Summary: Increase target_messages_per_sec of ReplicaScaleTest to reduce the run time Key: KAFKA-10893 URL: https://issues.apache.org/jira/browse/KAFKA-10893

[jira] [Created] (KAFKA-10887) Migrate log4j-appender module to Junit 5

2020-12-23 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-10887: -- Summary: Migrate log4j-appender module to Junit 5 Key: KAFKA-10887 URL: https://issues.apache.org/jira/browse/KAFKA-10887 Project: Kafka Issue Type: Sub

<    1   2   3   4   5   6   >