[
https://issues.apache.org/jira/browse/KAFKA-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17001799#comment-17001799
]
John Roesler commented on KAFKA-9011:
-------------------------------------
Hey [~akokachev], I cherry-picked them to 2.4, but on 2.3 we get some build
failures in the scala test suite.
If you really want them on 2.3, can you send a PR against the 2.3 branch,
porting the PRs and fixing the build?
Thanks,
-John
Failures:
{noformat}
> Task :streams:streams-scala:compileTestScala FAILED
Pruning sources from previous analysis, due to incompatible CompileSetup.
/home/confluent/kafka/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala:193:
not found: value Instant
val now = Instant.now()
^
/home/confluent/kafka/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala:195:
value createInput is not a member of
org.apache.kafka.streams.TopologyTestDriver
val testInput = testDriver.createInput[String, String](sourceTopic)
^
/home/confluent/kafka/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala:196:
value createOutput is not a member of
org.apache.kafka.streams.TopologyTestDriver
val testOutput = testDriver.createOutput[String, String](sinkTopic)
^
/home/confluent/kafka/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala:228:
not found: value Instant
val now = Instant.now()
^
/home/confluent/kafka/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala:230:
value createInput is not a member of
org.apache.kafka.streams.TopologyTestDriver
val testInput = testDriver.createInput[String, String](sourceTopic)
^
/home/confluent/kafka/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala:231:
value createOutput is not a member of
org.apache.kafka.streams.TopologyTestDriver
val testOutput = testDriver.createOutput[String, String](sinkTopic)
^
/home/confluent/kafka/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala:263:
not found: value Instant
val now = Instant.now()
^
/home/confluent/kafka/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala:265:
value createInput is not a member of
org.apache.kafka.streams.TopologyTestDriver
val testInput = testDriver.createInput[String, String](sourceTopic)
^
/home/confluent/kafka/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala:266:
value createOutput is not a member of
org.apache.kafka.streams.TopologyTestDriver
val testOutput = testDriver.createOutput[String, String](sinkTopic)
^
/home/confluent/kafka/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala:296:
not found: value Instant
val now = Instant.now()
^
/home/confluent/kafka/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala:298:
value createInput is not a member of
org.apache.kafka.streams.TopologyTestDriver
val testInput = testDriver.createInput[String, String](sourceTopic)
^
/home/confluent/kafka/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala:299:
value createOutput is not a member of
org.apache.kafka.streams.TopologyTestDriver
val testOutput = testDriver.createOutput[String, String](sinkTopic)
^
12 errors found
{noformat}
> Add KStream#flatTransform and KStream#flatTransformValues to Scala API
> ----------------------------------------------------------------------
>
> Key: KAFKA-9011
> URL: https://issues.apache.org/jira/browse/KAFKA-9011
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Affects Versions: 2.3.0
> Reporter: Alex Kokachev
> Assignee: Alex Kokachev
> Priority: Major
> Labels: scala, streams
> Fix For: 2.5.0
>
>
> Part of KIP-313:
> [https://cwiki.apache.org/confluence/display/KAFKA/KIP-313%3A+Add+KStream.flatTransform+and+KStream.flatTransformValues]
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
