我们可以从 Log Analytics Workspace 访问 Pod 相关日志,但没有应用程序日志(与我们在 中看到的类似kubectl get events)。
我指的是 Azure 文档,但我仍然无法从 Azure 门户访问应用程序 Pod 日志
我需要一些帮助来为我的 Java kafka 使用者构建 Junit 测试用例。
我的原始源代码具有如下方法,并且需要为此创建一个单元测试用例。
public void processConsumerRecord(ConsumerRecords<String, GenericRecord> records, boolean isEventProcessed, boolean isOffsetCommitted,
int totalErrorCountFromSinkService, int totalErrorCount, Consumer<String, GenericRecord> consumer) {
Run Code Online (Sandbox Code Playgroud)
...... }
我的 Kafka 消费者正在从 kafka 主题中提取消息,我需要能够以 ConsumerRecords 格式提供输入消息,但作为单元测试的一部分,我没有轮询来自 kafka 的消息,而是模拟来自原始 kafka 主题的消息并提供测试上述方法的单元测试用例的静态输入消息,如图所示。如何以 ConsumerRecords < String, GenericRecord > 的形式创建模拟输入消息?