Commit Graph

  • 1e484d0fad Support flush after send Gary Russell 2020-03-23 11:53:00 -04:00
  • e0be544a40 Add more XSD version into spring.schemas Artem Bilan 2020-03-18 14:40:38 -04:00
  • a58169f4e1 Fix Gradle Deprecations Gary Russell 2020-03-18 14:27:25 -04:00
  • 81b9ae4a7a Use core Kotlin DSL Gary Russell 2020-03-17 13:30:36 -04:00
  • 0b7ea6d3c2 Remove deprecated methods Gary Russell 2020-03-17 13:09:25 -04:00
  • bdd236052b Upgrade to SK 2.5.0 Gary Russell 2020-03-17 12:09:21 -04:00
  • aaaaf86c07 GH-296: DSL: Support inline pub/sub subscriptions Gary Russell 2020-02-26 17:56:34 -05:00
  • 2331eee642 GH-296: Add Kafka-backed MessageChannels Gary Russell 2020-02-24 15:11:32 -05:00
  • 905a5155bc Master to 3.3; support non-Tx if template allows Gary Russell 2020-02-20 12:30:39 -05:00
  • f596e49242 Upgrade to latest releases Artem Bilan 2020-02-14 17:57:32 -05:00
  • 27f0775fb8 Apply SI-Kotlin-DSL in tests (#292) Artem Bilan 2019-11-06 10:01:25 -05:00
  • 386c64c617 Support ProducerRecord outbound payloads Gary Russell 2019-10-30 15:29:19 -04:00
  • cf3aa29a23 GH-290: Add ProducerRecordCreator Gary Russell 2019-10-30 12:41:55 -04:00
  • 6cddb2c169 Revert "Apply SI-Kotlin-DSL in tests" Gary Russell 2019-10-30 12:33:52 -04:00
  • 9b0b87d37e Apply SI-Kotlin-DSL in tests Artem Bilan 2019-10-02 15:44:46 -04:00
  • bf0134cb52 Upgrade to latest GAs Artem Bilan 2019-10-01 14:48:07 -04:00
  • 0e74cd1cee Add XML attribute for header-mapper tomvandenberge 2019-09-30 16:23:37 +02:00
  • 8cc2b2cc00 KMessageSource getter for consumer properties Gary Russell 2019-09-25 15:18:28 -04:00
  • adf91edf05 KMSource: Consumer Property Overrides Gary Russell 2019-09-18 13:22:11 -04:00
  • f6d858c7aa Polishing JavaDocs and possible NPEs Artem Bilan 2019-08-29 19:08:15 -04:00
  • 3831919cbc GH-282: KMSource - support async commits etc Gary Russell 2019-08-29 17:38:07 -04:00
  • c20ef85168 GH-280: Add topicPattern support to KafkaMessageSource Anshul Mehra 2019-08-28 15:55:42 -04:00
  • e52c535f7c Use ConsumerProperties in KafkaMessageSource Anshul Mehra 2019-08-23 14:07:44 -04:00
  • e6cdb8818f GH-279: Fix tests for latest SK Snapshots Gary Russell 2019-08-19 12:35:31 -04:00
  • 4cd81fda78 Fix NPE for retryTemp!=null but recoveryCall==null Urs Keller 2019-07-10 17:52:51 +02:00
  • d96a2d930c Add HTTPS entries for XSD into spring.schemas Artem Bilan 2019-07-18 13:10:01 -04:00
  • 41de7495e6 Resolve deprecations and other compiler warnings Gary Russell 2019-07-17 16:30:08 -04:00
  • 600e88ec56 GH-272: Add KafkaMDrivenChAdapterSpec.payloadType Cameron Mayfield 2019-06-25 07:12:37 -07:00
  • a1b51c9f47 Fix tests for SK 2.3.0.M3 Gary Russell 2019-06-14 17:35:37 -04:00
  • bc443474cb Pausable package change Gary Russell 2019-06-14 11:01:22 -04:00
  • 14302088c5 SIGH-2958: Add source record to common SI Header Gary Russell 2019-06-11 10:46:51 -04:00
  • c25b3b45f4 Allow fetching multiple records Gary Russell 2019-04-17 17:54:14 -04:00
  • cd6d17e4b0 GH-265: Ensure assignTimeout is used when no partitions are assigned Anshul Mehra 2019-04-16 23:15:16 -04:00
  • 28fc819fe9 Change MessageSource.payloadType to Class<?> Gary Russell 2019-04-04 08:15:52 -04:00
  • 22b1e70e13 GH-195: Add XML Schema support for new components Gary Russell 2019-04-03 12:49:51 -04:00
  • f59a3687a9 Fix race in KafkaProducerMessageHandlerTests. Gary Russell 2019-04-02 13:05:57 -04:00
  • e9833af732 Fix javadoFix javadoc Gary Russell 2019-04-02 12:34:08 -04:00
  • e76fd2bea2 Remove Lifecyle since it's the super of Pausable Gary Russell 2019-04-02 12:20:35 -04:00
  • ca125a8a6f Polishing - PR comments. Gary Russell 2019-04-02 12:19:50 -04:00
  • 087247d96f GH-259: Add pause/resume to KafkaMessageSource Gary Russell 2019-04-02 10:43:42 -04:00
  • ceb68b40ef GH-260: Fix outbound tx synchronization Gary Russell 2019-04-01 15:23:01 -04:00
  • cc3895f40d Fix XSD for the current version Artem Bilan 2019-03-27 11:59:36 -04:00
  • eb7f94ae0d URL Cleanup Artem Bilan 2019-03-25 12:45:52 -04:00
  • 71cdeee0b3 GH-235: KPMH: Flush the template in stop() Gary Russell 2019-03-25 10:54:20 -04:00
  • 4f54c4cab3 URL Cleanup Spring Operator 2019-03-20 20:05:52 -05:00
  • 9b670950a5 URL Cleanup Spring Operator 2019-03-19 22:39:58 -05:00
  • 7fae571c2d Changes for compatibility with Spring Kafka 2.3 Gary Russell 2019-02-26 12:36:25 -05:00
  • daedfb9210 Upgrade dependencies and fix issues Artem Bilan 2019-02-13 16:05:01 -05:00
  • e5b861dcea Remove unnecessary throws Exception clause Gary Russell 2019-02-12 17:53:02 -05:00
  • 1873e9ae41 GH-211: MessageSource acks; fix concurrency Gary Russell 2018-11-13 11:54:22 -05:00
  • 759e0e236d Nullable fixes Gary Russell 2018-10-29 13:22:13 -04:00
  • 19c3c4607f Fix TODOs in outbound channel adapter Gary Russell 2018-10-04 12:09:15 -04:00
  • f29bd3e322 GH-212: Add ConsumerSeekAware impl to Inbounds (#213) Artem Bilan 2018-09-07 14:31:59 -04:00
  • bedc0c8fdc GH-209: Upgrade to kafka-clients 2.0.0 Gary Russell 2018-08-02 15:18:18 -04:00
  • 0c1cfbc977 Upgrade to SI-5.1 M1, SK-2.2 M1 Artem Bilan 2018-07-30 09:47:38 -04:00
  • 8decbe7810 GH-204: DSL Register container as bean if needed Gary Russell 2018-05-14 12:43:01 -04:00
  • e296d66a4b Kotlin compatibility: hide recursive generics Artem Bilan 2018-05-01 11:42:58 -04:00
  • 1e006c9de7 Fix imports Gary Russell 2018-04-26 13:15:44 -04:00
  • c807ed5335 Fix typo in warning log. Gary Russell 2018-04-26 12:53:31 -04:00
  • 1be6a6a3fa Start version 3.1 for compatibility with SK-2.2 Artem Bilan 2018-04-13 21:01:46 -04:00
  • fc3f33671b GH-198: Support pause/resume on inbound adapter Gary Russell 2018-02-22 08:48:58 -05:00
  • d13551e6c3 Revert "GH-198: Support pause/resume on inbound adapter" Gary Russell 2018-02-22 09:35:13 -05:00
  • 17ea7dace7 GH-198: Support pause/resume on inbound adapter Gary Russell 2018-02-22 08:48:58 -05:00
  • 7b7bcf1014 Fix Race in InboundGatewayTests Gary Russell 2018-02-14 16:24:01 -05:00
  • 98a7c4241d Trace logging for InboundGatewayTests Gary Russell 2018-02-14 13:25:35 -05:00
  • accd2d9088 Debug logging for InboundGatewayTests Gary Russell 2018-02-14 11:14:52 -05:00
  • bd774de5c0 Support transaction initiation in ob endpoints Gary Russell 2018-02-14 10:06:53 -05:00
  • 2b292f2a7d GH-161: Implement Gateways Gary Russell 2018-02-02 17:26:40 -05:00
  • 86d8373084 Polish synchronization in KafkaMessageSource Mark 2018-01-30 19:42:32 +02:00
  • a997740c29 More Lifecycle Polishing Gary Russell 2018-01-23 16:33:48 -05:00
  • 28b4dd814c Remove pause/resumer; add Lifecycle Gary Russell 2018-01-23 13:29:54 -05:00
  • d738447005 GH-189: MessageSource - remove seek after poll Gary Russell 2018-01-22 15:39:41 -05:00
  • 23bc29958c GH-184: Polishing - user rebalance listener Gary Russell 2018-01-12 14:08:16 -05:00
  • b44dab40fa GH-184: Add Polled MessageSource Gary Russell 2017-12-26 17:17:36 -05:00
  • 29973e525d GH-185: Add deliveryAttempts header with retry Gary Russell 2017-12-28 15:59:00 -05:00
  • fb9dd91644 Fix test case for previous commit Gary Russell 2017-10-20 14:53:00 -04:00
  • 0580252f7a Polishing - PR Comments Gary Russell 2017-10-20 14:45:55 -04:00
  • b65f59cd67 GH-180: Add headerMapper() to DSL Gary Russell 2017-10-20 11:31:42 -04:00
  • 7aa04d3224 GH-175: XML Support for Error Handling Gary Russell 2017-09-11 12:43:06 -04:00
  • 857980349e GH-172: Add Success and Failure Message Channels Gary Russell 2017-08-14 17:14:27 -04:00
  • 37ffd4e2e9 GH-170: Add Support for Kafka Headers Gary Russell 2017-08-11 17:19:01 -04:00
  • 8d15b9582a Upgrade to SK 2.0 M3, Gradle 4.0.1 Artem Bilan 2017-07-24 17:19:15 -04:00
  • c219a43c58 SCSt-913: Add Support for Enhanced Error Handling Gary Russell 2017-04-17 17:28:17 -04:00
  • 8d18799ca8 Adapt Java DSL to the latest SI Artem Bilan 2017-05-24 17:25:12 -04:00
  • ee6b3f87b3 GH-164: Spring Kafka 2.0.0 Compatibility Gary Russell 2017-04-25 11:45:48 -04:00
  • 69e533f338 Compatibility with Latest 2.0.0.BUILD-SNAPSHOT Gary Russell 2017-04-10 15:54:03 -04:00
  • 9e047e7703 GH-158: Add record timestamp support Biju Kunjummen 2017-02-22 14:45:37 -08:00
  • 328e9cdb57 Update to Spring Kafka 2.0.0 Gary Russell 2017-02-01 10:04:42 -05:00
  • 87561e565f Move XSD to 3.0 version Artem Bilan 2016-11-16 11:57:13 -05:00
  • 598eb7f80e Upgrade to SI-5.0 & Port Kafka Java DSL Artem Bilan 2016-11-11 21:13:02 -05:00
  • 696376c728 Downgrade to AssertJ 2.5 for Boot compatibility Artem Bilan 2016-10-19 17:29:02 -04:00
  • 8cd471532d GH-145 send-timeout(-expression) and XSD for them Artem Bilan 2016-10-06 12:13:21 -04:00
  • 171dc9832a GH-147: Add Payload Type to Message Driven Adapter Gary Russell 2016-09-30 14:23:44 -04:00
  • 2c1b77c8fa Fix Schema Indentation Gary Russell 2016-09-16 10:02:08 -04:00
  • adfd6ee49e GH-143: Add sync to XML Namespace Gary Russell 2016-09-16 09:28:53 -04:00
  • cbfc6b0e73 GH-141: Support Batch Payloads Gary Russell 2016-09-07 16:49:35 -04:00
  • 0cf61af620 Update to s-k 1.1.0 Gary Russell 2016-09-06 17:08:33 -04:00
  • 8662c10232 Fix XSD type for partition-id Artem Bilan 2016-08-25 16:58:07 -04:00
  • 5bd2685a4d GH-135: Fix Schema Gary Russell 2016-08-25 09:57:08 -04:00
  • a4ab7e54b1 GH-130: Support KafkaNull Payloads Gary Russell 2016-08-11 17:31:32 -04:00