offectApp03无法进入写入数据库的操作

来源：7-10 自定义维护Offset读取实现

BillyWebber

2021-01-03

我在执行offect03的代码逻辑执行Kafka的消费的时候，断点无法进入offect写入数据库的逻辑是什么原因造成的呢？

以下是Kafka控制台的日志：

以下是断点的位置：

我的数据库对应的表是空的，按理来讲消费结束或者消费者程序结束掉后应该要把偏移量写入数据库的，但是代码直接跳过写入数据库的流程，数据库连接是没问题的：

补充：

生产者的Kafka日志如下：

以下是生产者测试类运行瞬间产生的日志：

写回答

1回答

Michael_PK

2021-01-03

跳过了检查你这批次里面有数据吗

Michael_PK

BillyWebber

你再你所关注的核心代码都加上log，看看日志到底走进去没呢。只要数据有产生，有被代码进行消费，肯定是能执行到的。你手工加些日志进去，也不用debug了，直接运行，然后关注日志就可以

2021-01-04

共2条回复

Spark3实时处理-Streaming+StructuredStreaming实战

实战Spark3实时处理，掌握两套企业级处理方案

340 学习 · 238 问题

相似问题

回答 1

回答 1

回答 1

回答 1

回答 1