@Test
void testLargeConsensusSubmitMessage() throws SQLException {

    var topicMessages = new HashSet<TopicMessage>();
    topicMessages.add(topicMessage(1, 6000)); // max 6KiB
    topicMessages.add(topicMessage(2, 6000));
    topicMessages.add(topicMessage(3, 6000));
    topicMessages.add(topicMessage(4, 6000));
    topicMessagePgCopy.copy(topicMessages, dataSource.getConnection());
    assertThat(topicMessageRepository.findAll()).hasSize(4).containsExactlyInAnyOrderElementsOf(topicMessages);
}