diff --git a/backend/pkg/api/handle_topic_messages_integration_test.go b/backend/pkg/api/handle_topic_messages_integration_test.go index 5327a0025..3421cc577 100644 --- a/backend/pkg/api/handle_topic_messages_integration_test.go +++ b/backend/pkg/api/handle_topic_messages_integration_test.go @@ -89,6 +89,10 @@ func (s *APIIntegrationTestSuite) TestListMessages() { phaseCount++ case *v1pb.ListMessagesResponse_Progress: progressCount++ + + assert.NotEmpty(cm.Progress) + assert.NotEmpty(cm.Progress.GetBytesConsumed()) + assert.NotEmpty(cm.Progress.GetMessagesConsumed()) case *v1pb.ListMessagesResponse_Error: errorCount++ }