https://github.com/SpringSource/spring-xd

Build: #1971 was successful

Job: Default Job was successful

Stages & jobs

  1. Default Stage

Code commits

Git

  • Marius Bogoevici <mbogoevici@pivotal.io>

    Marius Bogoevici <mbogoevici@pivotal.io> b4b654c723d6d360254e665fa507a4216818159f

    XD-2361/2649 Switch to simple consumer for the Kafka Message Bus/Int Tests
    - Use the KafkaMessageDrivenChannelAdapter for consuming messages, backed by a KafkaTopicMetadataStore
    - For partitioning between listeners, added Bus properties for count and sequence, available with all deployments
    - For partitioned streams, fan out messages across the Kafka partitions that belong to a logical Spring XD partition;
    - Kafka partition assigning scheme ensures that for a given deployment, partitions alocation to a specific module sequence number or partition index will be preserved
    - Enable Kafka Spark Streaming tests

    • extensions/spring-xd-extension-kafka/src/main/java/org/springframework/integration/x/kafka/KafkaPartitionAllocator.java (version b4b654c723d6d360254e665fa507a4216818159f)
    • extensions/spring-xd-extension-kafka/src/test/java/org/springframework/integration/x/kafka/KafkaTopicMetadataStoreTest.java (version b4b654c723d6d360254e665fa507a4216818159f)
    • gradle/build-extensions.gradle (version b4b654c723d6d360254e665fa507a4216818159f)
    • gradle/build-messagebuses.gradle (version b4b654c723d6d360254e665fa507a4216818159f)
    • spring-xd-dirt/src/main/java/org/springframework/xd/dirt/server/StreamRuntimePropertiesProvider.java (version b4b654c723d6d360254e665fa507a4216818159f)
    • spring-xd-dirt/src/main/resources/application.yml (version b4b654c723d6d360254e665fa507a4216818159f)
    • spring-xd-dirt/src/test/java/org/springframework/xd/dirt/integration/kafka/KafkaMessageBusTests.java (version b4b654c723d6d360254e665fa507a4216818159f)
    • spring-xd-dirt/src/test/java/org/springframework/xd/dirt/integration/kafka/KafkaTestMessageBus.java (version b4b654c723d6d360254e665fa507a4216818159f)
    • spring-xd-dirt/src/test/java/org/springframework/xd/dirt/stream/KafkaSingleNodeStreamDeploymentIntegrationTests.java (version b4b654c723d6d360254e665fa507a4216818159f)
    • spring-xd-messagebus-kafka/src/main/java/org/springframework/xd/dirt/integration/kafka/KafkaMessageBus.java (version b4b654c723d6d360254e665fa507a4216818159f)
    • spring-xd-messagebus-kafka/src/main/resources/META-INF/spring-xd/bus/kafka-bus.xml (version b4b654c723d6d360254e665fa507a4216818159f)
    • spring-xd-messagebus-local/src/main/java/org/springframework/xd/dirt/integration/bus/local/LocalMessageBus.java (version b4b654c723d6d360254e665fa507a4216818159f)
    • spring-xd-messagebus-rabbit/src/main/java/org/springframework/xd/dirt/integration/rabbit/RabbitMessageBus.java (version b4b654c723d6d360254e665fa507a4216818159f)
    • spring-xd-messagebus-redis/src/main/java/org/springframework/xd/dirt/integration/redis/RedisMessageBus.java (version b4b654c723d6d360254e665fa507a4216818159f)
    • spring-xd-messagebus-spi/src/main/java/org/springframework/xd/dirt/integration/bus/AbstractBusPropertiesAccessor.java (version b4b654c723d6d360254e665fa507a4216818159f)
    • spring-xd-messagebus-spi/src/main/java/org/springframework/xd/dirt/integration/bus/BusProperties.java (version b4b654c723d6d360254e665fa507a4216818159f)
    • spring-xd-messagebus-spi/src/main/java/org/springframework/xd/dirt/integration/bus/MessageBusSupport.java (version b4b654c723d6d360254e665fa507a4216818159f)
    • spring-xd-shell/src/test/java/org/springframework/xd/shell/command/KafkaSourceSinkTests.java (version b4b654c723d6d360254e665fa507a4216818159f)
    • spring-xd-spark-streaming-tests/src/test/java/org/springframework/xd/spark/streaming/KafkaTransportSparkStreamingTests.java (version b4b654c723d6d360254e665fa507a4216818159f)
    • spring-xd-test/src/main/java/org/springframework/xd/test/kafka/KafkaTestSupport.java (version b4b654c723d6d360254e665fa507a4216818159f)
  • David Turanski <dturanski@pivotal.io>

    David Turanski <dturanski@pivotal.io> 66ab68e5a55b861fc3f91e711ac8b29ccb60cddb

    exclude kryo from spark

    • build.gradle (version 66ab68e5a55b861fc3f91e711ac8b29ccb60cddb)