Skip to content

Instantly share code, notes, and snippets.

import org.scalatest.WordSpec
import fs2.kafka._
import cats.effect._
import cats.implicits._
class ProducerSpec extends WordSpec {
"Producer" must {

Keybase proof

I hereby claim:

  • I am rogerzxu on github.
  • I am rogerzxu (https://keybase.io/rogerzxu) on keybase.
  • I have a public key whose fingerprint is F3CD 6047 2B55 8355 5F19 FD43 ACB6 207D 27D5 542A

To claim this, I am signing this object:

package echo360.searchindexer.service
import com.google.inject.Inject
import com.typesafe.scalalogging.LazyLogging
import echo360.search.model._
import echo360.searchindexer.dto.{IndexerAction, ObjectType, SearchIndexEvent}
import echo360.searchindexer.util.SearchDataException
import echo360.simplekafka.consumer.ConsumerRecordProcessor
import echo360.simplekafka.model.IncomingRecord
import play.api.libs.json.{JsError, JsSuccess, Json}
package echo360.searchindexer.service
import echo360.search.model._
import echo360.searchindexer.fixtures.{SearchDataFixtures, SearchIndexEventFixtures}
import echo360.searchindexer.util.SearchDataException
import echo360.test.EchoMatchers
import org.mockito.Mockito._
import org.scalatest.mockito.MockitoSugar
import org.scalatest.{FlatSpec, Matchers}