def getEventHubsConfWithoutStartingPositions()

in core/src/main/scala/org/apache/spark/eventhubs/utils/EventHubsTestUtils.scala [142:154]

• 12 lines of code
• 1 McCabe index (conditional complexity)

  def getEventHubsConfWithoutStartingPositions(ehName: String = "name"): EventHubsConf = {
    val connectionString = ConnectionStringBuilder()
      .setNamespaceName("namespace")
      .setEventHubName(ehName)
      .setSasKeyName("keyName")
      .setSasKey("key")
      .build

    EventHubsConf(connectionString)
      .setConsumerGroup("consumerGroup")
      .setMaxRatePerPartition(DefaultMaxRate)
      .setUseSimulatedClient(true)
  }