Type Members

1.  abstract class KafkaStreamsTwitterServer extends TwitterServer with KafkaFlagUtils with ScalaStreamsImplicits

   A com.twitter.server.TwitterServer that supports configuring a KafkaStreams topology.

   A com.twitter.server.TwitterServer that supports configuring a KafkaStreams topology.

   To use, override the configureKafkaStreams method to setup your topology.

   import com.twitter.finatra.kafkastreams.KafkaStreamsTwitterServer
   
   object MyKafkaStreamsTwitterServerMain extends MyKafkaStreamsTwitterServer
   
   class MyKafkaStreamsTwitterServer extends KafkaStreamsTwitterServer {
   
   override def configureKafkaStreams(streamsBuilder: StreamsBuilder): Unit = {
     streamsBuilder.asScala
       .stream("dp-it-devel-tweetid-to-interaction")(
         Consumed.`with`(ScalaSerdes.Long, ScalaSerdes.Thrift[MigratorInteraction])
       )
   }