billydh

package com.thecodebrews.kotlinspringvaluedemo

import org.springframework.beans.factory.annotation.Value
import org.springframework.stereotype.Component
import javax.annotation.PostConstruct

@Component
class StoreConfiguration(
    @Value("\${store.no-of-customers-capacity}") val capacity: Int
) {

billydh

package com.thecodebrews.kotlinspringvaluedemo

import org.springframework.beans.factory.annotation.Value
import org.springframework.stereotype.Component
import javax.annotation.PostConstruct

@Component
class StoreConfiguration {
    @Value("\${store.size-in-meter-square}")
    val size: Int = 0

billydh

package com.thecodebrews.kotlinspringvaluedemo

import org.springframework.beans.factory.annotation.Value
import org.springframework.boot.autoconfigure.SpringBootApplication
import org.springframework.boot.runApplication
import javax.annotation.PostConstruct

@SpringBootApplication
class KotlinspringvaluedemoApplication(
	@Value("\${application.name}") private val appName: String

billydh

package com.thecodebrews.kotlinspringvaluedemo

import org.springframework.beans.factory.annotation.Value
import org.springframework.boot.autoconfigure.SpringBootApplication
import org.springframework.boot.runApplication
import javax.annotation.PostConstruct

@SpringBootApplication
class KotlinspringvaluedemoApplication {
	@Value("\${store.name}")

billydh

store.name=mydemostore
store.address=123 Some Street, Some City, Some Country

store.size-in-meter-square=20
store.no-of-customers-capacity=10

application.name=SpringValueIsCool

billydh

package io.codebrews.kotlinkafkadynamodemo

import io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

object MockSchemaRegistry {
    val client = MockSchemaRegistryClient()
}

billydh

package io.codebrews.kotlinkafkadynamodemo

import io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient
import io.confluent.kafka.serializers.KafkaAvroDeserializer

class MockKafkaAvroDeserializer : KafkaAvroDeserializer(MockSchemaRegistry.client)

billydh

package io.codebrews.kotlinkafkadynamodemo

import io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient
import io.confluent.kafka.serializers.KafkaAvroSerializer

class MockKafkaAvroSerializer : KafkaAvroSerializer(MockSchemaRegistry.client)

billydh

package io.codebrews.kotlinkafkadynamodemo.kafka

import com.nhaarman.mockitokotlin2.given
import com.nhaarman.mockitokotlin2.timeout
import com.nhaarman.mockitokotlin2.verify
import io.codebrews.createuserrequest.CreateUserRequest
import io.codebrews.kotlinkafkadynamodemo.config.KafkaConfigProperties
import io.codebrews.kotlinkafkadynamodemo.service.CreateUserRequestHandler
import io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig
import org.apache.kafka.clients.producer.ProducerConfig

billydh

application:
  dynamo:
    customer-table-name: "demo-customer-info"
    region: "ap-southeast-2"
    endpoint: "http://localhost:8042"
  kafka:
    broker: "localhost:9092"
    serializer: io.confluent.kafka.serializers.KafkaAvroSerializer
    deserializer: io.confluent.kafka.serializers.KafkaAvroDeserializer
    schema-registry-url: "http://localhost:8081"