所有人！我有一些问题，希望有人能帮我。当我通过kafka neo4j通道到达时，我向kafka发送数据，但是neo4j通道没有接收到任务信息。我不知道为什么，我应该在哪里分析它。非常感谢你！
Kafka{“id”：“1”，“properties”：{“name”：“smith”，“dob”：19800101}
neo4j cql:match（n:people）其中n.name='smith'返回n

- name: NEO4J_apoc_import_file_enabled
        value: "true"
      - name: NEO4J_apoc_export_file_enabled
        value: "true"
      - name: NEO4J_apoc_import_file_use__neo4j__config
        value: "true"
      - name: NEO4J_kafka_zookeeper_connect
        value: "192.168.0.221:2181"
      - name: NEO4J_kafka_bootstrap_servers
        value: "192.168.0.221:9092"
      - name: NEO4J_dbms_memory_heap_max_size
        value: "2G"
      - name: NEO4J_streams_sink_enabled
        value: "true"
      - name: NEO4J_kafka_group_id
        value: "test-consumer-group"
      - name: NEO4J_enable_auto_commit
        value: "true"
      - name: NEO4J_streams_sink_topic_cypher_TestTopic
        value: "MERGE (a:Person {id: event.id}) ON CREATE set n += event.prorerties"
      - name: NEO4J_ACCEPT_LICENSE_AGREEMENT
        value: "yes"
      - name: NEO4J_AUTH
        value: "neo4j/bjsh"

neo4j测井：

Active database: graph.db
Directories in use:
  home:         /var/lib/neo4j
  config:       /var/lib/neo4j/conf
  logs:         /logs
  plugins:      /var/lib/neo4j/plugins
  import:       /var/lib/neo4j/import
  data:         /var/lib/neo4j/data
  certificates: /var/lib/neo4j/certificates
  run:          /var/lib/neo4j/run
Starting Neo4j.
Unknown config option: dbms.memory.heap.max.size
======== Neo4j 3.4.18 ========
Starting...
Initiating metrics...
Sending metrics to CSV file at /var/lib/neo4j/metrics
Bolt enabled on 0.0.0.0:7687.
Server thread metrics not available (missing neo4j.server.threads.jetty.all)
Server thread metrics not available (missing neo4j.server.threads.jetty.idle)
Started.
Mounted REST API at: /db/manage
Loaded server plugin "SpatialPlugin"
  GraphDatabaseService.addSimplePointLayer: add a new layer specialized at storing simple point location data
  GraphDatabaseService.addNodesToLayer: adds many geometry nodes (about 10k-50k) to a layer, as long as the nodes contain the geometry information appropriate to this layer.
  GraphDatabaseService.findClosestGeometries: search a layer for the closest geometries and return them.
  GraphDatabaseService.addGeometryWKTToLayer: add a geometry specified in WKT format to a layer, encoding in the specified layers encoding schemea.
  GraphDatabaseService.addEditableLayer: add a new layer specialized at storing generic geometry data in WKB
  GraphDatabaseService.findGeometriesWithinDistance: search a layer for geometries within a distance of a point. To achieve more complex CQL searches, pre-define the dynamic layer with addCQLDynamicLayer.
  GraphDatabaseService.addCQLDynamicLayer: add a new dynamic layer exposing a filtered view of an existing layer
  GraphDatabaseService.addNodeToLayer: add a geometry node to a layer, as long as the node contains the geometry information appropriate to this layer.
  GraphDatabaseService.getLayer: find an existing layer
  GraphDatabaseService.findGeometriesInBBox: search a layer for geometries in a bounding box. To achieve more complex CQL searches, pre-define the dynamic layer with addCQLDynamicLayer.
  GraphDatabaseService.findGeometriesIntersectingBBox: search a layer for geometries intersecting a bounding box. To achieve more complex CQL searches, pre-define the dynamic layer with addCQLDynamicLayer.
Server thread metrics has been registered successfully
Remote interface available at http://localhost:7474/