Kafka手动提交offset

1 监听代码java import org.apache.kafka.clients.consumer.ConsumerRecord; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.kafka.listener.AcknowledgingMessageListener; imp
相关文章
相关标签/搜索