chore: apply suggestions from CR

src/log-store/src/error.rs

@@ -188,7 +188,7 @@ pub enum Error {
  },
 
  #[snafu(display("Failed to produce batch records to Kafka"))]
- ProduceBatch {
+ BatchProduce {
  #[snafu(implicit)]
  location: Location,
  #[snafu(source)]

src/log-store/src/kafka/producer.rs

@@ -60,7 +60,7 @@ async fn do_flush<A: Aggregator>(
  if let Err(err) = match client
  .produce(batch, compression)
  .await
- .context(error::ProduceBatchSnafu)
+ .context(error::BatchProduceSnafu)
  {
  Ok(aggregated_status) => sender.send(BatchFlushState::Result(Arc::new(AggregatedStatus {
  aggregated_status,