nit

ruokun-niu · Dec 5, 2024 · af27875 · af27875
1 parent 751f8c1
commit af27875
Showing 1 changed file with 0 additions and 31 deletions.
diff --git a/reactions/debezium/debezium-reaction/Services/ChangeHandler.cs b/reactions/debezium/debezium-reaction/Services/ChangeHandler.cs
@@ -81,35 +81,4 @@ public async Task HandleChange(ChangeEvent evt, object? queryConfig)
 
 		_producer.Flush();
 	}
-
-
-	// private async Task ProcessResults(EventMetadata metadata, Dictionary<string, object>[] results, string op)
-	// {
-	// 	var noIndent = new JsonSerializerOptions { WriteIndented = false };
-	// 	foreach (var res in results)
-	// 	{
-	// 		string eventString = _formatter.FormatEvent(metadata, res, op);
-
-	// 		_logger.LogInformation($"dataChangeEvent: {eventString}");
-	// 		try
-	// 		{
-	// 			var deliveryReport = await _producer.ProduceAsync(_topic, new Message<Null, string> { Value = eventString }, CancellationToken.None);
-
-	// 			if (deliveryReport.Status != PersistenceStatus.Persisted)
-	// 			{
-	// 				_logger.LogInformation($"Delivery failed: {deliveryReport.Message.Value}");
-	// 			}
-	// 			else
-	// 			{
-	// 				_logger.LogInformation($"Message delivered to {deliveryReport.TopicPartitionOffset}");
-	// 			}
-
-	// 		}
-	// 		catch (ProduceException<Null, string> ex)
-	// 		{
-	// 			_logger.LogInformation($"ProduceException: {ex.Error.Reason}");
-	// 		}
-	// 	}
-	// }
-
 }