This is an automated email from the ASF dual-hosted git repository. bbejeck pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push: new 0ef2b4c MINOR: fix Scala compiler warning (#6417) 0ef2b4c is described below commit 0ef2b4cccea4196256ea28b5429ce95e2507928b Author: Matthias J. Sax <mj...@apache.org> AuthorDate: Sat Mar 9 05:09:07 2019 -0800 MINOR: fix Scala compiler warning (#6417) Reviewers: Guozhang Wang <wangg...@gmail.com>, Bill Bejeck <bbej...@gmail.com> --- .../src/main/scala/org/apache/kafka/streams/scala/StreamsBuilder.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/StreamsBuilder.scala b/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/StreamsBuilder.scala index 4a1df92..1fcba48 100644 --- a/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/StreamsBuilder.scala +++ b/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/StreamsBuilder.scala @@ -27,7 +27,6 @@ import org.apache.kafka.streams.state.StoreBuilder import org.apache.kafka.streams.{Topology, StreamsBuilder => StreamsBuilderJ} import org.apache.kafka.streams.scala.kstream._ import ImplicitConversions._ -import org.apache.kafka.streams.errors.TopologyException import scala.collection.JavaConverters._ @@ -163,7 +162,7 @@ class StreamsBuilder(inner: StreamsBuilderJ = new StreamsBuilderJ) { * * @param builder the builder used to obtain this state store `StateStore` instance * @return the underlying Java abstraction `StreamsBuilder` after adding the `StateStore` - * @throws TopologyException if state store supplier is already added + * @throws org.apache.kafka.streams.errors.TopologyException if state store supplier is already added * @see `org.apache.kafka.streams.StreamsBuilder#addStateStore` */ def addStateStore(builder: StoreBuilder[_ <: StateStore]): StreamsBuilderJ = inner.addStateStore(builder)