This is an automated email from the ASF dual-hosted git repository.
ningjiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/servicecomb-pack.git.
from 0acb126 change call PageRequest
new cb3aca2 SCB-1418 add alpha-fsm-channel-kafka dependency to pom.xml
new 10bbf74 SCB-1418 add alpha-fsm-channel-kafka module to alpha
new 562a0c5 SCB-1418 add alpha-fsm-channel-kafka dependency to alpha-fsm
new 33b2bf9 SCB-1418 change FsmAutoConfiguration.kafkaEventChannel
new 35380b8 SCB-1418 add KafkaActorEventChannel.kafkaMessagePublisher
field
new f00727e SCB-1418 add alpha-fsm-channel-kafka module
new fe0fc45 SCB-1418 add License
new 0ef23fb SCB-1418 add test actorEventSink to KafkaChannelTest
new 6438dd3 SCB-1418 add countDownLatch field to KafkaActorEventSink
new 5bde386 SCB-1418 delete scala dependency to alpha-fsm-channel-kafka
new e23065e SCB-1418 change alpha-fsm-channel-kafka readme
new a00a148 SCB-1418 add producer param doc to readme
new cf16757 SCB-1418 add producer param to KafkaChannelAutoConfiguration
new 189d8a1 SCB-1418 add consumer param to KafkaChannelAutoConfiguration
new 81e8b7f SCB-1418 add consumer param doc to readme
new 8a07466 SCB-1418 change KafkaMessagePublisher send mode , future mode
to sync mode
new f9ab6e4 SCB-1418 change spring.kafka.consumer.enable.auto.commit
default value to false
new 208e294 SCB-1418 add Acknowledgment to KafkaMessageListener
new fa584b4 SCB-1418 add ackMode poolTimeout to
KafkaChannelAutoConfiguration
new 54ca218 SCB-1418 add listener param doc to readme
new 7a0468b SCB-1418 change buffer.memory default value
The 21 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
alpha/alpha-fsm-channel-kafka/README.md | 25 ++++
.../pom.xml | 38 ++++--
.../kafka/KafkaChannelAutoConfiguration.java | 151 +++++++++++++++++++++
.../fsm/channel/kafka/KafkaMessageListener.java} | 46 +++----
.../fsm/channel/kafka/KafkaMessagePublisher.java | 52 +++++++
.../src/main/resources/META-INF/spring.factories | 2 +-
.../channel/kafka/test/KafkaActorEventSink.java} | 15 +-
.../fsm/channel/kafka/test/KafkaApplication.java | 33 +++--
.../fsm/channel/kafka/test/KafkaChannelTest.java | 95 +++++++++++++
.../src/test/resources/log4j2.xml | 2 +-
alpha/alpha-fsm/pom.xml | 5 +-
.../pack/alpha/fsm/FsmAutoConfiguration.java | 8 +-
.../alpha/fsm/channel/KafkaActorEventChannel.java | 8 +-
alpha/pom.xml | 1 +
pom.xml | 5 +
15 files changed, 418 insertions(+), 68 deletions(-)
create mode 100644 alpha/alpha-fsm-channel-kafka/README.md
copy alpha/{alpha-fsm-channel-redis => alpha-fsm-channel-kafka}/pom.xml (78%)
create mode 100644
alpha/alpha-fsm-channel-kafka/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaChannelAutoConfiguration.java
copy
alpha/{alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/RedisActorEventChannel.java
=>
alpha-fsm-channel-kafka/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaMessageListener.java}
(51%)
create mode 100644
alpha/alpha-fsm-channel-kafka/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaMessagePublisher.java
copy {omega/omega-spring-cloud-eureka-starter =>
alpha/alpha-fsm-channel-kafka}/src/main/resources/META-INF/spring.factories
(94%)
copy
alpha/{alpha-fsm-channel-redis/src/test/java/org/apache/servicecomb/pack/alpha/fsm/RedisEventSink.java
=>
alpha-fsm-channel-kafka/src/test/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/test/KafkaActorEventSink.java}
(75%)
copy
integration-tests/pack-tests/src/test/java/org/apache/servicecomb/pack/integration/tests/GreetingApplication.java
=>
alpha/alpha-fsm-channel-kafka/src/test/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/test/KafkaApplication.java
(62%)
create mode 100644
alpha/alpha-fsm-channel-kafka/src/test/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/test/KafkaChannelTest.java
copy alpha/{alpha-fsm-channel-redis =>
alpha-fsm-channel-kafka}/src/test/resources/log4j2.xml (97%)
