k/group: fixed typos

Signed-off-by: Michal Maslanka <michal@redpanda.com>

src/v/kafka/server/group.cc

@@ -534,7 +534,7 @@ group::handle_join_group(join_group_request&& r, bool is_new_group) {
     }
 
     // TODO: move the logic in this method up to group manager to make the
-    // handling of is_new_group etc.. clearner rather than passing these flags
+    // handling of is_new_group etc.. clearer rather than passing these flags
     // down into the group-level handler.
     if (
       !is_new_group && !_initial_join_in_progress
@@ -553,7 +553,7 @@ group::handle_join_group(join_group_request&& r, bool is_new_group) {
          * take into account was the tolerance for timeouts by clients. this
          * handles the case that all clients join after a rebalance, but the
          * last client doesn't complete the join (see the case in
-         * try_complete_join where we return immedaitely rather than completing
+         * try_complete_join where we return immediately rather than completing
          * the join if we are in the preparing rebalance state). this check
          * handles that before returning.
          */
@@ -882,7 +882,7 @@ group::join_group_known_member(join_group_request&& r) {
               leader().value_or(member_id("")),
               std::move(r.data.member_id));
 
-            vlog(_ctxlog.trace, "Handling idemponent group join {}", response);
+            vlog(_ctxlog.trace, "Handling idempotent group join {}", response);
 
             return join_group_stages(std::move(response));
         }
@@ -1401,7 +1401,7 @@ group::sync_group_stages group::handle_sync_group(sync_group_request&& r) {
         sync_group_response reply(error_code::none, member->assignment());
         vlog(
           _ctxlog.trace,
-          "Handling idemponent group sync for member {} with reply {}",
+          "Handling idempotent group sync for member {} with reply {}",
           member,
           reply);
         return sync_group_stages(sync_group_response(std::move(reply)));
@@ -1495,7 +1495,7 @@ group::sync_group_stages group::sync_group_completing_rebalance(
                          r.error());
                        // an error was encountered persisting the group state:
                        //   - clear all the member assignments
-                       //   - propogate error back to waiting clients
+                       //   - propagate error back to waiting clients
                        clear_assignments();
                        finish_syncing_members(error_code::not_coordinator);
                        try_prepare_rebalance();
@@ -1833,7 +1833,7 @@ group::begin_tx(cluster::begin_group_tx_request r) {
         //
         // at the same time it's possible that it already aborted the old
         // tx before starting this. do_abort_tx is idempotent so calling it
-        // just in case to proactivly abort the tx instead of waiting for
+        // just in case to proactively abort the tx instead of waiting for
         // the timeout
 
         auto old_pid = model::producer_identity{
@@ -2825,7 +2825,7 @@ ss::future<error_code> group::remove() {
     } catch (const std::exception& e) {
         vlog(
           klog.error,
-          "Exception occured replicating group {} delete records {}",
+          "Exception occurred replicating group {} delete records {}",
           _id,
           e);
     }
@@ -2913,7 +2913,7 @@ group::remove_topic_partitions(const std::vector<model::topic_partition>& tps) {
     } catch (const std::exception& e) {
         vlog(
           klog.error,
-          "Exception occured replicating group {} cleanup records {}",
+          "Exception occurred replicating group {} cleanup records {}",
           _id,
           e);
     }