Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Commit Graph

  • cda52fe966 GH-125: Introduce sync mode for KafkaProducerMH Artem Bilan 2016-07-21 16:58:59 -04:00
  • 69cded293f GH-124: Add Retry and Filter Option to MDAdapter Artem Bilan 2016-07-21 14:16:02 -04:00
  • 490296c6b8 s-k 1.0.0.BUILD-SNAPSHOT Compatibility Gary Russell 2016-06-02 13:17:53 -04:00
  • 66e0772da0 GH-118: Update to Spring Kafka 1.0 BUILD-SNAPSHOT Gary Russell 2016-05-13 15:35:05 -04:00
  • caae6487e6 GH-115: Use SK MessageConverter from MDCAdapter Artem Bilan 2016-04-07 23:00:03 -04:00
  • f9adcbd3ec GH-112: Use s-k-test Utilities Gary Russell 2016-04-05 18:03:20 -04:00
  • a9456330ad Remove KafkaProducerMH.enableHeaderRouting Artem Bilan 2016-03-31 13:29:44 -04:00
  • 93e81f74c8 Add CheckStyle, travis; Fix Outbound, Add Tests Gary Russell 2016-03-30 14:35:41 -04:00
  • a030be3d7e Use spring-kafka in s-i-kafka Gary Russell 2016-02-25 16:24:23 -05:00
  • 49e533410c INTEXT-220: Add WindowingOffsetManager Artem Bilan 2016-02-11 20:01:57 -05:00
  • a98aba36c7 INTEXT-216: KafkaProducerContext.beanName as null Artem Bilan 2016-01-06 11:01:04 -05:00
  • d3e724d134 INTEXT-213: Outbound Adapter: Add RH Advice Chain Gary Russell 2016-01-05 13:02:24 -05:00
  • 5a25a9bd09 GH-96: Catch NPE from ClientUtils Artem Bilan 2015-12-23 17:14:47 -05:00
  • 079fa03563 Javadoc: Use the correct value "EarliestTime" Björn Häuser 2015-12-14 16:08:03 +01:00
  • 9208f74347 Fix deprecation warning Artem Bilan 2015-11-17 17:01:59 -05:00
  • d6a3b343aa GH-70 Allow the client to discover new brokers Marius Bogoevici 2015-11-03 14:20:10 -05:00
  • 4ff25fd894 Prevent Delay on Container Shutdown Marius Bogoevici 2015-11-02 22:03:43 -05:00
  • d6f895977a Add header routing setting to KafkaOutboundChannelAdapter Marius Bogoevici 2015-11-02 16:20:18 -05:00
  • ba96e7ce71 GH-84, GH-69 Improve Partitioner deprecation note Artem Bilan 2015-11-05 21:07:55 -05:00
  • 0f756cc1ec INTEXT-139: Deprecate High Level Consumer Adapter Artem Bilan 2015-10-29 18:47:21 -04:00
  • 28aca5332e INTEXT-206: Don't create extra consumers Artem Bilan 2015-10-26 21:13:14 -04:00
  • 464ca70aa6 Add Support for ProducerListener Marius Bogoevici 2015-10-24 16:09:09 -04:00
  • d8a1115f1f Kafka native offset implementation Chris Lemper 2015-08-27 13:33:21 -06:00
  • b6be2a33e7 Move XSD to the proper directory Artem Bilan 2015-10-22 20:04:55 -04:00
  • b67fa489cb Adding a deprecated setter for KafkaProducerMessageHandler.setPartitionExpression() for backwards compatibility Marius Bogoevici 2015-10-22 17:50:01 -04:00
  • 32715799d9 Issue#67: fixing custom paritioner issue Abhijith Prabhakar 2015-10-08 14:46:07 -04:00
  • fd93f91a78 Ignore broker bounce tests Marius Bogoevici 2015-10-22 16:51:09 -04:00
  • 3a5c2ffd77 Add test for producer key and payload cast Marius Bogoevici 2015-10-22 16:40:29 -04:00
  • 21600a275d convertPayloadIfNecessary change to use Value Class Type Gamal 2015-09-24 15:51:28 -05:00
  • 9b49e9a673 Deprecated Connection#getLeaders() - simplify DefaultConnectionFactory tests Marius Bogoevici 2015-10-22 15:28:12 -04:00
  • 9ddc4e6d12 Check if leader election is complete during tests Marius Bogoevici 2015-10-22 15:03:43 -04:00
  • 108197cffd Temporarily ignore bounce tests due to strain on CI environment Marius Bogoevici 2015-10-22 14:47:42 -04:00
  • bdb46760ad Support for sending messages synchronously to the Kafka broker. Martin Dam 2015-10-16 10:40:11 -07:00
  • 0065950830 GH-60: Get rid of HashCodeBuilder usage Artem Bilan 2015-09-02 11:50:47 -04:00
  • c1e1166895 Fix OutboundTests for required BeanFactory Artem Bilan 2015-07-31 19:09:58 -04:00
  • 31439da037 Add High Level Consumer Integration Test Gary Russell 2015-07-28 14:25:33 -04:00
  • c7f009f544 INTEXT-180: Fix ListenerContainer fetch pool size Marius Bogoevici 2015-07-17 12:11:52 -04:00
  • 19a27d7759 Fixed schema documentation for zookeeper-connect element Justin Walsh 2015-06-26 07:31:09 +02:00
  • 7695964e64 INTEXT-175: Fix IEC population Artem Bilan 2015-06-23 19:45:17 -04:00
  • b77f621c51 INTEXT-175 Replace onInit() check for IntegrationEvaluationContext Marius Bogoevici 2015-06-18 15:18:20 -04:00
  • 0956c0ad5a INTEXT-172 Make potentially long-running tasks SchedulingAwareRunnable Marius Bogoevici 2015-06-08 10:10:58 -04:00
  • 3cb57e96eb INTEXT-170 Use a custom MessageHeaders class Marius Bogoevici 2015-06-02 13:24:01 -04:00
  • 35be1cb4fb QueueingMessageListenerInvoker fixes Marius Bogoevici 2015-06-01 07:42:35 -04:00
  • d0c0adc5bb Check that the queueSize is a positive integer Marius Bogoevici 2015-05-31 08:48:27 -04:00
  • 1b28a7b863 INTEXT-169: Ensure queueSize is a Power of 2 Gary Russell 2015-05-29 11:26:00 -04:00
  • d475a79d83 Do not refresh metadata eagerly: Marius Bogoevici 2015-05-22 17:34:45 -04:00
  • 38856ee984 Add Reactor based ringbuffer Marius Bogoevici 2015-05-21 20:10:04 -04:00
  • d8df11c2aa INTEXT-168 Upgrade to Kafka 0.8.2.1 Marius Bogoevici 2015-05-01 16:59:24 -04:00
  • fbe2975ed4 INTEXT-165 Recovery when cluster inaccessible Marius Bogoevici 2015-04-24 18:47:40 +03:00
  • df652634a5 Fix expected type for listener-container attr Kevin Mooney 2015-04-15 10:44:10 -05:00
  • 790d899953 INTEXT-159 DefaultConnectionFactory thread safety Marius Bogoevici 2015-03-27 16:12:07 -04:00
  • 1e6e7b9bbf INTEXT 156-157 Marius Bogoevici 2015-03-25 21:26:43 +02:00
  • 3e6a796e85 Improve performance of header generation Marius Bogoevici 2015-03-23 14:11:44 +02:00
  • 52d218988b INTEXT-154: Namespace Support for New Features Gary Russell 2015-03-20 15:56:31 -04:00
  • 3ade92ba14 INTEXT-152 Improve message generation strategy Marius Bogoevici 2015-03-09 20:37:57 -04:00
  • 0e0e8cebe3 INTEXT-153 Stop the KafkaMessageListenerContainer Marius Bogoevici 2015-03-18 11:41:06 -04:00
  • 5360aa3130 INTEXT-146 Fix NPE in KafkaMessageHandlerAdapter Marius Bogoevici 2015-03-09 16:07:10 -04:00
  • da0f730298 INTEXT-145 Do not set the queue to fair Marius Bogoevici 2015-03-09 03:25:03 -04:00
  • aef99fcd9d INTEXT-143 Add Support for Manual Acknowledgment Marius Bogoevici 2015-03-02 17:42:21 -05:00
  • 1d77012dae Increase timeout leniency for Kafka Offset Topic Marius Bogoevici 2015-02-05 17:07:54 -05:00
  • ba647025b2 Log metadata fetch failures at INFO level. Marius Bogoevici 2015-02-05 15:20:05 -05:00
  • ae2a1a08cd INTEXT-131-134: Add KafkaTopicOffsetManager Marius Bogoevici 2015-02-03 21:29:30 +02:00
  • d85677f61e INTEXT-129: Namespace support for KafkaMDCA Artem Bilan 2015-01-23 16:31:59 +02:00
  • 2cae7420a3 Fixes a race condition in tests Marius Bogoevici 2015-01-16 13:59:39 -05:00
  • 6a6d119c4e INTEXT-123-124-125: Ignore Snappy test Artem Bilan 2015-01-16 20:16:12 +02:00
  • 5989e618ed INTEXT-123-124-125: Increase maxWait for tests Artem Bilan 2015-01-16 19:51:25 +02:00
  • 6acf985cc1 INTEXT-123-124-125 Introducing SimpleConsumer API Marius Bogoevici 2015-01-16 19:04:58 +02:00
  • 46d06fd404 KAFKA-10: Fix for ConsumerConfiguration.executor Artem Bilan 2015-01-08 12:05:26 +02:00
  • c3d696187c Remove SI-core XSD Version from Kafka XSD Artem Bilan 2014-12-05 19:23:54 +02:00
  • 614308b482 IE-100: Kafka:o-c-a: topic and message-key attrs Artem Bilan 2014-11-17 13:22:39 +02:00
  • 0e2808c014 INTEXT-121 Add SmartLifecycle to ProducerContext Gary Russell 2014-12-02 21:50:37 +02:00
  • 503ce78395 INT-3570 Core 4.0 Schema Work Around Gary Russell 2014-11-26 15:54:10 -05:00
  • e64d2ac0c8 Add StringDecoder for kafka messages Ilayaperumal Gopinathan 2014-11-12 12:15:51 -08:00
  • 896d2c43f4 INTEXT-111: Allow PP for Kafka producer context Ilayaperumal Gopinathan 2014-11-12 11:20:04 +02:00
  • 94585fe03b Kafka: PP for consumer context bean Ilayaperumal Gopinathan 2014-08-20 21:10:00 +03:00
  • 1829bd879f Make ConsumerContext disposable Ilayaperumal Gopinathan 2014-08-18 06:33:20 -07:00
  • bacf8d2ceb Kafka-GH-92: Allow PP for the <topic-filter> Artem Bilan 2014-08-12 22:57:50 +03:00
  • 999878f048 INTEXT-104: Kafka: order for o-channel-adapter Soby Chacko 2014-07-22 23:44:36 -04:00
  • e22a90ea1f INTEXT-110: Update Kafka version to 0.8.1.1 Soby Chacko 2014-07-22 00:42:22 -04:00
  • 58ff34d83b Kafka: KCCtx: return null if consumedData.isEmpty Artem Bilan 2014-07-01 15:01:22 +03:00
  • fb40e521c7 INTEXT-106: Update to spring-integration 4.0 Jonathan Pearlin 2014-06-12 18:07:19 -04:00
  • c52be66a1c INTEXT-92 Kafka: Add support for specifying any producer/consumer property Rajasekar Elango 2013-10-29 11:41:24 -07:00
  • d226b7c3c5 INTEXT-77 Add Kafka topic filter support for producer + consumer Rajasekar Elango 2013-07-19 11:32:31 -07:00
  • 94734e4ca3 INTEXT-84 Kafka: Enhance Avro serialization support Soby Chacko 2013-07-16 22:40:28 -04:00
  • af9440315c INTEXT-81 Add unit tests Gunnar Hillert 2013-07-15 12:40:28 -04:00
  • 6993b73041 INTEXT-81 Fixing bug in decoding message streams * adding a null check on the key decoder Kevin Eustice 2013-07-12 11:14:25 -07:00
  • bea8c7cc86 Moved Kafka Test Context Files Gunnar Hillert 2013-06-03 15:13:08 -04:00
  • 0b20c8dfdb INTEXT-44 - Polishing Gunnar Hillert 2013-06-03 00:02:47 -04:00
  • 9e626cb18b INTEXT-44 - Add Kafka Support Soby Chacko 2013-03-18 23:31:53 -04:00
  • 5d7f0d2d1c Fix RedisQueueMessageDrEndpointTests for Java 14 Artem Bilan 2020-06-24 12:43:12 -04:00
  • 6a3bea5a64 Add keepAlive(true) to testing Redis CF Artem Bilan 2020-06-24 11:58:09 -04:00
  • 94956859a2 Fix RedisAvailableRule for the proper evaluate Artem Bilan 2020-06-23 16:27:45 -04:00
  • 9367d7f4de Fix MessagingGateway for reactive reply type Artem Bilan 2020-06-23 14:26:11 -04:00
  • 3bb445e133 Fix deprecations from Reactor Artem Bilan 2020-06-22 13:32:06 -04:00
  • 498f42d480 Fix deprecations from SF Artem Bilan 2020-06-19 12:07:58 -04:00
  • 3a9ae217b8 Fix UDP tests to rely on a random port Artem Bilan 2020-06-18 14:49:52 -04:00
  • 9ad348b75f Log attempting to receive email under debug level instead of info (#3312) Filip Hrisafov 2020-06-18 18:06:00 +02:00
  • b4a82eb078 Resolve deprecations for MulticastSocket Artem Bilan 2020-06-17 15:24:36 -04:00
  • 3f5aba2cb9 Support Java 14 (#3310) Artem Bilan 2020-06-17 14:00:06 -04:00
  • a24f24fc6d More retry for TransactionTimedOutException Artem Bilan 2020-06-16 12:31:36 -04:00