[jira] [Assigned] (KAFKA-13821) Update Kafka Streams WordCount demo to new Processor API
[ https://issues.apache.org/jira/browse/KAFKA-13821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chun-Hao Tang reassigned KAFKA-13821: - Assignee: Chun-Hao Tang > Update Kafka Streams WordCount demo to new Processor API > > > Key: KAFKA-13821 > URL: https://issues.apache.org/jira/browse/KAFKA-13821 > Project: Kafka > Issue Type: Task > Components: streams >Affects Versions: 3.3.0 >Reporter: Jorge Esteban Quilcate Otoya >Assignee: Chun-Hao Tang >Priority: Minor > > Once KIP-820 is merged and release, WordCount[1] demo will be using > deprecated APIs: > [https://github.com/apache/kafka/pull/11993#discussion_r847744046] > [1] > https://github.com/apache/kafka/blob/0d518aaed158896ee9ee6949b8f38128d1d73634/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Created] (KAFKA-13101) Replace EasyMock and PowerMock with Mockito for RestServerTest
Chun-Hao Tang created KAFKA-13101: - Summary: Replace EasyMock and PowerMock with Mockito for RestServerTest Key: KAFKA-13101 URL: https://issues.apache.org/jira/browse/KAFKA-13101 Project: Kafka Issue Type: Sub-task Reporter: Chun-Hao Tang Assignee: Chun-Hao Tang -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (KAFKA-13094) Session windows do not consider user-specified grace when computing retention time for changelog
[
https://issues.apache.org/jira/browse/KAFKA-13094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chun-Hao Tang reassigned KAFKA-13094:
-
Assignee: Chun-Hao Tang
> Session windows do not consider user-specified grace when computing retention
> time for changelog
>
>
> Key: KAFKA-13094
> URL: https://issues.apache.org/jira/browse/KAFKA-13094
> Project: Kafka
> Issue Type: Bug
> Components: streams
>Affects Versions: 2.8.0
>Reporter: Bruno Cadonna
>Assignee: Chun-Hao Tang
>Priority: Major
>
> Session windows use internally method {{maintainMs()}} to compute the
> retention time for their changelog topic if users do not provide a retention
> time explicitly with {{Materilaized}}. However, {{maintainMs()}} does not
> consider user-specified grace period when computing the retention time.
> The bug can be verified with the following test method:
> {code:java}
> @Test
> public void
> shouldUseGapAndGraceAsRetentionTimeIfBothCombinedAreLargerThanDefaultRetentionTime()
> {
> final Duration gapSize = ofDays(1);
> final Duration gracePeriod = ofMillis(2);
> assertEquals(
> gapSize.toMillis() + gracePeriod.toMillis(),
> SessionWindows.with(gapSize).grace(gracePeriod).maintainMs()
> );
> }
> {code}
> The test should pass since the retention time of the changelog topic should
> be gap + grace. However, the test fails.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Created] (KAFKA-13088) Replace EasyMock with Mockito for ForwardingDisabledProcessorContextTest
Chun-Hao Tang created KAFKA-13088: - Summary: Replace EasyMock with Mockito for ForwardingDisabledProcessorContextTest Key: KAFKA-13088 URL: https://issues.apache.org/jira/browse/KAFKA-13088 Project: Kafka Issue Type: Sub-task Reporter: Chun-Hao Tang Assignee: Chun-Hao Tang -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (KAFKA-13082) Replace EasyMock with Mockito for ProcessorContextTest
[ https://issues.apache.org/jira/browse/KAFKA-13082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chun-Hao Tang updated KAFKA-13082: -- Summary: Replace EasyMock with Mockito for ProcessorContextTest (was: Replace EasyMock for ProcessorContextTest) > Replace EasyMock with Mockito for ProcessorContextTest > -- > > Key: KAFKA-13082 > URL: https://issues.apache.org/jira/browse/KAFKA-13082 > Project: Kafka > Issue Type: Sub-task >Reporter: Chun-Hao Tang >Assignee: Chun-Hao Tang >Priority: Major > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (KAFKA-13082) Replace EasyMock for ProcessorContextTest
Chun-Hao Tang created KAFKA-13082: - Summary: Replace EasyMock for ProcessorContextTest Key: KAFKA-13082 URL: https://issues.apache.org/jira/browse/KAFKA-13082 Project: Kafka Issue Type: Sub-task Reporter: Chun-Hao Tang Assignee: Chun-Hao Tang -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (KAFKA-13075) Consolidate RocksDBStore and RocksDBKeyValueStoreTest
[ https://issues.apache.org/jira/browse/KAFKA-13075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chun-Hao Tang reassigned KAFKA-13075: - Assignee: Chun-Hao Tang > Consolidate RocksDBStore and RocksDBKeyValueStoreTest > - > > Key: KAFKA-13075 > URL: https://issues.apache.org/jira/browse/KAFKA-13075 > Project: Kafka > Issue Type: Improvement > Components: streams >Reporter: A. Sophie Blee-Goldman >Assignee: Chun-Hao Tang >Priority: Major > Labels: newbie, newbie++ > > Looks like we have two different test classes covering pretty much the same > thing: RocksDBStore. It seems like RocksDBKeyValueStoreTest was the original > test class for RocksDBStore, but someone later added RocksDBStoreTest, most > likely because they didn't notice the RocksDBKeyValueStoreTest which didn't > follow the usual naming scheme for test classes. > We should consolidate these two into a single file, ideally retaining the > RocksDBStoreTest name since that conforms to the test naming pattern used > throughout Streams (and so this same thing doesn't happen again). It should > also extend AbstractKeyValueStoreTest like the RocksDBKeyValueStoreTest > currently does so we continue to get the benefit of all the tests in there as > well -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (KAFKA-13066) Replace EasyMock with Mockito for FileStreamSinkConnectorTest
Chun-Hao Tang created KAFKA-13066: - Summary: Replace EasyMock with Mockito for FileStreamSinkConnectorTest Key: KAFKA-13066 URL: https://issues.apache.org/jira/browse/KAFKA-13066 Project: Kafka Issue Type: Sub-task Reporter: Chun-Hao Tang Assignee: Chun-Hao Tang -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (KAFKA-13065) Replace EasyMock with Mockito for BasicAuthSecurityRestExtensionTest
Chun-Hao Tang created KAFKA-13065: - Summary: Replace EasyMock with Mockito for BasicAuthSecurityRestExtensionTest Key: KAFKA-13065 URL: https://issues.apache.org/jira/browse/KAFKA-13065 Project: Kafka Issue Type: Sub-task Reporter: Chun-Hao Tang Assignee: Chun-Hao Tang -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (KAFKA-13060) Replace EasyMock and PowerMock with Mockito in WorkerGroupMemberTest.java
Chun-Hao Tang created KAFKA-13060: - Summary: Replace EasyMock and PowerMock with Mockito in WorkerGroupMemberTest.java Key: KAFKA-13060 URL: https://issues.apache.org/jira/browse/KAFKA-13060 Project: Kafka Issue Type: Sub-task Reporter: Chun-Hao Tang Assignee: Chun-Hao Tang -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (KAFKA-12662) add unit test for ProducerPerformance
[ https://issues.apache.org/jira/browse/KAFKA-12662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chun-Hao Tang reassigned KAFKA-12662: - Assignee: Chun-Hao Tang > add unit test for ProducerPerformance > - > > Key: KAFKA-12662 > URL: https://issues.apache.org/jira/browse/KAFKA-12662 > Project: Kafka > Issue Type: Improvement >Reporter: Chia-Ping Tsai >Assignee: Chun-Hao Tang >Priority: Major > > ProducerPerformance is a useful tool which offers an official way to test > produce performance. Hence, it would be better to add enough tests for it. > (In fact, it has no unit tests currently). -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (KAFKA-806) Index may not always observe log.index.interval.bytes
[ https://issues.apache.org/jira/browse/KAFKA-806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chun-Hao Tang reassigned KAFKA-806: --- Assignee: Chun-Hao Tang > Index may not always observe log.index.interval.bytes > - > > Key: KAFKA-806 > URL: https://issues.apache.org/jira/browse/KAFKA-806 > Project: Kafka > Issue Type: Improvement > Components: log >Reporter: Jun Rao >Assignee: Chun-Hao Tang >Priority: Major > Labels: newbie++ > > Currently, each log.append() will add at most 1 index entry, even when the > appended data is larger than log.index.interval.bytes. One potential issue is > that if a follower restarts after being down for a long time, it may fetch > data much bigger than log.index.interval.bytes at a time. This means that > fewer index entries are created, which can increase the fetch time from the > consumers. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (KAFKA-12385) Remove FetchResponse#responseData
[ https://issues.apache.org/jira/browse/KAFKA-12385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17304418#comment-17304418 ] Chun-Hao Tang commented on KAFKA-12385: --- [~chia7712] Can I work on this? > Remove FetchResponse#responseData > - > > Key: KAFKA-12385 > URL: https://issues.apache.org/jira/browse/KAFKA-12385 > Project: Kafka > Issue Type: Bug >Reporter: Chia-Ping Tsai >Assignee: Chia-Ping Tsai >Priority: Major > > reference to [https://github.com/apache/kafka/pull/9758#discussion_r584142074] > We can rewrite related code to avoid using stale data structure. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (KAFKA-10697) Remove ProduceResponse.responses
[ https://issues.apache.org/jira/browse/KAFKA-10697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chun-Hao Tang reassigned KAFKA-10697: - Assignee: Chun-Hao Tang (was: UnityLung) > Remove ProduceResponse.responses > > > Key: KAFKA-10697 > URL: https://issues.apache.org/jira/browse/KAFKA-10697 > Project: Kafka > Issue Type: Improvement >Reporter: Chia-Ping Tsai >Assignee: Chun-Hao Tang >Priority: Minor > > This is a follow-up of KAFKA-9628. > related discussion: > https://github.com/apache/kafka/pull/9401#discussion_r518984349 -- This message was sent by Atlassian Jira (v8.3.4#803005)
