chia7712 commented on PR #20424: URL: https://github.com/apache/kafka/pull/20424#issuecomment-3234969859
> I still don't get this output... Not sure why That’s strange. I tested JDK 17, 21, and 24 according to [this comment](https://github.com/apache/kafka/pull/20424?utm_source=chatgpt.com#discussion_r2308284793), and all of them printed the unchecked warnings. The following outputs were generated on my local setup. Since `-Xlint:unchecked` is not enabled for test code by default, it’s not necessary to fix all of them in this PR. Just FYI. ``` > Task :server-common:compileTestJava /home/jenkins/kafka/server-common/src/test/java/org/apache/kafka/server/util/CommandLineUtilsTest.java:276: warning: [unchecked] unchecked conversion OptionSpec<String> spec = mock(OptionSpec.class); ^ required: OptionSpec<String> found: OptionSpec 1 warning > Task :metadata:compileTestJava /home/jenkins/kafka/metadata/src/test/java/org/apache/kafka/controller/metrics/ControllerMetadataMetricsTest.java:171: warning: [unchecked] unchecked cast Gauge<Integer> registrationState = (Gauge<Integer>) registry.allMetrics().get(name); ^ required: Gauge<Integer> found: Metric /home/jenkins/kafka/metadata/src/test/java/org/apache/kafka/controller/metrics/QuorumControllerMetricsTest.java:176: warning: [unchecked] unchecked cast Gauge<Integer> timeSinceLastHeartbeatReceivedMs = (Gauge<Integer>) registry.allMetrics().get(metricName("KafkaController", "TimeSinceLastHeartbeatReceivedMs", "broker=1")); ^ required: Gauge<Integer> found: Metric 2 warnings > Task :streams:compileTestJava Note: Some input files use or override a deprecated API. Note: Recompile with -Xlint:deprecation for details. > Task :server:compileTestJava /home/jenkins/kafka/server/src/test/java/org/apache/kafka/server/quota/ClientQuotasRequestTest.java:499: warning: [unchecked] unchecked method invocation: method ofEntries in interface Map is applied to given types Map<Object, Object> expectedMatchesMap = Map.ofEntries(expectedMatches.toArray(new Map.Entry[0])); ^ required: Entry<? extends K,? extends V>[] found: Entry[] where K,V are type-variables: K extends Object declared in method <K,V>ofEntries(Entry<? extends K,? extends V>...) V extends Object declared in method <K,V>ofEntries(Entry<? extends K,? extends V>...) /home/jenkins/kafka/server/src/test/java/org/apache/kafka/server/quota/ClientQuotasRequestTest.java:499: warning: [unchecked] unchecked conversion Map<Object, Object> expectedMatchesMap = Map.ofEntries(expectedMatches.toArray(new Map.Entry[0])); ^ required: Entry<? extends K,? extends V>[] found: Entry[] where K,V are type-variables: K extends Object declared in method <K,V>ofEntries(Entry<? extends K,? extends V>...) V extends Object declared in method <K,V>ofEntries(Entry<? extends K,? extends V>...) /home/jenkins/kafka/server/src/test/java/org/apache/kafka/server/quota/ClientQuotasRequestTest.java:499: warning: [unchecked] unchecked conversion Map<Object, Object> expectedMatchesMap = Map.ofEntries(expectedMatches.toArray(new Map.Entry[0])); ^ required: Map<Object,Object> found: Map 3 warnings > Task :connect:runtime:compileTestJava /home/jenkins/kafka/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTestUtils.java:174: warning: [unchecked] unchecked conversion Transformation<R> transformation = mock(Transformation.class); ^ required: Transformation<R> found: Transformation where R,T are type-variables: R extends ConnectRecord<R> declared in method <T,R>getTransformationChain(RetryWithToleranceOperator<T>,List<Object>) T extends Object declared in method <T,R>getTransformationChain(RetryWithToleranceOperator<T>,List<Object>) /home/jenkins/kafka/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTestUtils.java:180: warning: [unchecked] unchecked cast stub = stub.thenReturn((R) result); ^ required: R found: Object where R,T are type-variables: R extends ConnectRecord<R> declared in method <T,R>getTransformationChain(RetryWithToleranceOperator<T>,List<Object>) T extends Object declared in method <T,R>getTransformationChain(RetryWithToleranceOperator<T>,List<Object>) /home/jenkins/kafka/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskTest.java:196: warning: [unchecked] unchecked method invocation: method createTask in class WorkerSinkTaskTest is applied to given types createTask(initialState, keyConverter, valueConverter, headerConverter, toleranceOperator, List::of, transformationChain); ^ required: TargetState,Converter,Converter,HeaderConverter,RetryWithToleranceOperator<ConsumerRecord<byte[],byte[]>>,Supplier<List<ErrorReporter<ConsumerRecord<byte[],byte[]>>>>,TransformationChain<ConsumerRecord<byte[],byte[]>,SinkRecord> found: TargetState,Converter,Converter,HeaderConverter,RetryWithToleranceOperator,Supplier<List<ErrorReporter<ConsumerRecord<byte[],byte[]>>>>,TransformationChain /home/jenkins/kafka/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskTest.java:196: warning: [unchecked] unchecked conversion createTask(initialState, keyConverter, valueConverter, headerConverter, toleranceOperator, List::of, transformationChain); ^ required: RetryWithToleranceOperator<ConsumerRecord<byte[],byte[]>> found: RetryWithToleranceOperator /home/jenkins/kafka/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskTest.java:196: warning: [unchecked] unchecked conversion createTask(initialState, keyConverter, valueConverter, headerConverter, toleranceOperator, List::of, transformationChain); ^ required: TransformationChain<ConsumerRecord<byte[],byte[]>,SinkRecord> found: TransformationChain /home/jenkins/kafka/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskTest.java:1531: warning: [unchecked] unchecked method invocation: method forClass in class ArgumentCaptor is applied to given types ArgumentCaptor<Collection<TopicPartition>> closeCaptor = ArgumentCaptor.forClass(Collection.class); ^ required: Class<S> found: Class<Collection> where S,U are type-variables: S extends U declared in method <U,S>forClass(Class<S>) U extends Object declared in method <U,S>forClass(Class<S>) /home/jenkins/kafka/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskTest.java:1531: warning: [unchecked] unchecked conversion ArgumentCaptor<Collection<TopicPartition>> closeCaptor = ArgumentCaptor.forClass(Collection.class); ^ required: ArgumentCaptor<Collection<TopicPartition>> found: ArgumentCaptor 7 warnings > Task :core:compileTestScala [Warn] /home/jenkins/kafka/core/src/test/java/kafka/server/share/SharePartitionManagerTest.java:3247: [unchecked] unchecked cast [Warn] /home/jenkins/kafka/core/src/test/java/kafka/server/share/DelayedShareFetchTest.java:1319: [unchecked] unchecked method invocation: method thenReturn in interface OngoingStubbing is applied to given types [Warn] /home/jenkins/kafka/core/src/test/java/kafka/server/share/DelayedShareFetchTest.java:1319: [unchecked] unchecked conversion [Warn] /home/jenkins/kafka/core/src/test/java/kafka/server/share/DelayedShareFetchTest.java:1463: [unchecked] unchecked conversion [Warn] /home/jenkins/kafka/core/src/test/java/kafka/server/share/DelayedShareFetchTest.java:1557: [unchecked] unchecked conversion [Warn] /home/jenkins/kafka/core/src/test/java/kafka/server/share/DelayedShareFetchTest.java:2204: [unchecked] unchecked conversion [Warn] /home/jenkins/kafka/core/src/test/java/kafka/server/share/SharePartitionTest.java:8011: [unchecked] unchecked method invocation: method thenReturn in interface OngoingStubbing is applied to given types [Warn] /home/jenkins/kafka/core/src/test/java/kafka/server/share/SharePartitionTest.java:8011: [unchecked] unchecked conversion > Task :storage:compileTestJava /home/jenkins/kafka/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerTest.java:114: warning: [unchecked] unchecked conversion KafkaFuture<TopicDescription> mockFuture = mock(KafkaFuture.class); ^ required: KafkaFuture<TopicDescription> found: KafkaFuture /home/jenkins/kafka/storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerTest.java:386: warning: [unchecked] unchecked method invocation: method forClass in class ArgumentCaptor is applied to given types ArgumentCaptor<Map<String, Object>> capture = ArgumentCaptor.forClass(Map.class); ^ required: Class<S> found: Class<Map> where S,U are type-variables: S extends U declared in method <U,S>forClass(Class<S>) U extends Object declared in method <U,S>forClass(Class<S>) /home/jenkins/kafka/storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerTest.java:386: warning: [unchecked] unchecked conversion ArgumentCaptor<Map<String, Object>> capture = ArgumentCaptor.forClass(Map.class); ^ required: ArgumentCaptor<Map<String,Object>> found: ArgumentCaptor /home/jenkins/kafka/storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerTest.java:422: warning: [unchecked] unchecked method invocation: method forClass in class ArgumentCaptor is applied to given types ArgumentCaptor<Map<String, Object>> capture = ArgumentCaptor.forClass(Map.class); ^ required: Class<S> found: Class<Map> where S,U are type-variables: S extends U declared in method <U,S>forClass(Class<S>) U extends Object declared in method <U,S>forClass(Class<S>) /home/jenkins/kafka/storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerTest.java:422: warning: [unchecked] unchecked conversion ArgumentCaptor<Map<String, Object>> capture = ArgumentCaptor.forClass(Map.class); ^ required: ArgumentCaptor<Map<String,Object>> found: ArgumentCaptor /home/jenkins/kafka/storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerTest.java:435: warning: [unchecked] unchecked method invocation: method forClass in class ArgumentCaptor is applied to given types ArgumentCaptor<Map<String, Object>> capture = ArgumentCaptor.forClass(Map.class); ^ required: Class<S> found: Class<Map> where S,U are type-variables: S extends U declared in method <U,S>forClass(Class<S>) U extends Object declared in method <U,S>forClass(Class<S>) /home/jenkins/kafka/storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerTest.java:435: warning: [unchecked] unchecked conversion ArgumentCaptor<Map<String, Object>> capture = ArgumentCaptor.forClass(Map.class); ^ required: ArgumentCaptor<Map<String,Object>> found: ArgumentCaptor /home/jenkins/kafka/storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerTest.java:2077: warning: [unchecked] unchecked conversion new Supplier[]{ ^ required: Supplier<RetentionSizeData>[] found: Supplier[] /home/jenkins/kafka/storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerTest.java:2093: warning: [unchecked] unchecked conversion new Supplier[] { ^ required: Supplier<RetentionTimeData>[] found: Supplier[] /home/jenkins/kafka/storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerTest.java:3689: warning: [unchecked] unchecked generic array creation for varargs parameter of type INT#1[] clearInvocations(remoteLogMetadataManager, remoteStorageManager); ^ where INT#1 is an intersection type: INT#1 extends Object,Closeable,Configurable /home/jenkins/kafka/storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogReaderTest.java:63: warning: [unchecked] unchecked method invocation: method time in class Timer is applied to given types when(timer.time(any(Callable.class))).thenAnswer(ans -> ans.getArgument(0, Callable.class).call()); ^ required: Callable<T> found: Callable where T is a type-variable: T extends Object declared in method <T>time(Callable<T>) /home/jenkins/kafka/storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogReaderTest.java:63: warning: [unchecked] unchecked conversion when(timer.time(any(Callable.class))).thenAnswer(ans -> ans.getArgument(0, Callable.class).call()); ^ required: Callable<T> found: Callable where T is a type-variable: T extends Object declared in method <T>time(Callable<T>) /home/jenkins/kafka/storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogReaderTest.java:72: warning: [unchecked] unchecked conversion Consumer<RemoteLogReadResult> callback = mock(Consumer.class); ^ required: Consumer<RemoteLogReadResult> found: Consumer /home/jenkins/kafka/storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogReaderTest.java:105: warning: [unchecked] unchecked conversion Consumer<RemoteLogReadResult> callback = mock(Consumer.class); ^ required: Consumer<RemoteLogReadResult> found: Consumer > Task :clients:clients-integration-tests:compileTestJava /home/jenkins/kafka/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/ClientsTestUtils.java:314: warning: [unchecked] unchecked call to RetryCommitCallback(Consumer<K,V>,Optional<Map<TopicPartition,OffsetAndMetadata>>) as a member of the raw type RetryCommitCallback var commitCallback = new RetryCommitCallback(consumer, offsetsOpt); ^ where K,V are type-variables: K extends Object declared in class RetryCommitCallback V extends Object declared in class RetryCommitCallback /home/jenkins/kafka/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/MetricsDuringTopicCreationDeletionTest.java:144: warning: [unchecked] unchecked cast .map(entry -> (Gauge<Integer>) entry.getValue()) ^ required: Gauge<Integer> found: Metric /home/jenkins/kafka/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/ClientTelemetryTest.java:131: warning: [unchecked] unchecked generic array creation for varargs parameter of type List<String>[] ConfigCommand.ConfigCommandOptions addOpts = new ConfigCommand.ConfigCommandOptions(toArray(alterOpts)); ^ /home/jenkins/kafka/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/ClientTelemetryTest.java:155: warning: [unchecked] Possible heap pollution from parameterized vararg type List<String> private static String[] toArray(List<String>... lists) { ^ 4 warnings ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
