mirror of https://github.com/apache/kafka.git
When building Streams I get this warning: ``` > Task :streams:compileTestJava Note: Some input files use or override a deprecated API. Note: Recompile with -Xlint:deprecation for details. Note: <PATH>/kafka/streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java uses unchecked or unsafe operations. ``` Reviewers: Jhen-Yung Hsu <jhenyunghsu@gmail.com>, Ken Huang <s7133700@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
parent
a399852ced
commit
a3ed705092
|
@ -1947,7 +1947,7 @@ public class RecordCollectorTest {
|
||||||
);
|
);
|
||||||
collector.initialize();
|
collector.initialize();
|
||||||
|
|
||||||
collector.send(topic, "hello", "val", null, 0, null, (Serializer) errorSerializer, stringSerializer, sinkNodeName, context);
|
collector.send(topic, "hello", "val", null, 0, null, errorSerializer, stringSerializer, sinkNodeName, context);
|
||||||
|
|
||||||
assertNotNull(sourceRawData[0]);
|
assertNotNull(sourceRawData[0]);
|
||||||
assertNotNull(sourceRawData[1]);
|
assertNotNull(sourceRawData[1]);
|
||||||
|
|
Loading…
Reference in New Issue