Code commits

Git

  • Marius Bogoevici <mbogoevici@pivotal.io>

    Marius Bogoevici <mbogoevici@pivotal.io> 07f855a129c4e1b87c1abdab3cd4f951fda72de1

    Use `KafkaBinderConfigurationProperties` directly
    Fixes #548

    - Remove redundant property copying
    - Make `socketBufferSize` configurable (it wasn't provided as a configuration option)

    • spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/IntegerEncoderDecoder.java (version 07f855a129c4e1b87c1abdab3cd4f951fda72de1)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealthIndicator.java (version 07f855a129c4e1b87c1abdab3cd4f951fda72de1)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java (version 07f855a129c4e1b87c1abdab3cd4f951fda72de1)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderConfiguration.java (version 07f855a129c4e1b87c1abdab3cd4f951fda72de1)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderConfigurationProperties.java (version 07f855a129c4e1b87c1abdab3cd4f951fda72de1)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java (version 07f855a129c4e1b87c1abdab3cd4f951fda72de1)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaTestBinder.java (version 07f855a129c4e1b87c1abdab3cd4f951fda72de1)
    • spring-cloud-stream-docs/src/main/asciidoc/spring-cloud-stream-overview.adoc (version 07f855a129c4e1b87c1abdab3cd4f951fda72de1)