ファイルからKafkaにNeo4jコマンドを書き込むカスタムコネクタがあり、それをデバッグしたいと思います。だから、私はConfluent v3.3.0をダウンロードし、時間をかけてそれに慣れました。しかし、私は自分自身がコネクタをロードしようとしているのを知っています。私は、次のエラーを得たことが、このエラー以前のようにJSONファイルとしてファイルを解析しようとしていることを暗示していカスタムコネクタ設定ファイルをJavaプロパティ形式として解析するにはどうすればよいですか?
parse error: Invalid string: control characters from U+0000 through U+001F must be escaped at line 1, column 124
parse error: Invalid numeric literal at line 2, column 0
:私はその.propertiesファイルは、私は次のエラーを取得するファイルを使用してコネクターをロードしようとすると、コネクタロードしようとしたとき:
Warning: Install 'jq' to add support for parsing JSON
をそして私は、インストールさJQを醸造し、現在旧エラーを取得されていました。
このファイルは、.propertiesのために暗黙のうちに考えられるJavaプロパティ形式として解析されたいと思いますが、どこかの設定で明示的にする必要がありますか?
更新:
@Konstantine Karantasisにより示唆されるように、私はJSONに.propertiesファイルを変換しますが、前が、最初の行のないように私は同じエラーを取得:私は三重のチェックを
parse error: Invalid numeric literal at line 2, column 0
私の書式設定といくつかのエラーで検索しましたが、短くなってきました。書式設定でエラーが発生した場合、または私が気にしていないKafka ConnectでJSONファイルを使用する際に微妙な違いがあるかどうか教えてください。
Javaプロパティ:
name=neo4k-file-source
connector.class=neo4k.filestream.source.Neo4jFileStreamSourceConnector
tasks.max=1
file=Neo4jCommands.txt
topic=neo4j-commands
はJSONに変換:あなたのコネクターを開始するために使用している
[{
"name": "neo4k-file-source",
"connector": {
"class": "neo4k.filestream.source.Neo4jFileStreamSourceConnector"
},
"tasks": {
"max": 1
},
"file": "Neo4jCommands.txt",
"topic": "neo4j-commands"
}]
JSONを使用して、ロードしました。記事を読んでもらって、私のプロジェクトで拾うことができるものがあるかどうかを確認します。ありがとうございました! –