diff --git a/dlt-database/entity/0001-init_db/InvalidTransaction.ts b/dlt-database/entity/0001-init_db/InvalidTransaction.ts
index cfea858a1..f88093c7f 100644
--- a/dlt-database/entity/0001-init_db/InvalidTransaction.ts
+++ b/dlt-database/entity/0001-init_db/InvalidTransaction.ts
@@ -5,6 +5,6 @@ export class InvalidTransaction {
   @PrimaryGeneratedColumn('increment', { unsigned: true, type: 'bigint' })
   id: number
 
-  @Column({ name: 'iota_message_id', type: 'binary', length: 32, nullable: true })
-  iotaMessageId?: Buffer
+  @Column({ name: 'iota_message_id', type: 'binary', length: 32 })
+  iotaMessageId: Buffer
 }
diff --git a/dlt-database/migrations/0001-init_db.ts b/dlt-database/migrations/0001-init_db.ts
index 245e3b95c..011c96783 100644
--- a/dlt-database/migrations/0001-init_db.ts
+++ b/dlt-database/migrations/0001-init_db.ts
@@ -112,7 +112,7 @@ export async function upgrade(queryFn: (query: string, values?: any[]) => Promis
   await queryFn(`
     CREATE TABLE IF NOT EXISTS \`invalid_transactions\` (
       \`id\` bigint unsigned NOT NULL AUTO_INCREMENT,
-      \`iota_message_id\` binary(32) DEFAULT NULL,
+      \`iota_message_id\` binary(32) NOT NULL,
       PRIMARY KEY (\`id\`),
       INDEX (\`iota_message_id\`)
     ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;`)