- 博客(10)
- 资源 (1)
- 问答 (1)
- 收藏
- 关注
原创 kafka333
MessageListenerimport kafka.message.MessageAndMetadata;public interface MessageListener { void onMessage(MessageAndMetadata<String, String> messageAndMetadata);}MessageCon...
2020-05-05 23:35:24 162
原创 KafkaListenerImpl
public class KafkaListenerImpl implements MessageListener { private static final SimpleLogger logger = SimpleLogger.getLogger(KafkaListenerImpl.class); private static final Logger log = Log...
2020-05-05 23:27:56 147
原创 kafka111
##kafka configkafka.consumer.bootstrap.servers=172.0.0.1:9092kafka.consumer.group.id=kafka.consumer.enable.auto.commit=truekafka.consumer.auto.commit.interval.ms=5000kafka.consumer.session.timeo...
2020-05-05 23:26:17 4711
原创 555
<!--监听器--><bean id="rabbitMqListener" class="cn.com.ds.plugin.impl.listener.MqListenerImpl"/><bean id="pbocInfoListener" class="cn.com.ds.plugin.impl.listener.PbocListenerImpl"/>...
2020-04-25 23:36:00 386
原创 444
import java.util.Map/** * <p> * all service plugins base interface * <ul> * <li>External Service</li> * <li>Internal Service</li> * </ul> */publi...
2020-04-25 22:56:30 345
原创 333
/** * FicoScoreD * @date 2019/9/18 10:41 */public class FicoScorePlugin extends AbstractFicoServicePlugin{ @Override public String identity() { return "ficoScore"; }}
2020-04-25 22:50:31 80
原创 222
import com.alibaba.fastjson.JSONObject;import org.apache.commons.collections.MapUtils;import org.dom4j.Document;import org.dom4j.DocumentException;import org.dom4j.DocumentHelper;import org.dom...
2020-04-25 22:50:03 210
原创 111
import java.io.IOException;import java.io.UnsupportedEncodingException;import java.net.URLDecoder;import java.net.URLEncoder;import java.util.Map;import org.slf4j.Logger;import org.slf4j.Logge...
2020-04-25 22:47:08 167
使用ImageIO.read()方法读取图片时的路径问题
2016-02-25
TA创建的收藏夹 TA关注的收藏夹
TA关注的人