self review

Author: tungtose

core/integration/tests/server/scenarios/consumer_group_with_single_client_polling_messages_scenario.rs

@@ -175,7 +175,6 @@ async fn execute_using_none_key(client: &IggyClient) {
         let message = &polled_messages.messages[0];
         assert_eq!(message.header.offset, offset);
         let payload = from_utf8(&message.payload).unwrap();
-
         assert_eq!(
             payload,
             &create_extended_message_payload(partition_id, entity_id)

core/server/src/shard/handlers.rs

@@ -382,8 +382,6 @@ async fn handle_request(
 
             let ns = IggyFullNamespace::new(stream_id.clone(), topic_id.clone(), partition_id);
 
-            info!("DBG PollMessage: -1");
-
             match initial_data {
                 SocketTransferPayload::SendMessages { batch } => {
                     let batch = shard.maybe_encrypt_messages(batch)?;
@@ -457,14 +455,10 @@ async fn handle_request(
                         sender
                             .send_ok_response_vectored(&response_length_bytes, bufs)
                             .await?;
-
-                        info!("DBG PollMessage: 2");
                     }
                 }
             }
 
-            info!("DBG PollMessage: 3");
-
             registry.spawn_connection(async move {
                 match handle_connection(&session, &mut sender, &shard_for_conn, conn_stop_receiver)
                     .await
@@ -496,7 +490,6 @@ async fn handle_request(
                 }
             });
 
-            info!("DBG PollMessage: 4");
             Ok(ShardResponse::SocketTransferResponse)
         }
     }