需要编写自定义集成层以满足数据管道中的特定需求吗？了解如何使用Kafka和OpenSearch以及Go实现这一目标。