search

spring-attic / spring-integration-kafka

Apache License 2.0
324 stars 180 forks source link

GH-259: Add pause/resume to KafkaMessageSource #262

Closed garyrussell closed 5 years ago

garyrussell commented 5 years ago

Resolves https://github.com/spring-projects/spring-integration-kafka/issues/259

Enable pause/resume on the polled consumer.

cherry-pick to 3.1.x

artembilan commented 5 years ago

Gary, any ideas why does test fail on Travis:

org.springframework.integration.kafka.outbound.KafkaProducerMessageHandlerTests > testOutboundWithTimestampExpression FAILED
    org.opentest4j.AssertionFailedError at KafkaProducerMessageHandlerTests.java:248

?

garyrussell commented 5 years ago

Looks like that fixed it.

artembilan commented 5 years ago

Doh! I merged it without squashing 😢

Something is wrong in my relationships with this project...

artembilan commented 5 years ago

... and cherry-picked to 3.1.x as https://github.com/spring-projects/spring-integration-kafka/commit/5a7c5dd7b077552e35f56d6d4d4f754508c95cdc after squashing and resolving conflicts.