小编Sto*_*tov的帖子

当与 Apache Kafka 服务器的连接丢失时,如何使用 Spring Kafka Listener 停止微服务?

我目前正在实现一个微服务,它从 Apache Kafka 主题读取数据。我正在为微服务使用“spring-boot, version: 1.5.6.RELEASE”,为同一个微服务中的侦听器使用“spring-kafka, version: 1.2.2.RELEASE”。这是我的卡夫卡配置:

    @Bean
public Map<String, Object> consumerConfigs() {
    return new HashMap<String, Object>() {{
        put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, servers);
        put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        put(ConsumerConfig.GROUP_ID_CONFIG, groupIdConfig);
        put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, autoOffsetResetConfig);
    }};
}

@Bean
public ConsumerFactory<String, String> consumerFactory() {
    return new DefaultKafkaConsumerFactory<>(consumerConfigs());
}

@Bean
public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory() {
    ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(consumerFactory());
    return factory;
}
Run Code Online (Sandbox Code Playgroud)

我已经通过@KafkaListener注释实现了监听器:

@KafkaListener(topics = "${kafka.dataSampleTopic}")
public void receive(ConsumerRecord<String, String> payload) {
    //business logic
    latch.countDown();
}
Run Code Online (Sandbox Code Playgroud)

当侦听器与 Apache Kafka 服务器断开连接时,我需要能够关闭微服务。

当我杀死 kafka 服务器时,我在 …

spring apache-kafka spring-boot spring-kafka

3
推荐指数
1
解决办法
6249
查看次数

Formhandler主题动态字段

我对TYPO3扩展"Formhandler"有疑问.我安装了扩展程序,添加了验证码,一切正常.

这是HTML模板:

<!-- ###TEMPLATE_FORM1### begin -->
<form action="###REL_URL###" name="projektform" id="projektform" method="post" class="formhandler">
  <br />  
  <div id="sender_name">
    <label for="sender_name"><span style="color:red;">*</span>Name:</label>
    <br />
    <input type="text" name="formhandler[sender_name]" id="sender_name"
    value="###value_sender_name###" />
    ###error_sender_name###
  </div>
 <br />
 <div id="sender_email">
    <label for="sender_email"><span style="color:red;">*</span>Email:</label>
    <br />
    <input type="text" name="formhandler[sender_email]" id="sender_email"
    value="###value_sender_email###" />
    ###error_sender_email###
  </div>
  <br />
  <div id="sender_message">
    <label for="message"><span style="color:red;">*</span>Message:</label>
    <br />
    <textarea name="formhandler[message]" id="message">###value_message###</textarea>
    ###error_message###
  </div>
  <br />
  <!--###CAPTCHA_INSERT### this subpart is removed if CAPTCHA is not enabled! -->
  <div id="captcha">
    <label for="freecapfield"><span style="color:red;">*</span>###SR_FREECAP_NOTICE###</label>
    <br /> …
Run Code Online (Sandbox Code Playgroud)

typo3

2
推荐指数
1
解决办法
3071
查看次数

标签 统计

apache-kafka ×1

spring ×1

spring-boot ×1

spring-kafka ×1

typo3 ×1