Kafka Connect: я не могу найти таблицу в своей базе данных, но она говорит, что она создается - PullRequest
Новая
       72

Kafka Connect: я не могу найти таблицу в своей базе данных, но она говорит, что она создается

0 голосов
/ 19 декабря 2018

Я пытаюсь погрузить некоторые данные из темы Кафки в базу данных SQLite.Он проверяет таблицу и каждый раз странно создает таблицу, однако, когда я лично выполняю поиск в базе данных, такой таблицы не существует. 

[2018-12-19 15:33:39,438] INFO Checking Sqlite dialect for existence of table "neworders1" (io.confluent.connect.jdbc.dialect.SqliteDatabaseDialect:492)
[2018-12-19 15:33:39,439] INFO Using Sqlite dialect table "neworders1" present (io.confluent.connect.jdbc.dialect.SqliteDatabaseDialect:500)
[2018-12-19 15:33:39,453] INFO Setting metadata for table "neworders1" to Table{name='"neworders1"', columns=[Column{'eventTime', isPrimaryKey=false, allowsNull=false, sqlType=INTEGER}, Column{'receivedPacketUID', isPrimaryKey=false, allowsNull=false, sqlType=INTEGER}, Column{'eventLongitude', isPrimaryKey=false, allowsNull=false, sqlType=REAL}, Column{'eventLocationStampUID', isPrimaryKey=false, allowsNull=false, sqlType=INTEGER}, Column{'eventCourse', isPrimaryKey=false, allowsNull=false, sqlType=INTEGER}, Column{'remoteEventUID', isPrimaryKey=false, allowsNull=false, sqlType=INTEGER}, Column{'remoteUnitAID', isPrimaryKey=false, allowsNull=false, sqlType=INTEGER}, Column{'eventSpeed', isPrimaryKey=false, allowsNull=false, sqlType=INTEGER}, Column{'eventOdometer', isPrimaryKey=false, allowsNull=false, sqlType=INTEGER}, Column{'eventLatitude', isPrimaryKey=false, allowsNull=false, sqlType=REAL}]} (io.confluent.connect.jdbc.util.TableDefinitions:65)

Он даже говорит, что они фиксируются, и никакой ошибки не возникает: 

[2018-12-19 15:33:39,455] INFO Closing BufferedRecords with preparedStatement: null (io.confluent.connect.jdbc.sink.BufferedRecords:181)
[2018-12-19 15:33:39,463] INFO Closing BufferedRecords with preparedStatement: org.sqlite.jdbc4.JDBC4PreparedStatement@3d2cd826 (io.confluent.connect.jdbc.sink.BufferedRecords:181)
[2018-12-19 15:34:01,879] INFO WorkerSinkTask{id=test-sink-0} Committing offsets asynchronously using sequence number 1: {neworders1-0=OffsetAndMetadata{offset=1000, metadata=''}} (org.apache.kafka.connect.runtime.WorkerSinkTask:345)
  • но я понятия не имею, почему он не создается, где он хранит данные.Есть предложения?
...