root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity
kafka/streams
History
ClarkChen ec3c319c35
MINOR: Rewrite unchecked operations in Mock API (#19071) 
We encountered unchecked or unsafe operations in
`GroupMetadataManagerTest.java`, `KTableImplTest.java`, and
`ConfigCommandIntegrationTest.java`.

* Rewrite getArgument of invocation in InvocationOnMock API because the
implementation of InvocationOnMock discards type anyway in in
`GroupMetadataManagerTest.java`.

* Remove unchecked annotations for using mock API without variable
assignment in `KTableImplTest.java`.

<img width="1422" alt="Screenshot 2025-03-02 at 8 50 55 AM"
src="https://github.com/user-attachments/assets/10ff1799-ebaa-499c-9acd-ca3b30484e6d"
/>
  
* Follow-up: https://github.com/mockito/mockito/issues/1609

Update on March 2.
* Fix unchecked cast for KTableImpl in `KTableImplTest.java`.
<img width="1259" alt="Screenshot 2025-03-02 at 5 17 47 PM"
src="https://github.com/user-attachments/assets/a5ffa3d7-4897-43ee-9b5f-26337e2560c5"
/>

Update on March 10.
* Use anyMap instead any for unchecked map type issues.
<img width="1691" alt="Screenshot 2025-03-10 at 9 36 38 AM"
src="https://github.com/user-attachments/assets/9aabc595-e7ba-4e04-81f6-f238d42af5a6"
/>

Pass all testing.
<img width="946" alt="Screenshot 2025-03-10 at 10 10 56 AM"
src="https://github.com/user-attachments/assets/793f67ea-09dc-44af-9d6c-de15531e9e72"
/>

Reviewers: TengYao Chi <kitingiao@gmail.com>, Ken Huang <s7133700@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>
 		2025-03-18 00:47:34 +08:00
..
examples/src KAFKA-13722: code cleanup after deprecated StateStore.init() was removed (#18249) 2024-12-20 14:31:44 -08:00
integration-tests/src/test KAFKA-18943: Kafka Streams incorrectly commits TX during task revokation (#19164) 2025-03-13 09:37:11 -07:00
quickstart KAFKA-8116: Update Kafka Streams archetype for Java 11 (#18471) 2025-01-10 15:45:39 -08:00
src MINOR: Rewrite unchecked operations in Mock API (#19071) 2025-03-18 00:47:34 +08:00
streams-scala KAFKA-9366 Upgrade log4j to log4j2 (#17373) 2024-12-14 01:14:31 +08:00
test-utils/src KAFKA-13722: remove usage of old ProcessorContext (#18292) 2025-01-24 10:31:31 -08:00
upgrade-system-tests-10/src/test/java/org/apache/kafka/streams/tests MINOR: Code cleanup Kafka Streams (#16050) 2024-10-23 16:54:06 -07:00
upgrade-system-tests-11/src/test/java/org/apache/kafka/streams/tests MINOR: Code cleanup Kafka Streams (#16050) 2024-10-23 16:54:06 -07:00
upgrade-system-tests-20/src/test/java/org/apache/kafka/streams/tests MINOR: Code cleanup Kafka Streams (#16050) 2024-10-23 16:54:06 -07:00
upgrade-system-tests-21/src/test/java/org/apache/kafka/streams/tests MINOR: Code cleanup Kafka Streams (#16050) 2024-10-23 16:54:06 -07:00
upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests MINOR: Code cleanup Kafka Streams (#16050) 2024-10-23 16:54:06 -07:00
upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests MINOR: Code cleanup Kafka Streams (#16050) 2024-10-23 16:54:06 -07:00
upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-27/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-30/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-31/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-32/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-33/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-34/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-35/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-36/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-37/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-38/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-39/src/test/java/org/apache/kafka/streams/tests KAFKA-18006: Add 3.9.0 to end-to-end test (streams) (#17800) 2024-11-15 14:58:24 +01:00
upgrade-system-tests-0110/src/test/java/org/apache/kafka/streams/tests MINOR: Code cleanup Kafka Streams (#16050) 2024-10-23 16:54:06 -07:00
.gitignore
…