我正在测试发送通用记录。但是下面的代码
let fullName = "Test k"
let uniEncoding = new UnicodeEncoding()
let str = uniEncoding.GetBytes("abcdefg")
use ms = new MemoryStream()
ms.Write(str, 0, str.Length)
let content = ms.ToArray()
let config = new Dictionary<string, Object>()
config.Add("bootstrap.servers", "10.0.0.2:9092")
config.Add("schema.registry.url", "http://bing.com")
let s = Schema.Parse(
"""{
"namespace": "nnnnnnnn",
"type": "record",
"name": "fffffnnnnnn",
"fields": [
{"name": "file_name", "type": "string"},
{"name": "time", "type": "string"},
{"name": "content", "type": "bytes"}
]
}""") :?> RecordSchema
use producer = new Producer<string, GenericRecord>(
config, new AvroSerializer<string>(), new AvroSerializer<GenericRecord>())
let record = new GenericRecord(s)
record.Add("file_name", fullName)
record.Add("time", DateTimeOffset.Now.ToString())
record.Add("content", content)
let dr = producer.ProduceAsync("Topic1", fullName, record).Result // error
0 // return an integer exit code
返回此错误
HttpRequestException:异常:[
http://bing.com/]
http://bing.com/]
服务不可用-1