写文章
- @SDAUguo
简介
该用户还未填写简介
擅长的技术栈
未填写擅长的技术栈
可提供的服务
暂无可提供的服务
ERROR 220624 --- [ntainer#2-2-C-1] o.s.k.l.KafkaMessageListenerContainer : Failed to set initial
完整报错：org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired before the position for partition heartbeatMessage1-2 could be determined2021-12-03 16:17:44.253 ERROR 220624 --- [ntai
redisTemplate批量新增hash
需求：工作中使用kafka接收数据，需要批量对redis中的hash操作，而redisTemplate并没有提供相应的方法，里面对于批量插入操作，只有一个public void putAll(K key, Map<? extends HK, ? extends HV> m) {if (!m.isEmpty()) {byte[] rawKey = this.rawKey(key);Map
SpringbootKaka批量消费报Listener method could not be invoked with the incoming message
结论：在配置文件中加上spring.kafka.listener.type=batch 。完整报错信息如下：org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method could not be invoked with the incoming messageEndpoint handle
到底了