diff --git a/app/src/main/java/org/thoughtcrime/securesms/database/RecipientTable.kt b/app/src/main/java/org/thoughtcrime/securesms/database/RecipientTable.kt
index 1f8cafa905..c74ba9febc 100644
--- a/app/src/main/java/org/thoughtcrime/securesms/database/RecipientTable.kt
+++ b/app/src/main/java/org/thoughtcrime/securesms/database/RecipientTable.kt
@@ -607,6 +607,8 @@ open class RecipientTable(context: Context, databaseHelper: SignalDatabase) : Da
           Log.w(TAG, "Failed to update newly-created record for $recipientId")
         }
 
+        Log.i(TAG, "Group $groupId was newly-inserted as $recipientId")
+
         return recipientId
       }
     }
diff --git a/app/src/main/java/org/thoughtcrime/securesms/messages/IncomingMessageObserver.kt b/app/src/main/java/org/thoughtcrime/securesms/messages/IncomingMessageObserver.kt
index 93a407d37f..95dfaad7fd 100644
--- a/app/src/main/java/org/thoughtcrime/securesms/messages/IncomingMessageObserver.kt
+++ b/app/src/main/java/org/thoughtcrime/securesms/messages/IncomingMessageObserver.kt
@@ -393,6 +393,7 @@ class IncomingMessageObserver(private val context: Application) {
                 GroupsV2ProcessingLock.acquireGroupProcessingLock().use {
                   ReentrantSessionLock.INSTANCE.acquire().use {
                     batch.forEach {
+                      Log.d(TAG, "Beginning database transaction...")
                       SignalDatabase.runInTransaction {
                         val followUpOperations: List<FollowUpOperation>? = processEnvelope(bufferedStore, it.envelope, it.serverDeliveredTimestamp)
                         bufferedStore.flushToDisk()
@@ -401,6 +402,7 @@ class IncomingMessageObserver(private val context: Application) {
                           ApplicationDependencies.getJobManager().addAll(jobs)
                         }
                       }
+                      Log.d(TAG, "Ended database transaction.")
                       signalWebSocket.sendAck(it)
                     }
                   }