Build: #1119 failed Scheduled with changes by 10 people

Code commits

Showing 100 of 197 code changes

Plan Repository

  • fnu, rohan <rohan.mukesh@sabre.com>

    fnu, rohan <rohan.mukesh@sabre.com> dfd914254b355b29157623a0e0ae51d04bcffc2a

    INT-4566: R2DBC Outbound Channel Adapter
    JIRA: INT-4566">https://jira.spring.io/browse/INT-4566

    * Fixed review comments
    * added `DELETE` and `Criteria` implementation for outbound channel adapter
    * Clean up code style
    * Add initial docs

    • build.gradle (version dfd914254b355b29157623a0e0ae51d04bcffc2a)
    • spring-integration-r2dbc/src/main/java/org/springframework/integration/r2dbc/outbound/R2dbcMessageHandler.java (version dfd914254b355b29157623a0e0ae51d04bcffc2a)
    • spring-integration-r2dbc/src/test/java/org/springframework/integration/r2dbc/outbound/Person.java (version dfd914254b355b29157623a0e0ae51d04bcffc2a)
    • spring-integration-r2dbc/src/test/java/org/springframework/integration/r2dbc/outbound/R2DbcMessageHandlerTests.java (version dfd914254b355b29157623a0e0ae51d04bcffc2a)
    • src/reference/asciidoc/index-single.adoc (version dfd914254b355b29157623a0e0ae51d04bcffc2a)
    • src/reference/asciidoc/index.adoc (version dfd914254b355b29157623a0e0ae51d04bcffc2a)
    • src/reference/asciidoc/r2dbc.adoc (version dfd914254b355b29157623a0e0ae51d04bcffc2a)
    • src/reference/asciidoc/whats-new.adoc (version dfd914254b355b29157623a0e0ae51d04bcffc2a)
  • Gary Russell

    Gary Russell b860a2e818f06a9895ba80b0485e5f073b63c494

    Merge Spring Integration Kafka into Main Repo
    - merge master branch from old repo (`git-filter-repo`) for src branch
    - update build.gradle
    - copy docs from Spring for Apache Kafka Chapter

    Doc polishing.

    Fix http: references in tests.

    * Add `What's New` note and fix `polling-consumer.adoc`
    not linking to external project any more

    • build.gradle (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/api/overview.html (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/checkstyle/checkstyle-header.txt (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/checkstyle/checkstyle-suppressions.xml (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/checkstyle/checkstyle.xml (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/dist/license.txt (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/dist/notice.txt (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/channel/AbstractKafkaChannel.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/channel/PollableKafkaChannel.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/channel/PublishSubscribeKafkaChannel.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/channel/SubscribableKafkaChannel.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaChannelParser.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaInboundChannelAdapterParser.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaInboundGatewayParser.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaMessageDrivenChannelAdapterParser.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaNamespaceHandler.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaOutboundChannelAdapterParser.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaOutboundGatewayParser.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaParsingUtils.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/AbstractKafkaChannelSpec.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/Kafka.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundChannelAdapterSpec.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundGatewaySpec.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageDrivenChannelAdapterSpec.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageListenerContainerSpec.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaOutboundGatewaySpec.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaPointToPointChannelSpec.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaPollableChannelSpec.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaProducerMessageHandlerSpec.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaPublishSubscribeChannelSpec.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaSubscribableChannelSpec.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaTemplateSpec.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaInboundGateway.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/KafkaIntegrationHeaders.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/KafkaSendFailureException.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/RawRecordHeaderErrorMessageStrategy.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/channnel/ChannelTests.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/AllXmlTests-context.xml (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/AllXmlTests.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/ChannelParserTests.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaInboundChannelAdapterParserTests-context.xml (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaInboundChannelAdapterParserTests.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaInboundGatewayTests-context.xml (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaInboundGatewayTests.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaMessageDrivenChannelAdapterParserTests.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundGatewayParserTests-context.xml (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundGatewayParserTests.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/channels-context.xml (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/InboundGatewayTests.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceIntegrationTests.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/kotlin/KafkaDslKotlinTests.kt (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • src/checkstyle/checkstyle.xml (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • src/reference/asciidoc/endpoint-summary.adoc (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • src/reference/asciidoc/index-single.adoc (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • src/reference/asciidoc/index.adoc (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • src/reference/asciidoc/kafka.adoc (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • src/reference/asciidoc/polling-consumer.adoc (version b860a2e818f06a9895ba80b0485e5f073b63c494)
    • src/reference/asciidoc/whats-new.adoc (version b860a2e818f06a9895ba80b0485e5f073b63c494)
  • Gary Russell

    Gary Russell 3ec74f380f8a4b42d62559deff60054a357bb394

    KMSource - fix RebalanceListener (incremental)
    Support cooperative rebalancing
     - incremental assignment/revocation
     - re-pause if a rebalance occurs while paused

    **cheerry-pick to 3.2.x**

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version 3ec74f380f8a4b42d62559deff60054a357bb394)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version 3ec74f380f8a4b42d62559deff60054a357bb394)
  • Artem Bilan

    Artem Bilan a28647259c4c3e4f06a893f1717cc3de629e6705

    Upgrade dependencies; prepare for release

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/channel/PollableKafkaChannel.java (version a28647259c4c3e4f06a893f1717cc3de629e6705)
  • Artem Bilan

    Artem Bilan bfef5a49cff672363545950abb9a2b340112029e

    Fix Kotlin tests according upstream changes
    * Upgrade dependencies

    • spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/kotlin/KafkaDslKotlinTests.kt (version bfef5a49cff672363545950abb9a2b340112029e)
  • Gary Russell

    Gary Russell 213772dcaffb406ab0c4648dddfb5ab45f584fbf

    Fix S-K Deprecations

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageListenerContainerSpec.java (version 213772dcaffb406ab0c4648dddfb5ab45f584fbf)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version 213772dcaffb406ab0c4648dddfb5ab45f584fbf)
  • Gary Russell

    Gary Russell 1e484d0fad3b4cf803d6486f824a952e29dc5595

    Support flush after send
    * Add `flushExpression`.

    * Add DSL, XML configuration.

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaParsingUtils.java (version 1e484d0fad3b4cf803d6486f824a952e29dc5595)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaProducerMessageHandlerSpec.java (version 1e484d0fad3b4cf803d6486f824a952e29dc5595)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version 1e484d0fad3b4cf803d6486f824a952e29dc5595)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/KafkaIntegrationHeaders.java (version 1e484d0fad3b4cf803d6486f824a952e29dc5595)
    • spring-integration-kafka/src/main/resources/org/springframework/integration/kafka/config/spring-integration-kafka.xsd (version 1e484d0fad3b4cf803d6486f824a952e29dc5595)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests-context.xml (version 1e484d0fad3b4cf803d6486f824a952e29dc5595)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java (version 1e484d0fad3b4cf803d6486f824a952e29dc5595)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundGatewayParserTests-context.xml (version 1e484d0fad3b4cf803d6486f824a952e29dc5595)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundGatewayParserTests.java (version 1e484d0fad3b4cf803d6486f824a952e29dc5595)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version 1e484d0fad3b4cf803d6486f824a952e29dc5595)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version 1e484d0fad3b4cf803d6486f824a952e29dc5595)
  • Artem Bilan

    Artem Bilan 04019dbb96d8bdbcdec714da5b43c8860911b1bf

    Fix checkstyle.xml for Windows new line

    • spring-integration-kafka/src/checkstyle/checkstyle.xml (version 04019dbb96d8bdbcdec714da5b43c8860911b1bf)
  • Gary Russell

    Gary Russell 8771f8e18ced73164e2d158a4b6fb9b0d9c6a47d

    Fix tests for latest SK snapshot

    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version 8771f8e18ced73164e2d158a4b6fb9b0d9c6a47d)
  • Gary Russell

    Gary Russell a58169f4e190a69e9d3ea122ff088c08d6fcfd96

    Fix Gradle Deprecations
    * Rename schema

    * Upgrade to Gradle 6.3-rc-3 for transitive dependency fix.

    * Remove version from schema; polish `build.gradle` to remove unneeded features.

    • spring-integration-kafka/src/main/resources/META-INF/spring.schemas (version a58169f4e190a69e9d3ea122ff088c08d6fcfd96)
    • spring-integration-kafka/src/main/resources/org/springframework/integration/kafka/config/spring-integration-kafka.xsd (version a58169f4e190a69e9d3ea122ff088c08d6fcfd96)
  • Gary Russell

    Gary Russell bdd236052b61e91581170ac978fd2ae4dee9db28

    Upgrade to SK 2.5.0
    - add deliveryAttempt header when retry is not configured
    - temporary work around for gradle bug, jar with test classifier missing from CP

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/Kafka.java (version bdd236052b61e91581170ac978fd2ae4dee9db28)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaInboundGateway.java (version bdd236052b61e91581170ac978fd2ae4dee9db28)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java (version bdd236052b61e91581170ac978fd2ae4dee9db28)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version bdd236052b61e91581170ac978fd2ae4dee9db28)
  • Gary Russell

    Gary Russell 0b7ea6d3c286575026afa9761c49310947a5d54b

    Remove deprecated methods

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/Kafka.java (version 0b7ea6d3c286575026afa9761c49310947a5d54b)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundChannelAdapterSpec.java (version 0b7ea6d3c286575026afa9761c49310947a5d54b)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaOutboundGatewaySpec.java (version 0b7ea6d3c286575026afa9761c49310947a5d54b)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version 0b7ea6d3c286575026afa9761c49310947a5d54b)
  • Gary Russell

    Gary Russell 81b9ae4a7ae4c85c6cd813dcb9c1a3fe0c611507

    Use core Kotlin DSL

    • spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/kotlin/KafkaDslKotlinTests.kt (version 81b9ae4a7ae4c85c6cd813dcb9c1a3fe0c611507)
  • Artem Bilan

    Artem Bilan e0be544a403a5a09c9d4a7cae7e7b46ae2b4f904

    Add more XSD version into spring.schemas
    * Fix some deprecation in `build.gradle`

    • spring-integration-kafka/src/main/resources/META-INF/spring.schemas (version e0be544a403a5a09c9d4a7cae7e7b46ae2b4f904)
  • Gary Russell

    Gary Russell 2331eee642671081e3298aa2803d2f742a3aa909

    GH-296: Add Kafka-backed MessageChannels
    Resolves https://github.com/spring-projects/spring-integration-kafka/issues/296

    * * Add DSL support

    * * Polishing and XML support

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/channel/AbstractKafkaChannel.java (version 2331eee642671081e3298aa2803d2f742a3aa909)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/channel/PollableKafkaChannel.java (version 2331eee642671081e3298aa2803d2f742a3aa909)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/channel/SubscribableKafkaChannel.java (version 2331eee642671081e3298aa2803d2f742a3aa909)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/channel/package-info.java (version 2331eee642671081e3298aa2803d2f742a3aa909)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaChannelParser.java (version 2331eee642671081e3298aa2803d2f742a3aa909)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaNamespaceHandler.java (version 2331eee642671081e3298aa2803d2f742a3aa909)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/AbstractKafkaChannelSpec.java (version 2331eee642671081e3298aa2803d2f742a3aa909)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/Kafka.java (version 2331eee642671081e3298aa2803d2f742a3aa909)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaPollableChannelSpec.java (version 2331eee642671081e3298aa2803d2f742a3aa909)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaSubscribableChannelSpec.java (version 2331eee642671081e3298aa2803d2f742a3aa909)
    • spring-integration-kafka/src/main/resources/org/springframework/integration/kafka/config/spring-integration-kafka-3.2.xsd (version 2331eee642671081e3298aa2803d2f742a3aa909)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/channnel/ChannelTests.java (version 2331eee642671081e3298aa2803d2f742a3aa909)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/ChannelParserTests.java (version 2331eee642671081e3298aa2803d2f742a3aa909)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/channels-context.xml (version 2331eee642671081e3298aa2803d2f742a3aa909)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version 2331eee642671081e3298aa2803d2f742a3aa909)
  • Gary Russell

    Gary Russell 905a5155bc7497d4d6a84d863e7a28888d55df44

    Master to 3.3; support non-Tx if template allows
    * SI to 5.3.0.B-S

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version 905a5155bc7497d4d6a84d863e7a28888d55df44)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java (version 905a5155bc7497d4d6a84d863e7a28888d55df44)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version 905a5155bc7497d4d6a84d863e7a28888d55df44)
  • Artem Bilan

    Artem Bilan f596e49242045467830a499b4ac08fd16482e00d

    Upgrade to latest releases
    * Upgrade to Gradle 6.1.1
    * Fix for latest Checkstyle
    * Fix for latest SI-Kotlin-DSL

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version f596e49242045467830a499b4ac08fd16482e00d)
    • spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/kotlin/KafkaDslKotlinTests.kt (version f596e49242045467830a499b4ac08fd16482e00d)
  • Gary Russell

    Gary Russell aaaaf86c074ab33307446fe3f3fcbf66f82df58a

    GH-296: DSL: Support inline pub/sub subscriptions
    Resolves https://github.com/spring-projects/spring-integration-kafka/issues/296

    * * Add generic type to specsto avoid cast to `BroadcastCapableChannel`.

    * * Remove unneeded fields in the abstract spec

    * Restore log4j config

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/channel/AbstractKafkaChannel.java (version aaaaf86c074ab33307446fe3f3fcbf66f82df58a)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/channel/PublishSubscribeKafkaChannel.java (version aaaaf86c074ab33307446fe3f3fcbf66f82df58a)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/channel/SubscribableKafkaChannel.java (version aaaaf86c074ab33307446fe3f3fcbf66f82df58a)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaChannelParser.java (version aaaaf86c074ab33307446fe3f3fcbf66f82df58a)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/AbstractKafkaChannelSpec.java (version aaaaf86c074ab33307446fe3f3fcbf66f82df58a)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/Kafka.java (version aaaaf86c074ab33307446fe3f3fcbf66f82df58a)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaPointToPointChannelSpec.java (version aaaaf86c074ab33307446fe3f3fcbf66f82df58a)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaPollableChannelSpec.java (version aaaaf86c074ab33307446fe3f3fcbf66f82df58a)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaPublishSubscribeChannelSpec.java (version aaaaf86c074ab33307446fe3f3fcbf66f82df58a)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaSubscribableChannelSpec.java (version aaaaf86c074ab33307446fe3f3fcbf66f82df58a)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/channnel/ChannelTests.java (version aaaaf86c074ab33307446fe3f3fcbf66f82df58a)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version aaaaf86c074ab33307446fe3f3fcbf66f82df58a)
  • Artem Bilan

    Artem Bilan 9b0b87d37eb751d7af2b0da0349e9b35e9ba9a69

    Apply SI-Kotlin-DSL in tests

    • spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/KafkaDslKotlinTests.kt (version 9b0b87d37eb751d7af2b0da0349e9b35e9ba9a69)
  • Gary Russell

    Gary Russell 6cddb2c1693d15d98dba27f39cb292d0d51af3fa

    Revert "Apply SI-Kotlin-DSL in tests"
    This reverts commit b03ddcb953c18469564994921efb84a072a0e358.

    • spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/KafkaDslKotlinTests.kt (version 6cddb2c1693d15d98dba27f39cb292d0d51af3fa)
  • Gary Russell

    Gary Russell cf3aa29a234e99cbecb96c3a75300f08710797d5

    GH-290: Add ProducerRecordCreator
    Resolves https://github.com/spring-projects/spring-integration-kafka/issues/290

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version cf3aa29a234e99cbecb96c3a75300f08710797d5)
  • Gary Russell

    Gary Russell 386c64c6176664973ac2d998c4f8a00c633b7c02

    Support ProducerRecord outbound payloads

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version 386c64c6176664973ac2d998c4f8a00c633b7c02)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version 386c64c6176664973ac2d998c4f8a00c633b7c02)
  • Artem Bilan

    Artem Bilan 27f0775fb801f86ac5a10d447a0b163144a6c141

    Apply SI-Kotlin-DSL in tests (#292)
    * Apply SI-Kotlin-DSL in tests

    * Upgrade dependencies

    * Upgrade to latest releases

    • spring-integration-kafka/src/checkstyle/checkstyle.xml (version 27f0775fb801f86ac5a10d447a0b163144a6c141)
    • spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/KafkaDslKotlinTests.kt (version 27f0775fb801f86ac5a10d447a0b163144a6c141)
  • tomvandenberge <tom.vandenberge@gmail.com>

    tomvandenberge <tom.vandenberge@gmail.com> 0e74cd1cee1a70accf596bd311b30fbf6033c4f5

    Add XML attribute for header-mapper
    * Added support for header-mapper to outbound-channel-adapter and
    outbound-gateway XML

    * Follow up on review

    * Corrected mistake

    * Corrected indentation

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaParsingUtils.java (version 0e74cd1cee1a70accf596bd311b30fbf6033c4f5)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version 0e74cd1cee1a70accf596bd311b30fbf6033c4f5)
    • spring-integration-kafka/src/main/resources/org/springframework/integration/kafka/config/spring-integration-kafka-3.2.xsd (version 0e74cd1cee1a70accf596bd311b30fbf6033c4f5)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests-context.xml (version 0e74cd1cee1a70accf596bd311b30fbf6033c4f5)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java (version 0e74cd1cee1a70accf596bd311b30fbf6033c4f5)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundGatewayParserTests-context.xml (version 0e74cd1cee1a70accf596bd311b30fbf6033c4f5)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundGatewayParserTests.java (version 0e74cd1cee1a70accf596bd311b30fbf6033c4f5)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version 0e74cd1cee1a70accf596bd311b30fbf6033c4f5)
  • Gary Russell

    Gary Russell adf91edf050d6d496192a3c670a75eb15ecff8a0

    KMSource: Consumer Property Overrides
    - support property overrides in the message source

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version adf91edf050d6d496192a3c670a75eb15ecff8a0)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceIntegrationTests.java (version adf91edf050d6d496192a3c670a75eb15ecff8a0)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version adf91edf050d6d496192a3c670a75eb15ecff8a0)
  • Artem Bilan

    Artem Bilan bf0134cb52c2d7f993ac1fc69d515e21c228d6a9

    Upgrade to latest GAs
    * Move all the test to JUnit 5; remove redundant JUnit 4 dependencies

    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaMessageDrivenChannelAdapterParserTests.java (version bf0134cb52c2d7f993ac1fc69d515e21c228d6a9)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java (version bf0134cb52c2d7f993ac1fc69d515e21c228d6a9)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version bf0134cb52c2d7f993ac1fc69d515e21c228d6a9)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/InboundGatewayTests.java (version bf0134cb52c2d7f993ac1fc69d515e21c228d6a9)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version bf0134cb52c2d7f993ac1fc69d515e21c228d6a9)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceIntegrationTests.java (version bf0134cb52c2d7f993ac1fc69d515e21c228d6a9)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version bf0134cb52c2d7f993ac1fc69d515e21c228d6a9)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version bf0134cb52c2d7f993ac1fc69d515e21c228d6a9)
    • spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/KafkaDslKotlinTests.kt (version bf0134cb52c2d7f993ac1fc69d515e21c228d6a9)
  • Artem Bilan

    Artem Bilan f6d858c7aad76656c536245b268eb07ee68a92dd

    Polishing JavaDocs and possible NPEs
    https://build.spring.io/browse/INTEXT-KAFKA-310/

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/Kafka.java (version f6d858c7aad76656c536245b268eb07ee68a92dd)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version f6d858c7aad76656c536245b268eb07ee68a92dd)
  • Gary Russell

    Gary Russell 8cc2b2cc00b82b5298f2b4652792ab56d21f9318

    KMessageSource getter for consumer properties
    - allow customization after creation - e.g. SCSt `MessageSourceCustomizer`
    - also fix deprecation in `ReplyingKafkaTemplate`

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaOutboundGatewaySpec.java (version 8cc2b2cc00b82b5298f2b4652792ab56d21f9318)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version 8cc2b2cc00b82b5298f2b4652792ab56d21f9318)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version 8cc2b2cc00b82b5298f2b4652792ab56d21f9318)
    • spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/KafkaDslKotlinTests.kt (version 8cc2b2cc00b82b5298f2b4652792ab56d21f9318)
  • Anshul Mehra <ansh.mehra@me.com>

    Anshul Mehra <ansh.mehra@me.com> c20ef851687f396d4b2e9f48db351f3ea2b9b97b

    GH-280: Add topicPattern support to KafkaMessageSource
    Fixes https://github.com/spring-projects/spring-integration-kafka/issues/280

    * Refactored to topics/topicPattern to be a property to
    prevent constructor telescoping

    * Add support for manual partition assignment

    - Cleanup after rebasing from #283
    - Add additional tests

    * Fix checkstyle

    * Remove redundant factory methods

    * Add better test for static assignment

    * Use ConsumerProperties

    Fix typo where ContainerProperties was used
    instead of ConsumerProperties

    * Simplify construction

    * Remove unused import

    * Use ObjectUtils

    * Use component name for clientId

    * Collapse static assignment for loop

    * Fix lint warning

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version c20ef851687f396d4b2e9f48db351f3ea2b9b97b)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaInboundChannelAdapterParserTests.java (version c20ef851687f396d4b2e9f48db351f3ea2b9b97b)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version c20ef851687f396d4b2e9f48db351f3ea2b9b97b)
  • Gary Russell

    Gary Russell e6cdb8818f965ee06e6024d3641dc0bb8ef2d950

    GH-279: Fix tests for latest SK Snapshots
    - add tests for tx.id overrides

    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java (version e6cdb8818f965ee06e6024d3641dc0bb8ef2d950)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version e6cdb8818f965ee06e6024d3641dc0bb8ef2d950)
  • Gary Russell

    Gary Russell 3831919cbc2def7c80b366e3f58618f6470377c8

    GH-282: KMSource - support async commits etc
    Resolves https://github.com/spring-projects/spring-integration-kafka/issues/282

    Use sync-related properties from `ConsumerProperties`.

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version 3831919cbc2def7c80b366e3f58618f6470377c8)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version 3831919cbc2def7c80b366e3f58618f6470377c8)
  • Anshul Mehra <ansh.mehra@me.com>

    Anshul Mehra <ansh.mehra@me.com> e52c535f7cdb9c87b9eb3f7ed81f52f475c864cd

    Use ConsumerProperties in KafkaMessageSource
    * Preserve existing constructors

    * Add @deprecated in java docs

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaInboundChannelAdapterParser.java (version e52c535f7cdb9c87b9eb3f7ed81f52f475c864cd)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/Kafka.java (version e52c535f7cdb9c87b9eb3f7ed81f52f475c864cd)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundChannelAdapterSpec.java (version e52c535f7cdb9c87b9eb3f7ed81f52f475c864cd)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version e52c535f7cdb9c87b9eb3f7ed81f52f475c864cd)
    • spring-integration-kafka/src/main/resources/org/springframework/integration/kafka/config/spring-integration-kafka-3.2.xsd (version e52c535f7cdb9c87b9eb3f7ed81f52f475c864cd)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/AllXmlTests-context.xml (version e52c535f7cdb9c87b9eb3f7ed81f52f475c864cd)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaInboundChannelAdapterParserTests-context.xml (version e52c535f7cdb9c87b9eb3f7ed81f52f475c864cd)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version e52c535f7cdb9c87b9eb3f7ed81f52f475c864cd)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceIntegrationTests.java (version e52c535f7cdb9c87b9eb3f7ed81f52f475c864cd)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version e52c535f7cdb9c87b9eb3f7ed81f52f475c864cd)
    • spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/KafkaDslKotlinTests.kt (version e52c535f7cdb9c87b9eb3f7ed81f52f475c864cd)
  • Urs Keller <urs@revault.ch>

    Urs Keller <urs@revault.ch> 4cd81fda787c9fbf6820f758d2532042f63039c7

    Fix NPE for retryTemp!=null but recoveryCall==null
    Starting with version `3.0.x`, the `KafkaInboundGateway` and
    `KafkaMessageDrivenChannelAdapter` rely on the
    `RetryContext.getRetryCount()` for the
    `IntegrationMessageHeaderAccessor.DELIVERY_ATTEMPT` message header, but
    the `RetryContext` is obtained from the `TheadLocal` `attributesHolder`,
    which is populated from the `RetryListener.open()` only if
    `recoveryCallback != null`

    * Fix `KafkaInboundGateway` and `KafkaMessageDrivenChannelAdapter` to
    populate `TheadLocal` `attributesHolder` with the `RetryContext`
    from the `RetryListener.open()` when only `retryTemplate != null`

    **Cherry-pick to `master` & 3.0.x**

    # Conflicts:
    #        src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaInboundGateway.java (version 4cd81fda787c9fbf6820f758d2532042f63039c7)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java (version 4cd81fda787c9fbf6820f758d2532042f63039c7)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/InboundGatewayTests.java (version 4cd81fda787c9fbf6820f758d2532042f63039c7)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version 4cd81fda787c9fbf6820f758d2532042f63039c7)
  • Gary Russell

    Gary Russell 41de7495e627154ff3e23c56632a08f6535f4dd1

    Resolve deprecations and other compiler warnings

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/Kafka.java (version 41de7495e627154ff3e23c56632a08f6535f4dd1)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundGatewaySpec.java (version 41de7495e627154ff3e23c56632a08f6535f4dd1)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageDrivenChannelAdapterSpec.java (version 41de7495e627154ff3e23c56632a08f6535f4dd1)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageListenerContainerSpec.java (version 41de7495e627154ff3e23c56632a08f6535f4dd1)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaInboundGateway.java (version 41de7495e627154ff3e23c56632a08f6535f4dd1)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/InboundGatewayTests.java (version 41de7495e627154ff3e23c56632a08f6535f4dd1)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version 41de7495e627154ff3e23c56632a08f6535f4dd1)
  • Cameron Mayfield <cameronjmayfield@gmail.com>

    Cameron Mayfield <cameronjmayfield@gmail.com> 600e88ec56c087ea25113771757e2b27399ca9b8

    GH-272: Add KafkaMDrivenChAdapterSpec.payloadType
    Fixes https://github.com/spring-projects/spring-integration-kafka/issues/272

    Add `payloadType` option into `KafkaMessageDrivenChannelAdapterSpec`

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageDrivenChannelAdapterSpec.java (version 600e88ec56c087ea25113771757e2b27399ca9b8)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version 600e88ec56c087ea25113771757e2b27399ca9b8)
  • Artem Bilan

    Artem Bilan d96a2d930c500f05abda87df68870bc147b85256

    Add HTTPS entries for XSD into spring.schemas
    Related to spring-projects/spring-integration#2987

    **Cherry-pick to 3.1.x, 3.0.x & 2.3.x**

    • spring-integration-kafka/src/main/resources/META-INF/spring.schemas (version d96a2d930c500f05abda87df68870bc147b85256)
  • Gary Russell

    Gary Russell a1b51c9f47d158d4faf2739ca9b2a27c217f586c

    Fix tests for SK 2.3.0.M3

    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java (version a1b51c9f47d158d4faf2739ca9b2a27c217f586c)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version a1b51c9f47d158d4faf2739ca9b2a27c217f586c)
  • Anshul Mehra <ansh.mehra@me.com>

    Anshul Mehra <ansh.mehra@me.com> cd6d17e4b0506404fef084610e6c5d051b8021ac

    GH-265: Ensure assignTimeout is used when no partitions are assigned
    * Refactored to rely on assignedPartitions for determining whether to
    use pollTimeout or assignTimeout
    * Removed redundant assigned flag

    fixes #265

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version cd6d17e4b0506404fef084610e6c5d051b8021ac)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version cd6d17e4b0506404fef084610e6c5d051b8021ac)
  • Gary Russell

    Gary Russell 14302088c5e560c3eaadaba048a3a112893b3091

    SIGH-2958: Add source record to common SI Header
    Resolves https://github.com/spring-projects/spring-integration/issues/2958

    Enables applications to be agnostic regarding the source of
    a message. e.g Kafka Vs. AMQP.

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaInboundGateway.java (version 14302088c5e560c3eaadaba048a3a112893b3091)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java (version 14302088c5e560c3eaadaba048a3a112893b3091)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version 14302088c5e560c3eaadaba048a3a112893b3091)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/RawRecordHeaderErrorMessageStrategy.java (version 14302088c5e560c3eaadaba048a3a112893b3091)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/InboundGatewayTests.java (version 14302088c5e560c3eaadaba048a3a112893b3091)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version 14302088c5e560c3eaadaba048a3a112893b3091)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version 14302088c5e560c3eaadaba048a3a112893b3091)
  • Gary Russell

    Gary Russell bc443474cbb6d1c794993640d90a9f2088782d58

    Pausable package change

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java (version bc443474cbb6d1c794993640d90a9f2088782d58)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version bc443474cbb6d1c794993640d90a9f2088782d58)
  • Gary Russell

    Gary Russell c25b3b45f44cd21d9abc8d0c5e52290ba3773bce

    Allow fetching multiple records
    Resolves https://github.com/spring-projects/spring-integration-kafka/issues/267

    - add an option to allow fetching multiple records per poll

    * DSL for new constructor arg

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaInboundChannelAdapterParser.java (version c25b3b45f44cd21d9abc8d0c5e52290ba3773bce)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/Kafka.java (version c25b3b45f44cd21d9abc8d0c5e52290ba3773bce)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundChannelAdapterSpec.java (version c25b3b45f44cd21d9abc8d0c5e52290ba3773bce)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version c25b3b45f44cd21d9abc8d0c5e52290ba3773bce)
    • spring-integration-kafka/src/main/resources/org/springframework/integration/kafka/config/spring-integration-kafka-3.2.xsd (version c25b3b45f44cd21d9abc8d0c5e52290ba3773bce)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaInboundChannelAdapterParserTests-context.xml (version c25b3b45f44cd21d9abc8d0c5e52290ba3773bce)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaInboundChannelAdapterParserTests.java (version c25b3b45f44cd21d9abc8d0c5e52290ba3773bce)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version c25b3b45f44cd21d9abc8d0c5e52290ba3773bce)
  • Gary Russell

    Gary Russell 28fc819fe9c25d75cb10cad41848dd21a4fada32

    Change MessageSource.payloadType to Class<?>
    - consistency with other endpoints
    - avoid the need for SpEL in XML config

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundChannelAdapterSpec.java (version 28fc819fe9c25d75cb10cad41848dd21a4fada32)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version 28fc819fe9c25d75cb10cad41848dd21a4fada32)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaInboundChannelAdapterParserTests-context.xml (version 28fc819fe9c25d75cb10cad41848dd21a4fada32)
  • Gary Russell

    Gary Russell e76fd2bea2bc902bab656b418fec9fd0f65da635

    Remove Lifecyle since it's the super of Pausable

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version e76fd2bea2bc902bab656b418fec9fd0f65da635)
  • Gary Russell

    Gary Russell e9833af73286e7d262af91591aafa68bf636accd

    Fix javadoFix javadoc

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version e9833af73286e7d262af91591aafa68bf636accd)
  • Gary Russell

    Gary Russell ca125a8a6ff06a42588f5998a0eb5ea5f548516a

    Polishing - PR comments.

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version ca125a8a6ff06a42588f5998a0eb5ea5f548516a)
  • Gary Russell

    Gary Russell f59a3687a97706d1ddb6fea46cc931b2337760a5

    Fix race in KafkaProducerMessageHandlerTests.

    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version f59a3687a97706d1ddb6fea46cc931b2337760a5)
  • Gary Russell

    Gary Russell 22b1e70e1346f665fc7ba336719b0b580c7b42b2

    GH-195: Add XML Schema support for new components
    Resolves https://github.com/spring-projects/spring-integration-kafka/issues/195

    - gateways
    - message source

    Polishing

    Don't start adapters in parser tests

    Fix XML filename for test

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaInboundChannelAdapterParser.java (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaInboundGatewayParser.java (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaNamespaceHandler.java (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaOutboundChannelAdapterParser.java (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaOutboundGatewayParser.java (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaParsingUtils.java (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/main/resources/org/springframework/integration/kafka/config/spring-integration-kafka-3.2.xsd (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/AllXmlTests-context.xml (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/AllXmlTests.java (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaInboundChannelAdapterParserTests-context.xml (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaInboundChannelAdapterParserTests.java (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaInboundGatewayTests-context.xml (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaInboundGatewayTests.java (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundGatewayParserTests-context.xml (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundGatewayParserTests.java (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version 22b1e70e1346f665fc7ba336719b0b580c7b42b2)
  • Artem Bilan

    Artem Bilan cc3895f40d6c3fcabe3351a5949950fe5d75f6c2

    Fix XSD for the current version

    • spring-integration-kafka/src/main/resources/META-INF/spring.schemas (version cc3895f40d6c3fcabe3351a5949950fe5d75f6c2)
    • spring-integration-kafka/src/main/resources/org/springframework/integration/kafka/config/spring-integration-kafka-3.2.xsd (version cc3895f40d6c3fcabe3351a5949950fe5d75f6c2)
  • Gary Russell

    Gary Russell ceb68b40ef3b919ed126e168b4cfb7ea1c2a4b17

    GH-260: Fix outbound tx synchronization
    Resolves https://github.com/spring-projects/spring-integration-kafka/issues/260

    The outbound endpoint used
    `TransactionSynchronizationManager.isActualTransactionActive()`
    to detect a global transaction instead of
    `TransactionSynchronizationManager.getResource(this.kafkaTemplate.getProducerFactory()) == null`.

    The KTM uses `SYNCHRONIZATION_NEVER` by default so the first will
    return false unless the synchronization is explicitly set. This
    causes a new transaction to be started.

    Use the presence of the resource holder instead.

    **cherry-pick to 3.1.x**

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version ceb68b40ef3b919ed126e168b4cfb7ea1c2a4b17)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version ceb68b40ef3b919ed126e168b4cfb7ea1c2a4b17)
  • Artem Bilan

    Artem Bilan eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d

    URL Cleanup
    This commit updates URLs to prefer the https protocol.
    Redirects are not followed to avoid accidentally expanding intentionally
    shortened URLs (i.e. if using a URL shortener).

    # Fixed URLs

    ## Fixed Success
    These URLs were switched to an https URL with a 2xx status.
    While the status was successful, your review is still recommended.

    * [ ] http://www.apache.org/licenses/ with 1 occurrences migrated to:
      https://www.apache.org/licenses/ ([https](https://www.apache.org/licenses/) result 200).
    * [ ] http://www.apache.org/licenses/LICENSE-2.0 with 28 occurrences migrated to:
      https://www.apache.org/licenses/LICENSE-2.0 ([https](https://www.apache.org/licenses/LICENSE-2.0) result 200).

    • spring-integration-kafka/src/checkstyle/checkstyle-header.txt (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/dist/license.txt (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaMessageDrivenChannelAdapterParser.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaNamespaceHandler.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaOutboundChannelAdapterParser.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/Kafka.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundChannelAdapterSpec.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundGatewaySpec.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageDrivenChannelAdapterSpec.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageListenerContainerSpec.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaOutboundGatewaySpec.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaProducerMessageHandlerSpec.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaTemplateSpec.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaInboundGateway.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/KafkaSendFailureException.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/RawRecordHeaderErrorMessageStrategy.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaMessageDrivenChannelAdapterParserTests.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/InboundGatewayTests.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceIntegrationTests.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
    • spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/KafkaDslKotlinTests.kt (version eb7f94ae0d3bb73d4f03a8b7b7e04f467a85fa8d)
  • Gary Russell

    Gary Russell 087247d96fdc09c9f8b2baf49cb2cf9582037c2e

    GH-259: Add pause/resume to KafkaMessageSource
    Resolves https://github.com/spring-projects/spring-integration-kafka/issues/259

    Enable pause/resume on the polled consumer.

    **cherry-pick to 3.1.x**

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version 087247d96fdc09c9f8b2baf49cb2cf9582037c2e)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version 087247d96fdc09c9f8b2baf49cb2cf9582037c2e)
  • Gary Russell

    Gary Russell 7fae571c2ddccff8f35cff4c94d4156bedbd01b7

    Changes for compatibility with Spring Kafka 2.3
    Also remove test for bad partition in DSL tests - the send now gives an error
    about the topic not being present in metadata instead of "not in range".

    Use sync for publishing in DSL tests, to fail fast.

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version 7fae571c2ddccff8f35cff4c94d4156bedbd01b7)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version 7fae571c2ddccff8f35cff4c94d4156bedbd01b7)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version 7fae571c2ddccff8f35cff4c94d4156bedbd01b7)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version 7fae571c2ddccff8f35cff4c94d4156bedbd01b7)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version 7fae571c2ddccff8f35cff4c94d4156bedbd01b7)
    • spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/KafkaDslKotlinTests.kt (version 7fae571c2ddccff8f35cff4c94d4156bedbd01b7)
  • Spring Operator <spring-operator@users.noreply.github.com>

    Spring Operator <spring-operator@users.noreply.github.com> 9b670950a5d529ae330c80d77bf4e88fa650d09c

    URL Cleanup
    This commit updates URLs to prefer the https protocol. Redirects are not followed to avoid accidentally expanding intentionally shortened URLs (i.e. if using a URL shortener).

    # Fixed URLs

    ## Fixed But Review Recommended
    These URLs were fixed, but the https status was not OK. However, the https status was the same as the http request or http redirected to an https URL, so they were migrated. Your review is recommended.

    * http://www.puppycrawl.com/dtds/configuration_1_2.dtd (404) with 1 occurrences migrated to:
      https://www.puppycrawl.com/dtds/configuration_1_2.dtd ([https](https://www.puppycrawl.com/dtds/configuration_1_2.dtd) result 404).
    * http://www.puppycrawl.com/dtds/suppressions_1_1.dtd (404) with 1 occurrences migrated to:
      https://www.puppycrawl.com/dtds/suppressions_1_1.dtd ([https](https://www.puppycrawl.com/dtds/suppressions_1_1.dtd) result 404).

    ## Fixed Success
    These URLs were switched to an https URL with a 2xx status. While the status was successful, your review is still recommended.

    * http://www.springframework.org/schema/beans/spring-beans.xsd with 2 occurrences migrated to:
      https://www.springframework.org/schema/beans/spring-beans.xsd ([https](https://www.springframework.org/schema/beans/spring-beans.xsd) result 200).
    * http://www.springframework.org/schema/context/spring-context.xsd with 1 occurrences migrated to:
      https://www.springframework.org/schema/context/spring-context.xsd ([https](https://www.springframework.org/schema/context/spring-context.xsd) result 200).
    * http://www.springframework.org/schema/integration/kafka/spring-integration-kafka.xsd with 2 occurrences migrated to:
      https://www.springframework.org/schema/integration/kafka/spring-integration-kafka.xsd ([https](https://www.springframework.org/schema/integration/kafka/spring-integration-kafka.xsd) result 200).
    * http://www.springframework.org/schema/integration/spring-integration.xsd with 1 occurrences migrated to:
      https://www.springframework.org/schema/integration/spring-integration.xsd ([https](https://www.springframework.org/schema/integration/spring-integration.xsd) result 200).

    # Ignored
    These URLs were intentionally ignored.

    * http://www.springframework.org/schema/beans with 4 occurrences
    * http://www.springframework.org/schema/context with 2 occurrences
    * http://www.springframework.org/schema/integration with 2 occurrences
    * http://www.springframework.org/schema/integration/kafka with 4 occurrences
    * http://www.w3.org/2001/XMLSchema-instance with 2 occurrences

    * Upgrade Checkstyle and its DTDs for HTTPS

    • spring-integration-kafka/src/checkstyle/checkstyle-suppressions.xml (version 9b670950a5d529ae330c80d77bf4e88fa650d09c)
    • spring-integration-kafka/src/checkstyle/checkstyle.xml (version 9b670950a5d529ae330c80d77bf4e88fa650d09c)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaMessageDrivenChannelAdapterParserTests-context.xml (version 9b670950a5d529ae330c80d77bf4e88fa650d09c)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests-context.xml (version 9b670950a5d529ae330c80d77bf4e88fa650d09c)
  • Artem Bilan

    Artem Bilan daedfb92108fe94699579d1845e487450922df81

    Upgrade dependencies and fix issues

    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version daedfb92108fe94699579d1845e487450922df81)
    • spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/KafkaDslKotlinTests.kt (version daedfb92108fe94699579d1845e487450922df81)
  • Gary Russell

    Gary Russell 71cdeee0b3f4ab0a6b7fc51037f2cdd1f1cd3cc8

    GH-235: KPMH: Flush the template in stop()
    Resolves https://github.com/spring-projects/spring-integration-kafka/issues/235

    **cherry-pick to 3.1.x**

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version 71cdeee0b3f4ab0a6b7fc51037f2cdd1f1cd3cc8)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version 71cdeee0b3f4ab0a6b7fc51037f2cdd1f1cd3cc8)
  • Spring Operator <spring-operator@users.noreply.github.com>

    Spring Operator <spring-operator@users.noreply.github.com> 4f54c4cab31fd9a337dd7103bc2a0835711c7fe6

    URL Cleanup
    This commit updates URLs to prefer the https protocol. Redirects are not followed to avoid accidentally expanding intentionally shortened URLs (i.e. if using a URL shortener).

    # Fixed URLs

    ## Fixed But Review Recommended
    These URLs were fixed, but the https status was not OK. However, the https status was the same as the http request or http redirected to an https URL, so they were migrated. Your review is recommended.

    * [ ] http://help.github.com/send-pull-requests (404) with 1 occurrences migrated to:
      https://help.github.com/send-pull-requests ([https](https://help.github.com/send-pull-requests) result 404).

    ## Fixed Success
    These URLs were switched to an https URL with a 2xx status. While the status was successful, your review is still recommended.

    * [ ] http://kafka.apache.org/ with 1 occurrences migrated to:
      https://kafka.apache.org/ ([https](https://kafka.apache.org/) result 200).
    * [ ] http://www.apache.org with 1 occurrences migrated to:
      https://www.apache.org ([https](https://www.apache.org) result 200).
    * [ ] http://www.springframework.org/schema/integration/spring-integration.xsd with 1 occurrences migrated to:
      https://www.springframework.org/schema/integration/spring-integration.xsd ([https](https://www.springframework.org/schema/integration/spring-integration.xsd) result 200).
    * [ ] http://static.springsource.org/spring-integration/reference (301) with 1 occurrences migrated to:
      https://docs.spring.io/spring-integration/reference ([https](https://static.springsource.org/spring-integration/reference) result 301).
    * [ ] http://www.springframework.org with 1 occurrences migrated to:
      https://www.springframework.org ([https](https://www.springframework.org) result 301).
    * [ ] http://www.springsource.com with 2 occurrences migrated to:
      https://www.springsource.com ([https](https://www.springsource.com) result 301).

    # Ignored
    These URLs were intentionally ignored.

    * http://www.springframework.org/schema/beans with 1 occurrences
    * http://www.springframework.org/schema/integration with 2 occurrences
    * http://www.springframework.org/schema/integration/kafka with 2 occurrences
    * http://www.springframework.org/schema/tool with 2 occurrences
    * http://www.w3.org/2001/XMLSchema with 1 occurrences

    • spring-integration-kafka/src/api/overview.html (version 4f54c4cab31fd9a337dd7103bc2a0835711c7fe6)
    • spring-integration-kafka/src/dist/notice.txt (version 4f54c4cab31fd9a337dd7103bc2a0835711c7fe6)
    • spring-integration-kafka/src/main/resources/org/springframework/integration/kafka/config/spring-integration-kafka-3.1.xsd (version 4f54c4cab31fd9a337dd7103bc2a0835711c7fe6)
  • Gary Russell

    Gary Russell 1873e9ae419edcc156971fef6d8d7c31e6d45211

    GH-211: MessageSource acks; fix concurrency
    Fixes https://github.com/spring-projects/spring-integration-kafka/issues/211

    Use `ConcurrentHashMap` with synchronized set values to avoid concurrency issues
    when acks are processed on multiple threads.

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version 1873e9ae419edcc156971fef6d8d7c31e6d45211)
  • Gary Russell

    Gary Russell e5b861dcea14916d89d4657bbd2e66c1734bf89d

    Remove unnecessary throws Exception clause

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaInboundGateway.java (version e5b861dcea14916d89d4657bbd2e66c1734bf89d)
  • Artem Bilan

    Artem Bilan f29bd3e322213ed69fc2c5cd3285894a366cb882

    GH-212: Add ConsumerSeekAware impl to Inbounds (#213)
    * GH-212: Add ConsumerSeekAware impl to Inbounds

    Fixes spring-projects/spring-integration-kafka#212

    **Cherry-pick to 3.0.x**

    * GH-212: Add ConsumerSeekAware impl to Inbounds

    Fixes spring-projects/spring-integration-kafka#212

    * Introduce a new `IntegrationKafkaHeaders.CONSUMER_SEEK_CALLBACK`
    header to be populated to messages for sending to the channel
    * Populate that header from the `KafkaInboundGateway` and
    `KafkaMessageDrivenChannelAdapter` into the message from the
    `seekCallBack` property if `ListenerContainer` is single-threaded or
    from the `ThreadLocal<ConsumerSeekAware.ConsumerSeekCallback>` otherwise;
    and only if newly introduced `setAdditionalHeaders` is `true`
    * Populate `seekCallBack` property or `ThreadLocal<?>` from the
    `registerSeekCallback()` implementation from the internal listeners
    * Add `setOnPartitionsAssignedSeekCallback(BiConsumer)` and
    `setOnIdleSeekCallback(BiConsumer)` options to react for the appropriate
    event from the underlying container and perform appropriate seek management
    * Add new options to the DSL classes and cover them with tests, including
    check for new `IntegrationKafkaHeaders.CONSUMER_SEEK_CALLBACK` header

    **Cherry-pick to 3.0.x**

    * Address PR comments: remove unnecessary API

    * *Polishing `setOnPartitionsAssignedSeekCallback()` JavaDocs
    *Close producers in the `KafkaProducerMessageHandlerTests`

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundGatewaySpec.java (version f29bd3e322213ed69fc2c5cd3285894a366cb882)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageDrivenChannelAdapterSpec.java (version f29bd3e322213ed69fc2c5cd3285894a366cb882)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaInboundGateway.java (version f29bd3e322213ed69fc2c5cd3285894a366cb882)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java (version f29bd3e322213ed69fc2c5cd3285894a366cb882)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version f29bd3e322213ed69fc2c5cd3285894a366cb882)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/InboundGatewayTests.java (version f29bd3e322213ed69fc2c5cd3285894a366cb882)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version f29bd3e322213ed69fc2c5cd3285894a366cb882)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version f29bd3e322213ed69fc2c5cd3285894a366cb882)
  • Gary Russell

    Gary Russell 19c3c4607f20b6622195c924e4d8a3e29120d3ff

    Fix TODOs in outbound channel adapter
    - always use `successChannel` for metadata
    - unwrap `ExecutionException`

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaOutboundChannelAdapterParser.java (version 19c3c4607f20b6622195c924e4d8a3e29120d3ff)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version 19c3c4607f20b6622195c924e4d8a3e29120d3ff)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java (version 19c3c4607f20b6622195c924e4d8a3e29120d3ff)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version 19c3c4607f20b6622195c924e4d8a3e29120d3ff)
  • Gary Russell

    Gary Russell 759e0e236d27e75348477ba6dd0254c14f11f75e

    Nullable fixes

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/RawRecordHeaderErrorMessageStrategy.java (version 759e0e236d27e75348477ba6dd0254c14f11f75e)
  • Gary Russell

    Gary Russell bedc0c8fdc2c75d9c0aca0bd4913d69b2fd34544

    GH-209: Upgrade to kafka-clients 2.0.0
    Fixes https://github.com/spring-projects/spring-integration-kafka/issues/209

    * README Polishing

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version bedc0c8fdc2c75d9c0aca0bd4913d69b2fd34544)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version bedc0c8fdc2c75d9c0aca0bd4913d69b2fd34544)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceIntegrationTests.java (version bedc0c8fdc2c75d9c0aca0bd4913d69b2fd34544)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version bedc0c8fdc2c75d9c0aca0bd4913d69b2fd34544)
  • Gary Russell

    Gary Russell 8decbe78100301fbfb0e5a65207672c55c760657

    GH-204: DSL Register container as bean if needed
    Fixes https://github.com/spring-projects/spring-integration-kafka/issues/204

    When an external container is provided to the DSL, register it as a bean
    if it is not already a bean.

    Polishing id from PR comments; add gateway support too.

    * Polishing JavaDocs and omissions in the test-case

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/Kafka.java (version 8decbe78100301fbfb0e5a65207672c55c760657)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundGatewaySpec.java (version 8decbe78100301fbfb0e5a65207672c55c760657)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageDrivenChannelAdapterSpec.java (version 8decbe78100301fbfb0e5a65207672c55c760657)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version 8decbe78100301fbfb0e5a65207672c55c760657)
  • Artem Bilan

    Artem Bilan e296d66a4b26d64a62d1b7ea99fb010ad2b552d3

    Kotlin compatibility: hide recursive generics
    Related to https://jira.spring.io/browse/INT-4458

    **Cherry-pick to 3.0.x**

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/Kafka.java (version e296d66a4b26d64a62d1b7ea99fb010ad2b552d3)
    • spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/KafkaDslKotlinTests.kt (version e296d66a4b26d64a62d1b7ea99fb010ad2b552d3)
  • Artem Bilan

    Artem Bilan 0c1cfbc9777dcbef843b458749473efeddc2e38b

    Upgrade to SI-5.1 M1, SK-2.2 M1
    * Fixes according the upgrades
    * Polishing some code style

    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaMessageDrivenChannelAdapterParserTests-context.xml (version 0c1cfbc9777dcbef843b458749473efeddc2e38b)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version 0c1cfbc9777dcbef843b458749473efeddc2e38b)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/InboundGatewayTests.java (version 0c1cfbc9777dcbef843b458749473efeddc2e38b)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version 0c1cfbc9777dcbef843b458749473efeddc2e38b)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceIntegrationTests.java (version 0c1cfbc9777dcbef843b458749473efeddc2e38b)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version 0c1cfbc9777dcbef843b458749473efeddc2e38b)
    • spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/KafkaDslKotlinTests.kt (version 0c1cfbc9777dcbef843b458749473efeddc2e38b)
  • Gary Russell

    Gary Russell d13551e6c35c525437d05a32b4b71a8bc86c0d43

    Revert "GH-198: Support pause/resume on inbound adapter"
    This reverts commit 7befa83ba87058540f624ec1bf33fcabf054f3b5.

    Temporary revert; pushed to 3.0.3

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java (version d13551e6c35c525437d05a32b4b71a8bc86c0d43)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version d13551e6c35c525437d05a32b4b71a8bc86c0d43)
  • Gary Russell

    Gary Russell fc3f33671b882868863ce2b4dac22d6c7fbe8531

    GH-198: Support pause/resume on inbound adapter
    Resolves https://github.com/spring-projects/spring-integration-kafka/issues/198

    You can now pause/resume the consumer.

    Any records previously fetched will be processed before the pause takes effect.
    The listener container requires an `idleEventInterval`, a resume will take effect
    on the next `ListenerContainerIdleEvent`.

    * Delegate Pausable methods to listener container

    Requires https://github.com/spring-projects/spring-kafka/pull/584

    * Polishing

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java (version fc3f33671b882868863ce2b4dac22d6c7fbe8531)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version fc3f33671b882868863ce2b4dac22d6c7fbe8531)
  • Gary Russell

    Gary Russell 1e006c9de723028a6af006bf45217912f32e0e9d

    Fix imports

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version 1e006c9de723028a6af006bf45217912f32e0e9d)
  • Gary Russell

    Gary Russell c807ed5335b06b8082b59137f56b50f20dc7deaf

    Fix typo in warning log.

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version c807ed5335b06b8082b59137f56b50f20dc7deaf)
  • Artem Bilan

    Artem Bilan 1be6a6a3fa97cd2e399b772610a56b98a2cd0bbb

    Start version 3.1 for compatibility with SK-2.2

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/Kafka.java (version 1be6a6a3fa97cd2e399b772610a56b98a2cd0bbb)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageListenerContainerSpec.java (version 1be6a6a3fa97cd2e399b772610a56b98a2cd0bbb)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version 1be6a6a3fa97cd2e399b772610a56b98a2cd0bbb)
    • spring-integration-kafka/src/main/resources/META-INF/spring.schemas (version 1be6a6a3fa97cd2e399b772610a56b98a2cd0bbb)
    • spring-integration-kafka/src/main/resources/org/springframework/integration/kafka/config/spring-integration-kafka-3.1.xsd (version 1be6a6a3fa97cd2e399b772610a56b98a2cd0bbb)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaMessageDrivenChannelAdapterParserTests-context.xml (version 1be6a6a3fa97cd2e399b772610a56b98a2cd0bbb)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaMessageDrivenChannelAdapterParserTests.java (version 1be6a6a3fa97cd2e399b772610a56b98a2cd0bbb)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version 1be6a6a3fa97cd2e399b772610a56b98a2cd0bbb)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/InboundGatewayTests.java (version 1be6a6a3fa97cd2e399b772610a56b98a2cd0bbb)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version 1be6a6a3fa97cd2e399b772610a56b98a2cd0bbb)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version 1be6a6a3fa97cd2e399b772610a56b98a2cd0bbb)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version 1be6a6a3fa97cd2e399b772610a56b98a2cd0bbb)
  • Gary Russell

    Gary Russell accd2d908841f6b4b437aed3ee8a854bdd7a66fb

    Debug logging for InboundGatewayTests

    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/InboundGatewayTests.java (version accd2d908841f6b4b437aed3ee8a854bdd7a66fb)
  • Gary Russell

    Gary Russell bd774de5c0d9bf8263b2cbe4a74879531e786c1c

    Support transaction initiation in ob endpoints
    * Use template.isTransactional()

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version bd774de5c0d9bf8263b2cbe4a74879531e786c1c)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version bd774de5c0d9bf8263b2cbe4a74879531e786c1c)
  • Gary Russell

    Gary Russell 98a7c4241d7d8620956766bb74ebd217e946263e

    Trace logging for InboundGatewayTests

    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/InboundGatewayTests.java (version 98a7c4241d7d8620956766bb74ebd217e946263e)
  • Gary Russell

    Gary Russell 7b7bcf1014323ab4405baab3a1c7586fe5acdeae

    Fix Race in InboundGatewayTests
    The debug log indicates that the reply was successfully sent but never
    received. My working theory is that the reply consumer got the reply
    during the `poll()` to force the subscription.

    Start the consumers before the replies are sent.

    I will also add code to `KafkaEmbedded` to seek to beginning all topics
    if necessary.

    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/InboundGatewayTests.java (version 7b7bcf1014323ab4405baab3a1c7586fe5acdeae)
  • Gary Russell

    Gary Russell 17ea7dace7ffe42a4a0b738f8f4058255cecb1f4

    GH-198: Support pause/resume on inbound adapter
    Resolves https://github.com/spring-projects/spring-integration-kafka/issues/198

    You can now pause/resume the consumer.

    Any records previously fetched will be processed before the pause takes effect.
    The listener container requires an `idleEventInterval`, a resume will take effect
    on the next `ListenerContainerIdleEvent`.

    * Delegate Pausable methods to listener container

    Requires https://github.com/spring-projects/spring-kafka/pull/584

    * Polishing

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java (version 17ea7dace7ffe42a4a0b738f8f4058255cecb1f4)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version 17ea7dace7ffe42a4a0b738f8f4058255cecb1f4)
  • Mark <markinnork7@gmail.com>

    Mark <markinnork7@gmail.com> 86d8373084fa71f1fede3b029d0424df9e1fa9d0

    Polish synchronization in KafkaMessageSource
    * Remove volatile from running flag

    As running is always accessed through `KafkaMessageSource` monitor use existing `synchronized` to guard access to it.
    Also move setting `running=true` from consumerMonitor in `createConsumer()` method to `doReceive()` as it's guarded by needed lock

    * Extract common stopping consumer logic

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version 86d8373084fa71f1fede3b029d0424df9e1fa9d0)
  • Gary Russell

    Gary Russell a997740c298c28baa254ab9625235167bc1f71d3

    More Lifecycle Polishing
    - `null` the consumer on `stop()`
    - set `running` to true on first receive if needed

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version a997740c298c28baa254ab9625235167bc1f71d3)
  • Gary Russell

    Gary Russell 28b4dd814c27bdc60b89d10744613655afd1281e

    Remove pause/resumer; add Lifecycle
    Pause/resume was too chatty - user can avoid a rebalance with `max.poll.interval.ms`.

    Implement `Lifecyle` and `close()` the consumer on `stop()`.

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version 28b4dd814c27bdc60b89d10744613655afd1281e)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version 28b4dd814c27bdc60b89d10744613655afd1281e)
  • Gary Russell

    Gary Russell d73844700513491465c863a182b94caa3617e09d

    GH-189: MessageSource - remove seek after poll
    Fixes https://github.com/spring-projects/spring-integration-kafka/issues/189

    If the DKCFactory is being used, force the `max.poll.records` property to 1.
    Otherwise, throw an `IllegalArgumentException`.

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version d73844700513491465c863a182b94caa3617e09d)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version d73844700513491465c863a182b94caa3617e09d)
  • Gary Russell

    Gary Russell 2b292f2a7d90624d63c719dfef3e3432677de980

    GH-161: Implement Gateways
    Resolves https://github.com/spring-projects/spring-integration-kafka/issues/161

    Initial commit - outbound

    TODO: inbound, DSL, XML, Docs

    Fix reply topic.

    Polishing - don't leak internal headers; don't propagate outbound headers (topic etc.).

    Polishing

    Validate reply topic and partition against replying template.

    DSL

    Checkstyle fixes.

    Add inbound gateway.

    Inbound DSL

    Polishing - PR comments.

    Polishing - PR comments

    More polishing

    Increase test timeouts.

    Increase test timeouts.

    * Code style polishing
    * Fix `KafkaInboundGatewaySpec.getComponentsToRegister()` to `get()`
    on Specs
    * Remove `getContainer()` in the `KafkaMessageListenerContainerSpec` in
    favor of `get()` in the `IntegrationComponentSpec`

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/Kafka.java (version 2b292f2a7d90624d63c719dfef3e3432677de980)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundGatewaySpec.java (version 2b292f2a7d90624d63c719dfef3e3432677de980)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageDrivenChannelAdapterSpec.java (version 2b292f2a7d90624d63c719dfef3e3432677de980)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageListenerContainerSpec.java (version 2b292f2a7d90624d63c719dfef3e3432677de980)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaOutboundGatewaySpec.java (version 2b292f2a7d90624d63c719dfef3e3432677de980)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaProducerMessageHandlerSpec.java (version 2b292f2a7d90624d63c719dfef3e3432677de980)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaTemplateSpec.java (version 2b292f2a7d90624d63c719dfef3e3432677de980)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaInboundGateway.java (version 2b292f2a7d90624d63c719dfef3e3432677de980)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java (version 2b292f2a7d90624d63c719dfef3e3432677de980)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version 2b292f2a7d90624d63c719dfef3e3432677de980)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version 2b292f2a7d90624d63c719dfef3e3432677de980)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/InboundGatewayTests.java (version 2b292f2a7d90624d63c719dfef3e3432677de980)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version 2b292f2a7d90624d63c719dfef3e3432677de980)
  • Gary Russell

    Gary Russell 29973e525de5ea2686cf08e1f487e4e1bdda7adf

    GH-185: Add deliveryAttempts header with retry
    Resolves: https://github.com/spring-projects/spring-integration-kafka/issues/185

    When a `RetryTemplate` is wired into the message-driven adapter, add
    and increment an `AtomicInteger`-valued header.

    See https://jira.spring.io/browse/INT-4369

    * Actualize Copyright in the affected classes

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java (version 29973e525de5ea2686cf08e1f487e4e1bdda7adf)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version 29973e525de5ea2686cf08e1f487e4e1bdda7adf)
  • Gary Russell

    Gary Russell fb9dd91644197cdfba3fc7aaffc18882a786fcaa

    Fix test case for previous commit

    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version fb9dd91644197cdfba3fc7aaffc18882a786fcaa)
  • Gary Russell

    Gary Russell b44dab40faddf45eadf291f45374f06beecd7f69

    GH-184: Add Polled MessageSource
    Resolves https://github.com/spring-projects/spring-integration-kafka/issues/184

    Polishing - changes in core

    Pause/Resume; Add integration tests

    Synchronize all consumer operations on the consumer, to support noAutoAck()

    Polishing - PR Comments

    More polishing

    Major rework - see commit comment

    - only fetch one record at a time (warn log and seek if max.poll.records incorrect)
    - when an application has multiple outstanding records,
     - track records; apply commits in the right order, deferring if necessary
     - when requeued, mark later offsets as rolled back to prevent commits
    - Support transactions
     - start/end transactions
     - provide access to the producer

    Fix transaction synchronization

    - if there is an existing Kafka transaction, participate in it
    - if not, bind a new transactional resource to the thread - allows a KafkaTemplate to
      participate by utilizing the producer factory message header
    - if there is an existing non-kafka transaction, sync the kafka transaction with it

    Check for KafkaMessageHeaders when building the message.

    Polishing - PR Comments

    Simplify AckInfo

    Remove internal transaction support - the user can start a transacion before calling receive
    and send offsets to the transaction using a KafkaTemplate.

    Polishing

    * Simple polishing according IDEA warnings
    * Upgrade to Gradle 4.4.1
    * Some upgrades and dependencies polishing

    • spring-integration-kafka/src/checkstyle/checkstyle.xml (version b44dab40faddf45eadf291f45374f06beecd7f69)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/Kafka.java (version b44dab40faddf45eadf291f45374f06beecd7f69)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundChannelAdapterSpec.java (version b44dab40faddf45eadf291f45374f06beecd7f69)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version b44dab40faddf45eadf291f45374f06beecd7f69)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version b44dab40faddf45eadf291f45374f06beecd7f69)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceIntegrationTests.java (version b44dab40faddf45eadf291f45374f06beecd7f69)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version b44dab40faddf45eadf291f45374f06beecd7f69)
  • Gary Russell

    Gary Russell 23bc29958c0124b3077a93ab2710e844cd860f05

    GH-184: Polishing - user rebalance listener
    Needed by the SCST Kafka Binder

    * GH-184: Polishing - add raw header option

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundChannelAdapterSpec.java (version 23bc29958c0124b3077a93ab2710e844cd860f05)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java (version 23bc29958c0124b3077a93ab2710e844cd860f05)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceIntegrationTests.java (version 23bc29958c0124b3077a93ab2710e844cd860f05)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java (version 23bc29958c0124b3077a93ab2710e844cd860f05)
  • Gary Russell

    Gary Russell 857980349eda29f1fbbaeb3c07d576d03bc2d520

    GH-172: Add Success and Failure Message Channels
    Resolves https://github.com/spring-projects/spring-integration-kafka/issues/172

    Use `ErrorMessageStrategy` to build an error message in the event of a failure.

    Update to SI 4.3.12.

    Polishing - PR Comments - Use standard outputChannel (if configured) for success.

    Polishing - PR Comments

    Javadoc Polishing

    * Polishing `@since` in JavaDocs

    * Upgrade to Checkstyle 8.1, SI-5.0.B-S
    * Adjust `RequireThis` rule and fix vulnerabilities

    # Conflicts:
    #        build.gradle
    #        src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java

    • spring-integration-kafka/src/checkstyle/checkstyle-suppressions.xml (version 857980349eda29f1fbbaeb3c07d576d03bc2d520)
    • spring-integration-kafka/src/checkstyle/checkstyle.xml (version 857980349eda29f1fbbaeb3c07d576d03bc2d520)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaProducerMessageHandlerSpec.java (version 857980349eda29f1fbbaeb3c07d576d03bc2d520)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version 857980349eda29f1fbbaeb3c07d576d03bc2d520)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/KafkaSendFailureException.java (version 857980349eda29f1fbbaeb3c07d576d03bc2d520)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaMessageDrivenChannelAdapterParserTests.java (version 857980349eda29f1fbbaeb3c07d576d03bc2d520)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version 857980349eda29f1fbbaeb3c07d576d03bc2d520)
  • Gary Russell

    Gary Russell 37ffd4e2e96b02ae44d450f5370a479de2142834

    GH-170: Add Support for Kafka Headers
    Resolves https://github.com/spring-projects/spring-integration-kafka/issues/170

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version 37ffd4e2e96b02ae44d450f5370a479de2142834)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version 37ffd4e2e96b02ae44d450f5370a479de2142834)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version 37ffd4e2e96b02ae44d450f5370a479de2142834)
  • Gary Russell

    Gary Russell 0580252f7a08b0466771af0318db3d7f87dca6f8

    Polishing - PR Comments

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaProducerMessageHandlerSpec.java (version 0580252f7a08b0466771af0318db3d7f87dca6f8)
  • Gary Russell

    Gary Russell b65f59cd679458c81d4b56d979a7a803285a40c5

    GH-180: Add headerMapper() to DSL
    Fixes https://github.com/spring-projects/spring-integration-kafka/issues/180

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaProducerMessageHandlerSpec.java (version b65f59cd679458c81d4b56d979a7a803285a40c5)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version b65f59cd679458c81d4b56d979a7a803285a40c5)
  • Gary Russell

    Gary Russell 7aa04d32243ead986c6bd7e4f396321348e6212e

    GH-175: XML Support for Error Handling
    Resolves spring-projects/spring-integration-kafka#175

    __cherry-pick to 2.3.x__

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaMessageDrivenChannelAdapterParser.java (version 7aa04d32243ead986c6bd7e4f396321348e6212e)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaOutboundChannelAdapterParser.java (version 7aa04d32243ead986c6bd7e4f396321348e6212e)
    • spring-integration-kafka/src/main/resources/org/springframework/integration/kafka/config/spring-integration-kafka-3.0.xsd (version 7aa04d32243ead986c6bd7e4f396321348e6212e)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaMessageDrivenChannelAdapterParserTests-context.xml (version 7aa04d32243ead986c6bd7e4f396321348e6212e)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaMessageDrivenChannelAdapterParserTests.java (version 7aa04d32243ead986c6bd7e4f396321348e6212e)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests-context.xml (version 7aa04d32243ead986c6bd7e4f396321348e6212e)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java (version 7aa04d32243ead986c6bd7e4f396321348e6212e)
  • Artem Bilan

    Artem Bilan 8d18799ca85b836811043f02ca6d42894a5dae02

    Adapt Java DSL to the latest SI
    * Add ability to specify `id` for `MessageListenerContainer` and
    `KafkaTemplate` beans configured internally and exposed as beans
    by the DSL

    checkstyle

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/Kafka.java (version 8d18799ca85b836811043f02ca6d42894a5dae02)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageDrivenChannelAdapterSpec.java (version 8d18799ca85b836811043f02ca6d42894a5dae02)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaProducerMessageHandlerSpec.java (version 8d18799ca85b836811043f02ca6d42894a5dae02)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version 8d18799ca85b836811043f02ca6d42894a5dae02)
  • Gary Russell

    Gary Russell 69e533f3381818bacd6d371d2c7b6d4fd7610afc

    Compatibility with Latest 2.0.0.BUILD-SNAPSHOT
    Removed methods.

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageDrivenChannelAdapterSpec.java (version 69e533f3381818bacd6d371d2c7b6d4fd7610afc)
  • Artem Bilan

    Artem Bilan 8d15b9582a94d48d4b6ca2bd6d2a24195f5882ba

    Upgrade to SK 2.0 M3, Gradle 4.0.1

    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java (version 8d15b9582a94d48d4b6ca2bd6d2a24195f5882ba)
  • Gary Russell

    Gary Russell ee6b3f87b3bc3df460522676efa0bbe58bf62869

    GH-164: Spring Kafka 2.0.0 Compatibility
    Resolves: https://github.com/spring-projects/spring-integration-kafka/issues/164

    Also gradle 3.5.

    Requires https://github.com/spring-projects/spring-kafka/pull/296

    Fix javadocs

    More javadoc polishing

    Updates for new Consumer header

    * Simple polishing

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageDrivenChannelAdapterSpec.java (version ee6b3f87b3bc3df460522676efa0bbe58bf62869)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java (version ee6b3f87b3bc3df460522676efa0bbe58bf62869)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaMessageDrivenChannelAdapterParserTests.java (version ee6b3f87b3bc3df460522676efa0bbe58bf62869)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version ee6b3f87b3bc3df460522676efa0bbe58bf62869)
  • Gary Russell

    Gary Russell c219a43c585c29c9771bcf34c0b4cf128a7bd875

    SCSt-913: Add Support for Enhanced Error Handling
    - bind input message, raw record to retry context
    - support recover without retry (recover after a single shot)

    Change RecoveryCallback from <Void> to <Object>

    Actually <? extends Object> for backwards compatibility.

    Changes needed for the latest updates to Spring Integration

    Now that the 4.3.10.BS artifacts are in artifactory.

    Suppress Deprecation Warnings

    checkstyle and PR Comments

    Javadocs and TL.remove()

    Fix Attributes Logic

    Polishing - PR Comments - Enhanced error message for conversion errors.

    Make errorChannel and retryTemplate mutually exclusive

    Fix TL.remove with retry.

    * Polishing `build.gradle` before merging

    Fix TL.remove with retry.

    Remove mavenLocal()

    Conflicts:
            build.gradle
            src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java

    * Use `KafkaHeaders.RAW_DATA`
    * Use `ErrorMesage` directly
    * Adapt DSL test to use `ErrorMessageSendingRecoverer`

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageDrivenChannelAdapterSpec.java (version c219a43c585c29c9771bcf34c0b4cf128a7bd875)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java (version c219a43c585c29c9771bcf34c0b4cf128a7bd875)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/package-info.java (version c219a43c585c29c9771bcf34c0b4cf128a7bd875)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/RawRecordHeaderErrorMessageStrategy.java (version c219a43c585c29c9771bcf34c0b4cf128a7bd875)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/package-info.java (version c219a43c585c29c9771bcf34c0b4cf128a7bd875)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version c219a43c585c29c9771bcf34c0b4cf128a7bd875)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version c219a43c585c29c9771bcf34c0b4cf128a7bd875)
  • Biju Kunjummen <biju.kunjummen@gmail.com>

    Biju Kunjummen <biju.kunjummen@gmail.com> 9e047e77038c7515229d51710f3613b93f4b1ce4

    GH-158: Add record timestamp support
    Fixes spring-projects/spring-integration-kafka#158

    Fixing build - replaced a call to removed API in spring-kafka project

    Support for timestamp expression in SI schema and SI DSL

    * Polishing according PR comments

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaOutboundChannelAdapterParser.java (version 9e047e77038c7515229d51710f3613b93f4b1ce4)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaProducerMessageHandlerSpec.java (version 9e047e77038c7515229d51710f3613b93f4b1ce4)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version 9e047e77038c7515229d51710f3613b93f4b1ce4)
    • spring-integration-kafka/src/main/resources/org/springframework/integration/kafka/config/spring-integration-kafka-3.0.xsd (version 9e047e77038c7515229d51710f3613b93f4b1ce4)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests-context.xml (version 9e047e77038c7515229d51710f3613b93f4b1ce4)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java (version 9e047e77038c7515229d51710f3613b93f4b1ce4)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java (version 9e047e77038c7515229d51710f3613b93f4b1ce4)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java (version 9e047e77038c7515229d51710f3613b93f4b1ce4)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandlerTests.java (version 9e047e77038c7515229d51710f3613b93f4b1ce4)
  • Gary Russell

    Gary Russell 328e9cdb578dc1aeef3e8bbab86345e8c7d90ac1

    Update to Spring Kafka 2.0.0
    Revert assertJ to the Cairo version; an issue with 3.5.2 needs to be investigated.

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageDrivenChannelAdapterSpec.java (version 328e9cdb578dc1aeef3e8bbab86345e8c7d90ac1)
  • Artem Bilan

    Artem Bilan 87561e565f86de2a9972f093b6f9a5e5dc984315

    Move XSD to 3.0 version
    * Upgrade to Gradle 3.2
    * Increase timeout in the `KafkaTests`

    • spring-integration-kafka/src/main/resources/META-INF/spring.schemas (version 87561e565f86de2a9972f093b6f9a5e5dc984315)
    • spring-integration-kafka/src/main/resources/org/springframework/integration/kafka/config/spring-integration-kafka-3.0.xsd (version 87561e565f86de2a9972f093b6f9a5e5dc984315)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaTests.java (version 87561e565f86de2a9972f093b6f9a5e5dc984315)
  • Artem Bilan

    Artem Bilan 598eb7f80eae57c039c6d99e5d421f3f3d357d05

    Upgrade to SI-5.0 & Port `Kafka` Java DSL
    * Upgrade all the dependencies
    * Upgrade to Gradle 3.1 (experimental)
    * Make Java 8 as minimal
    * Decrease test logging level to `warn`
    * Document Java DSL support and some other polishing in the `README.adoc`

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/Kafka.java (version 598eb7f80eae57c039c6d99e5d421f3f3d357d05)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageDrivenChannelAdapterSpec.java (version 598eb7f80eae57c039c6d99e5d421f3f3d357d05)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaProducerMessageHandlerSpec.java (version 598eb7f80eae57c039c6d99e5d421f3f3d357d05)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/package-info.java (version 598eb7f80eae57c039c6d99e5d421f3f3d357d05)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaTests.java (version 598eb7f80eae57c039c6d99e5d421f3f3d357d05)
    • spring-integration-kafka/src/test/resources/log4j2-test.xml (version 598eb7f80eae57c039c6d99e5d421f3f3d357d05)
  • Artem Bilan

    Artem Bilan 696376c72877f9da621628770532089cdf127c36

    Downgrade to AssertJ 2.5 for Boot compatibility
    See https://github.com/spring-projects/spring-kafka/issues/196

    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java (version 696376c72877f9da621628770532089cdf127c36)
  • Artem Bilan

    Artem Bilan 8cd471532d6a4dd3df6140792fc31eb9ddaa90d9

    GH-145 send-timeout(-expression) and XSD for them
    Fixes GH-145 (https://github.com/spring-projects/spring-integration-kafka/issues/145)

    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/config/xml/KafkaOutboundChannelAdapterParser.java (version 8cd471532d6a4dd3df6140792fc31eb9ddaa90d9)
    • spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java (version 8cd471532d6a4dd3df6140792fc31eb9ddaa90d9)
    • spring-integration-kafka/src/main/resources/org/springframework/integration/kafka/config/spring-integration-kafka-2.1.xsd (version 8cd471532d6a4dd3df6140792fc31eb9ddaa90d9)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests-context.xml (version 8cd471532d6a4dd3df6140792fc31eb9ddaa90d9)
    • spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java (version 8cd471532d6a4dd3df6140792fc31eb9ddaa90d9)