diff --git a/thread.go b/thread.go
index d3421184..088f90ea 100644
--- a/thread.go
+++ b/thread.go
@@ -72,7 +72,7 @@ func (*Session) populateThreads(
 ) (int, error) {
 	total := 0
 	for i := range msgs {
-		if msgs[i].ThreadTimestamp == "" {
+		if msgs[i].ThreadTimestamp == "" || msgs[i].SubType == "thread_broadcast" {
 			continue
 		}
 		threadMsgs, err := dumpFn(ctx, l, channelID, msgs[i].ThreadTimestamp, oldest, latest)