Skip to content

Commit

Permalink
Merge pull request #21410 from mmaslankaprv/group-logging-fix
Browse files Browse the repository at this point in the history
k/group: do not log ignoring raft configuration batches
  • Loading branch information
mmaslankaprv authored Jul 17, 2024
2 parents 015afa7 + 0d7a1d5 commit 8791fde
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions src/v/kafka/server/group_data_parser.h
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
#include "kafka/server/group_metadata.h"
#include "kafka/server/logger.h"
#include "model/record.h"
#include "model/record_batch_types.h"

template<typename T>
T parse_tx_batch(const model::record_batch& batch, int8_t version) {
Expand Down Expand Up @@ -81,6 +82,10 @@ class group_data_parser {
if (b.header().type == model::record_batch_type::raft_data) {
return handle_raft_data(std::move(b));
}
// silently ignore raft configuration.
if (b.header().type == model::record_batch_type::raft_configuration) {
return ss::now();
}
if (b.header().type == model::record_batch_type::group_prepare_tx) {
auto data = parse_tx_batch<kafka::group_tx::offsets_metadata>(
b, group::prepared_tx_record_version);
Expand Down

0 comments on commit 8791fde

Please sign in to comment.