diff --git a/library/src/androidTest/java/org/xmtp/android/library/GroupMembershipChangeTest.kt b/library/src/androidTest/java/org/xmtp/android/library/GroupMembershipChangeTest.kt
index 2d7048d2a..c0f7f0ed9 100644
--- a/library/src/androidTest/java/org/xmtp/android/library/GroupMembershipChangeTest.kt
+++ b/library/src/androidTest/java/org/xmtp/android/library/GroupMembershipChangeTest.kt
@@ -11,6 +11,7 @@ import org.junit.runner.RunWith
 import org.xmtp.android.library.messages.PrivateKey
 import org.xmtp.android.library.messages.PrivateKeyBuilder
 import org.xmtp.android.library.messages.walletAddress
+import uniffi.xmtpv3.org.xmtp.android.library.codecs.ContentTypeGroupMembershipChange
 import uniffi.xmtpv3.org.xmtp.android.library.codecs.GroupMembershipChangeCodec
 import uniffi.xmtpv3.org.xmtp.android.library.codecs.GroupMembershipChanges
 
@@ -99,6 +100,34 @@ class GroupMembershipChangeTest {
         assert(content?.membersAddedList.isNullOrEmpty())
     }
 
+    @Test
+    fun testRemovesInvalidMessageKind() {
+        Client.register(codec = GroupMembershipChangeCodec())
+
+        val membershipChange = GroupMembershipChanges.newBuilder().build()
+
+        val group = runBlocking {
+            alixClient.conversations.newGroup(
+                listOf(
+                    bo.walletAddress,
+                    caro.walletAddress
+                )
+            )
+        }
+        val messages = group.messages()
+        assertEquals(messages.size, 1)
+        assertEquals(group.memberAddresses().size, 3)
+        runBlocking {
+            group.send(
+                content = membershipChange,
+                options = SendOptions(contentType = ContentTypeGroupMembershipChange),
+            )
+            group.sync()
+        }
+        val updatedMessages = group.messages()
+        assertEquals(updatedMessages.size, 1)
+    }
+
     @Test
     fun testIfNotRegisteredReturnsFallback() {
         val group = runBlocking {
diff --git a/library/src/androidTest/java/org/xmtp/android/library/GroupTest.kt b/library/src/androidTest/java/org/xmtp/android/library/GroupTest.kt
index 8478dadf3..e32507256 100644
--- a/library/src/androidTest/java/org/xmtp/android/library/GroupTest.kt
+++ b/library/src/androidTest/java/org/xmtp/android/library/GroupTest.kt
@@ -21,6 +21,9 @@ import org.xmtp.android.library.messages.PrivateKey
 import org.xmtp.android.library.messages.PrivateKeyBuilder
 import org.xmtp.android.library.messages.walletAddress
 import uniffi.xmtpv3.GroupPermissions
+import uniffi.xmtpv3.org.xmtp.android.library.codecs.ContentTypeGroupMembershipChange
+import uniffi.xmtpv3.org.xmtp.android.library.codecs.GroupMembershipChangeCodec
+import uniffi.xmtpv3.org.xmtp.android.library.codecs.GroupMembershipChanges
 
 @RunWith(AndroidJUnit4::class)
 class GroupTest {
@@ -360,12 +363,19 @@ class GroupTest {
 
     @Test
     fun testCanStreamGroupMessages() = kotlinx.coroutines.test.runTest {
+        Client.register(codec = GroupMembershipChangeCodec())
+        val membershipChange = GroupMembershipChanges.newBuilder().build()
+
         val group = boClient.conversations.newGroup(listOf(alix.walletAddress.lowercase()))
         alixClient.conversations.syncGroups()
         val alixGroup = alixClient.conversations.listGroups().first()
         group.streamMessages().test {
             alixGroup.send("hi")
             assertEquals("hi", awaitItem().body)
+            alixGroup.send(
+                content = membershipChange,
+                options = SendOptions(contentType = ContentTypeGroupMembershipChange),
+            )
             alixGroup.send("hi again")
             assertEquals("hi again", awaitItem().body)
         }
@@ -432,6 +442,8 @@ class GroupTest {
 
     @Test
     fun testCanStreamAllDecryptedGroupMessages() = kotlinx.coroutines.test.runTest {
+        Client.register(codec = GroupMembershipChangeCodec())
+        val membershipChange = GroupMembershipChanges.newBuilder().build()
         val group = caroClient.conversations.newGroup(listOf(alix.walletAddress))
         alixClient.conversations.syncGroups()
 
@@ -448,6 +460,10 @@ class GroupTest {
         }
 
         group.send("hi 1")
+        group.send(
+            content = membershipChange,
+            options = SendOptions(contentType = ContentTypeGroupMembershipChange),
+        )
         group.send("hi 2")
 
         job.join()
diff --git a/library/src/androidTest/java/org/xmtp/android/library/TestHelpers.kt b/library/src/androidTest/java/org/xmtp/android/library/TestHelpers.kt
index 3d250ac84..cdc307665 100644
--- a/library/src/androidTest/java/org/xmtp/android/library/TestHelpers.kt
+++ b/library/src/androidTest/java/org/xmtp/android/library/TestHelpers.kt
@@ -175,6 +175,7 @@ class FakeApiClient : ApiClient {
                 MessageApiOuterClass.SortDirection.SORT_DIRECTION_ASCENDING -> {
                     result = result.reversed().toMutableList()
                 }
+
                 else -> Unit
             }
         }
@@ -191,6 +192,7 @@ class FakeApiClient : ApiClient {
         published.addAll(envelopes)
         return PublishResponse.newBuilder().build()
     }
+
     override suspend fun subscribe(request: Flow<MessageApiOuterClass.SubscribeRequest>): Flow<MessageApiOuterClass.Envelope> {
         val env = stream.counts().first()
 
@@ -205,7 +207,9 @@ data class Fixtures(
     val aliceAccount: PrivateKeyBuilder,
     val bobAccount: PrivateKeyBuilder,
     val caroAccount: PrivateKeyBuilder,
-    val clientOptions: ClientOptions? = null
+    val clientOptions: ClientOptions? = ClientOptions(
+        ClientOptions.Api(XMTPEnvironment.LOCAL, isSecure = false)
+    ),
 ) {
     var fakeApiClient: FakeApiClient = FakeApiClient()
     var alice: PrivateKey = aliceAccount.getPrivateKey()
@@ -214,6 +218,7 @@ data class Fixtures(
     var bobClient: Client = Client().create(account = bobAccount, options = clientOptions)
     var caro: PrivateKey = caroAccount.getPrivateKey()
     var caroClient: Client = Client().create(account = caroAccount, options = clientOptions)
+
     constructor(clientOptions: ClientOptions?) : this(
         aliceAccount = PrivateKeyBuilder(),
         bobAccount = PrivateKeyBuilder(),
diff --git a/library/src/main/java/libxmtp-version.txt b/library/src/main/java/libxmtp-version.txt
new file mode 100644
index 000000000..c066b7057
--- /dev/null
+++ b/library/src/main/java/libxmtp-version.txt
@@ -0,0 +1,3 @@
+Version: 4068715
+Branch: main
+Date: 2024-04-06 04:27:39 +0000
diff --git a/library/src/main/java/org/xmtp/android/library/Conversation.kt b/library/src/main/java/org/xmtp/android/library/Conversation.kt
index 62e738102..7230c0b46 100644
--- a/library/src/main/java/org/xmtp/android/library/Conversation.kt
+++ b/library/src/main/java/org/xmtp/android/library/Conversation.kt
@@ -4,7 +4,7 @@ import android.util.Log
 import com.google.protobuf.kotlin.toByteString
 import kotlinx.coroutines.flow.Flow
 import org.xmtp.android.library.codecs.EncodedContent
-import org.xmtp.android.library.libxmtp.Message
+import org.xmtp.android.library.libxmtp.MessageV3
 import org.xmtp.android.library.messages.DecryptedMessage
 import org.xmtp.android.library.messages.Envelope
 import org.xmtp.android.library.messages.PagingInfoSortDirection
@@ -121,7 +121,7 @@ sealed class Conversation {
         }
     }
 
-    fun decode(envelope: Envelope, message: Message? = null): DecodedMessage {
+    fun decode(envelope: Envelope, message: MessageV3? = null): DecodedMessage {
         return when (this) {
             is V1 -> conversationV1.decode(envelope)
             is V2 -> conversationV2.decodeEnvelope(envelope)
@@ -277,7 +277,7 @@ sealed class Conversation {
 
     fun decrypt(
         envelope: Envelope,
-        message: Message? = null,
+        message: MessageV3? = null,
     ): DecryptedMessage {
         return when (this) {
             is V1 -> conversationV1.decrypt(envelope)
diff --git a/library/src/main/java/org/xmtp/android/library/Conversations.kt b/library/src/main/java/org/xmtp/android/library/Conversations.kt
index 10f73adeb..b54a55779 100644
--- a/library/src/main/java/org/xmtp/android/library/Conversations.kt
+++ b/library/src/main/java/org/xmtp/android/library/Conversations.kt
@@ -12,7 +12,7 @@ import kotlinx.coroutines.flow.flow
 import kotlinx.coroutines.flow.merge
 import org.xmtp.android.library.GRPCApiClient.Companion.makeQueryRequest
 import org.xmtp.android.library.GRPCApiClient.Companion.makeSubscribeRequest
-import org.xmtp.android.library.libxmtp.Message
+import org.xmtp.android.library.libxmtp.MessageV3
 import org.xmtp.android.library.messages.DecryptedMessage
 import org.xmtp.android.library.messages.Envelope
 import org.xmtp.android.library.messages.EnvelopeBuilder
@@ -576,7 +576,10 @@ data class Conversations(
     fun streamAllGroupMessages(): Flow<DecodedMessage> = callbackFlow {
         val messageCallback = object : FfiMessageCallback {
             override fun onMessage(message: FfiMessage) {
-                trySend(Message(client, message).decode())
+                val decodedMessage = MessageV3(client, message).decodeOrNull()
+                decodedMessage?.let {
+                    trySend(it)
+                }
             }
         }
         val stream = libXMTPConversations?.streamAllMessages(messageCallback)
@@ -587,7 +590,10 @@ data class Conversations(
     fun streamAllGroupDecryptedMessages(): Flow<DecryptedMessage> = callbackFlow {
         val messageCallback = object : FfiMessageCallback {
             override fun onMessage(message: FfiMessage) {
-                trySend(Message(client, message).decrypt())
+                val decryptedMessage = MessageV3(client, message).decryptOrNull()
+                decryptedMessage?.let {
+                    trySend(it)
+                }
             }
         }
         val stream = libXMTPConversations?.streamAllMessages(messageCallback)
diff --git a/library/src/main/java/org/xmtp/android/library/DecodedMessage.kt b/library/src/main/java/org/xmtp/android/library/DecodedMessage.kt
index eb80cd770..8657e2ad5 100644
--- a/library/src/main/java/org/xmtp/android/library/DecodedMessage.kt
+++ b/library/src/main/java/org/xmtp/android/library/DecodedMessage.kt
@@ -11,7 +11,7 @@ data class DecodedMessage(
     var topic: String,
     var encodedContent: Content.EncodedContent,
     var senderAddress: String,
-    var sent: Date
+    var sent: Date,
 ) {
     companion object {
         fun preview(client: Client, topic: String, body: String, senderAddress: String, sent: Date): DecodedMessage {
diff --git a/library/src/main/java/org/xmtp/android/library/Group.kt b/library/src/main/java/org/xmtp/android/library/Group.kt
index 7812201fc..f802cf29c 100644
--- a/library/src/main/java/org/xmtp/android/library/Group.kt
+++ b/library/src/main/java/org/xmtp/android/library/Group.kt
@@ -6,7 +6,7 @@ import kotlinx.coroutines.flow.callbackFlow
 import org.xmtp.android.library.codecs.ContentCodec
 import org.xmtp.android.library.codecs.EncodedContent
 import org.xmtp.android.library.codecs.compress
-import org.xmtp.android.library.libxmtp.Message
+import org.xmtp.android.library.libxmtp.MessageV3
 import org.xmtp.android.library.messages.DecryptedMessage
 import org.xmtp.android.library.messages.PagingInfoSortDirection
 import org.xmtp.android.library.messages.Topic
@@ -93,9 +93,10 @@ class Group(val client: Client, private val libXMTPGroup: FfiGroup) {
                 sentAfterNs = after?.time?.nanoseconds?.toLong(DurationUnit.NANOSECONDS),
                 limit = limit?.toLong()
             )
-        ).map {
-            Message(client, it).decode()
+        ).mapNotNull {
+            MessageV3(client, it).decodeOrNull()
         }
+
         return when (direction) {
             MessageApiOuterClass.SortDirection.SORT_DIRECTION_ASCENDING -> messages
             else -> messages.reversed()
@@ -114,18 +115,19 @@ class Group(val client: Client, private val libXMTPGroup: FfiGroup) {
                 sentAfterNs = after?.time?.nanoseconds?.toLong(DurationUnit.NANOSECONDS),
                 limit = limit?.toLong()
             )
-        ).map {
-            Message(client, it).decrypt()
+        ).mapNotNull {
+            MessageV3(client, it).decryptOrNull()
         }
+
         return when (direction) {
             MessageApiOuterClass.SortDirection.SORT_DIRECTION_ASCENDING -> messages
             else -> messages.reversed()
         }
     }
 
-    suspend fun processMessage(envelopeBytes: ByteArray): Message {
+    suspend fun processMessage(envelopeBytes: ByteArray): MessageV3 {
         val message = libXMTPGroup.processStreamedGroupMessage(envelopeBytes)
-        return Message(client, message)
+        return MessageV3(client, message)
     }
 
     fun isActive(): Boolean {
@@ -173,7 +175,10 @@ class Group(val client: Client, private val libXMTPGroup: FfiGroup) {
     fun streamMessages(): Flow<DecodedMessage> = callbackFlow {
         val messageCallback = object : FfiMessageCallback {
             override fun onMessage(message: FfiMessage) {
-                trySend(Message(client, message).decode())
+                val decodedMessage = MessageV3(client, message).decodeOrNull()
+                decodedMessage?.let {
+                    trySend(it)
+                }
             }
         }
 
@@ -184,7 +189,10 @@ class Group(val client: Client, private val libXMTPGroup: FfiGroup) {
     fun streamDecryptedMessages(): Flow<DecryptedMessage> = callbackFlow {
         val messageCallback = object : FfiMessageCallback {
             override fun onMessage(message: FfiMessage) {
-                trySend(Message(client, message).decrypt())
+                val decryptedMessage = MessageV3(client, message).decryptOrNull()
+                decryptedMessage?.let {
+                    trySend(it)
+                }
             }
         }
 
diff --git a/library/src/main/java/org/xmtp/android/library/libxmtp/Message.kt b/library/src/main/java/org/xmtp/android/library/libxmtp/MessageV3.kt
similarity index 56%
rename from library/src/main/java/org/xmtp/android/library/libxmtp/Message.kt
rename to library/src/main/java/org/xmtp/android/library/libxmtp/MessageV3.kt
index b2105aa6b..8bc57409a 100644
--- a/library/src/main/java/org/xmtp/android/library/libxmtp/Message.kt
+++ b/library/src/main/java/org/xmtp/android/library/libxmtp/MessageV3.kt
@@ -1,5 +1,6 @@
 package org.xmtp.android.library.libxmtp
 
+import android.util.Log
 import org.xmtp.android.library.Client
 import org.xmtp.android.library.DecodedMessage
 import org.xmtp.android.library.XMTPException
@@ -7,10 +8,13 @@ import org.xmtp.android.library.codecs.EncodedContent
 import org.xmtp.android.library.messages.DecryptedMessage
 import org.xmtp.android.library.messages.Topic
 import org.xmtp.android.library.toHex
+import uniffi.xmtpv3.FfiGroupMessageKind
 import uniffi.xmtpv3.FfiMessage
+import uniffi.xmtpv3.org.xmtp.android.library.codecs.ContentTypeGroupMembershipChange
 import java.util.Date
 
-data class Message(val client: Client, private val libXMTPMessage: FfiMessage) {
+data class MessageV3(val client: Client, private val libXMTPMessage: FfiMessage) {
+
     val id: ByteArray
         get() = libXMTPMessage.id
 
@@ -25,26 +29,48 @@ data class Message(val client: Client, private val libXMTPMessage: FfiMessage) {
 
     fun decode(): DecodedMessage {
         try {
-            return DecodedMessage(
+            val decodedMessage = DecodedMessage(
                 id = id.toHex(),
                 client = client,
                 topic = Topic.groupMessage(convoId.toHex()).description,
                 encodedContent = EncodedContent.parseFrom(libXMTPMessage.content),
                 senderAddress = senderAddress,
-                sent = sentAt
+                sent = sentAt,
             )
+            if (decodedMessage.encodedContent.type == ContentTypeGroupMembershipChange && libXMTPMessage.kind != FfiGroupMessageKind.MEMBERSHIP_CHANGE) {
+                throw XMTPException("Error decoding group membership change")
+            }
+            return decodedMessage
         } catch (e: Exception) {
             throw XMTPException("Error decoding message", e)
         }
     }
 
+    fun decodeOrNull(): DecodedMessage? {
+        return try {
+            decode()
+        } catch (e: Exception) {
+            Log.d("MESSAGE_V3", "discarding message that failed to decode", e)
+            null
+        }
+    }
+
+    fun decryptOrNull(): DecryptedMessage? {
+        return try {
+            decrypt()
+        } catch (e: Exception) {
+            Log.d("MESSAGE_V3", "discarding message that failed to decrypt", e)
+            null
+        }
+    }
+
     fun decrypt(): DecryptedMessage {
         return DecryptedMessage(
             id = id.toHex(),
             topic = Topic.groupMessage(convoId.toHex()).description,
             encodedContent = decode().encodedContent,
             senderAddress = senderAddress,
-            sentAt = Date()
+            sentAt = Date(),
         )
     }
 }
diff --git a/library/src/main/java/org/xmtp/android/library/messages/DecryptedMessage.kt b/library/src/main/java/org/xmtp/android/library/messages/DecryptedMessage.kt
index c2b2d4ef5..2b3980073 100644
--- a/library/src/main/java/org/xmtp/android/library/messages/DecryptedMessage.kt
+++ b/library/src/main/java/org/xmtp/android/library/messages/DecryptedMessage.kt
@@ -8,5 +8,5 @@ data class DecryptedMessage(
     var encodedContent: EncodedContent,
     var senderAddress: String,
     var sentAt: Date,
-    var topic: String = ""
+    var topic: String = "",
 )
diff --git a/library/src/main/java/xmtpv3.kt b/library/src/main/java/xmtpv3.kt
index 242321bd3..890152485 100644
--- a/library/src/main/java/xmtpv3.kt
+++ b/library/src/main/java/xmtpv3.kt
@@ -2500,7 +2500,8 @@ data class FfiMessage (
     var `sentAtNs`: Long,
     var `convoId`: ByteArray,
     var `addrFrom`: String,
-    var `content`: ByteArray
+    var `content`: ByteArray,
+    var `kind`: FfiGroupMessageKind
 ) {
 
     companion object
@@ -2514,6 +2515,7 @@ public object FfiConverterTypeFfiMessage: FfiConverterRustBuffer<FfiMessage> {
             FfiConverterByteArray.read(buf),
             FfiConverterString.read(buf),
             FfiConverterByteArray.read(buf),
+            FfiConverterTypeFfiGroupMessageKind.read(buf),
         )
     }
 
@@ -2522,7 +2524,8 @@ public object FfiConverterTypeFfiMessage: FfiConverterRustBuffer<FfiMessage> {
                     FfiConverterLong.allocationSize(value.`sentAtNs`) +
                     FfiConverterByteArray.allocationSize(value.`convoId`) +
                     FfiConverterString.allocationSize(value.`addrFrom`) +
-                    FfiConverterByteArray.allocationSize(value.`content`)
+                    FfiConverterByteArray.allocationSize(value.`content`) +
+                    FfiConverterTypeFfiGroupMessageKind.allocationSize(value.`kind`)
             )
 
     override fun write(value: FfiMessage, buf: ByteBuffer) {
@@ -2531,6 +2534,7 @@ public object FfiConverterTypeFfiMessage: FfiConverterRustBuffer<FfiMessage> {
         FfiConverterByteArray.write(value.`convoId`, buf)
         FfiConverterString.write(value.`addrFrom`, buf)
         FfiConverterByteArray.write(value.`content`, buf)
+        FfiConverterTypeFfiGroupMessageKind.write(value.`kind`, buf)
     }
 }
 
@@ -2743,6 +2747,30 @@ public object FfiConverterTypeFfiV2SubscribeRequest: FfiConverterRustBuffer<FfiV
 
 
 
+enum class FfiGroupMessageKind {
+    APPLICATION,MEMBERSHIP_CHANGE;
+    companion object
+}
+
+public object FfiConverterTypeFfiGroupMessageKind: FfiConverterRustBuffer<FfiGroupMessageKind> {
+    override fun read(buf: ByteBuffer) = try {
+        FfiGroupMessageKind.values()[buf.getInt() - 1]
+    } catch (e: IndexOutOfBoundsException) {
+        throw RuntimeException("invalid enum value, something is very wrong!!", e)
+    }
+
+    override fun allocationSize(value: FfiGroupMessageKind) = 4
+
+    override fun write(value: FfiGroupMessageKind, buf: ByteBuffer) {
+        buf.putInt(value.ordinal + 1)
+    }
+}
+
+
+
+
+
+
 enum class FfiSortDirection {
     UNSPECIFIED,ASCENDING,DESCENDING;
     companion object
diff --git a/library/src/main/jniLibs/arm64-v8a/libuniffi_xmtpv3.so b/library/src/main/jniLibs/arm64-v8a/libuniffi_xmtpv3.so
index 29b7e22df..f719c5695 100755
Binary files a/library/src/main/jniLibs/arm64-v8a/libuniffi_xmtpv3.so and b/library/src/main/jniLibs/arm64-v8a/libuniffi_xmtpv3.so differ
diff --git a/library/src/main/jniLibs/armeabi-v7a/libuniffi_xmtpv3.so b/library/src/main/jniLibs/armeabi-v7a/libuniffi_xmtpv3.so
index c9dfe8fee..8d8e6b627 100755
Binary files a/library/src/main/jniLibs/armeabi-v7a/libuniffi_xmtpv3.so and b/library/src/main/jniLibs/armeabi-v7a/libuniffi_xmtpv3.so differ
diff --git a/library/src/main/jniLibs/x86/libuniffi_xmtpv3.so b/library/src/main/jniLibs/x86/libuniffi_xmtpv3.so
index 7006a1741..6c8f2f36d 100755
Binary files a/library/src/main/jniLibs/x86/libuniffi_xmtpv3.so and b/library/src/main/jniLibs/x86/libuniffi_xmtpv3.so differ
diff --git a/library/src/main/jniLibs/x86_64/libuniffi_xmtpv3.so b/library/src/main/jniLibs/x86_64/libuniffi_xmtpv3.so
index 559d9f473..1b3773029 100755
Binary files a/library/src/main/jniLibs/x86_64/libuniffi_xmtpv3.so and b/library/src/main/jniLibs/x86_64/libuniffi_xmtpv3.so differ