Spring Integration Kafka 1.2 发布 - 开源中国社区
Spring Integration Kafka 1.2 发布
oschina 2015年06月20日

Spring Integration Kafka 1.2 发布

oschina oschina 发布于2015年06月20日 收藏 18 评论 3

有免费的MySQL,为什么还要买? >>>  

Spring Integration Kafka 1.2 发布,此版本提供大量的改进:

  • 支持 Apache Kafka 0.8.2,使用最新的 Producer API;

  • 使用基于 Reactor 的一个非阻塞循环缓冲区实现来改进内部并发调度

每次改进,目标都是提升 producer 的性能。

未来将会加入的新特性:

  • Improving the documentation by creating a dedicated wiki;

  • Making it easy to send messages outside of a Spring Integration Kafka outbound channel adapter by providing template support;

  • Exploring the options for Reactive Streams integration.

更多内容请看发行说明

Spring Integration能在基于Spring的应用中进行简单的消息通信,并通过简单的适配器与外部系统集成。这些适配器提供了一个更高级别的抽象,超越 了Spring对远程调用、消息和调度的支持。其主要目标是在保持关注点分离的同时,为构建企业集成解决方案提供一个简单的模型,该模型对产出可维护、可 测试的代码来说是必不可少的。

文档地址

本站文章除注明转载外,均为本站原创或编译。欢迎任何形式的转载,但请务必注明出处,尊重他人劳动共创开源社区。
转载请注明:文章转载自 开源中国社区 [http://www.oschina.net]
本文标题:Spring Integration Kafka 1.2 发布
分享
评论(3)
最新评论
0

引用来自“Alex.Wong”的评论

2015-09-17 10:12:53
[DEBUG]-[Thread: main]-[org.springframework.integration.channel.AbstractMessageChannel.send()]: preSend on channel 'common-message.producer', message: GenericMessage [payload=11111111111, headers={timestamp=1442455973278, id=7ad6e987-af77-a16c-e655-71801bfe83cd, topic=test-2, messageKey=key}]

2015-09-17 10:12:53
[DEBUG]-[Thread: main]-[org.springframework.integration.channel.AbstractMessageChannel.send()]: postSend (sent=true) on channel 'common-message.producer', message: GenericMessage [payload=11111111111, headers={timestamp=1442455973278, id=7ad6e987-af77-a16c-e655-71801bfe83cd, topic=test-2, messageKey=key}]


提示发送成功,队列就是收不到数据,求解。

引用来自“woxi内特”的评论

@Alex.Wong ,这位朋友,我在使用spring-integration-kafka集成kafka时,遇到跟你类似的问题,我的生产者程序生产消息成功,用kafka给出的消费者程序可以消费出来,可是用spring-integration-kafka的KafkaMessageDrivenChannelAdapter总消费不出来,不知何解!朋友你如果已经解决问题,希望你能帮助我。
上回看了源码,将auto-startup设置为"true"便可以了。
你试试看,不知对你是否有帮助~
0

引用来自“Alex.Wong”的评论

2015-09-17 10:12:53
[DEBUG]-[Thread: main]-[org.springframework.integration.channel.AbstractMessageChannel.send()]: preSend on channel 'common-message.producer', message: GenericMessage [payload=11111111111, headers={timestamp=1442455973278, id=7ad6e987-af77-a16c-e655-71801bfe83cd, topic=test-2, messageKey=key}]

2015-09-17 10:12:53
[DEBUG]-[Thread: main]-[org.springframework.integration.channel.AbstractMessageChannel.send()]: postSend (sent=true) on channel 'common-message.producer', message: GenericMessage [payload=11111111111, headers={timestamp=1442455973278, id=7ad6e987-af77-a16c-e655-71801bfe83cd, topic=test-2, messageKey=key}]


提示发送成功,队列就是收不到数据,求解。
@Alex.Wong ,这位朋友,我在使用spring-integration-kafka集成kafka时,遇到跟你类似的问题,我的生产者程序生产消息成功,用kafka给出的消费者程序可以消费出来,可是用spring-integration-kafka的KafkaMessageDrivenChannelAdapter总消费不出来,不知何解!朋友你如果已经解决问题,希望你能帮助我。
0
2015-09-17 10:12:53
[DEBUG]-[Thread: main]-[org.springframework.integration.channel.AbstractMessageChannel.send()]: preSend on channel 'common-message.producer', message: GenericMessage [payload=11111111111, headers={timestamp=1442455973278, id=7ad6e987-af77-a16c-e655-71801bfe83cd, topic=test-2, messageKey=key}]

2015-09-17 10:12:53
[DEBUG]-[Thread: main]-[org.springframework.integration.channel.AbstractMessageChannel.send()]: postSend (sent=true) on channel 'common-message.producer', message: GenericMessage [payload=11111111111, headers={timestamp=1442455973278, id=7ad6e987-af77-a16c-e655-71801bfe83cd, topic=test-2, messageKey=key}]


提示发送成功,队列就是收不到数据,求解。
顶部