这是我的输出。我认为一切正常：
[2018-07-06 22:27:51,458] INFO [Consumer clientId=consumer-4, groupId=connect-elk-sink] Setting newly assigned partitions [elk-test-0] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2018-07-06 22:27:51,471] INFO [Consumer clientId=consumer-4, groupId=connect-elk-sink] Resetting offset for partition elk-test-0 to offset 0. (org.apache.kafka.clients.consumer.internals.Fetcher)
如何在 Kibana 中可视化数据？
我相信，您可以直接使用Elasticsearch REST API来访问您在Connect Config中设置的索引或/_cat端点。
但是，Kibana 作为可视化会更容易。在 Kibana 中执行任何操作之前，您必须通过"设置"面板设置索引模式，它会提示输入一个时间字段，如果您没有时间字段，可以忽略该时间字段，但您可以转到"发现"面板并根据需要查询数据。
如果未创建索引模式，则 Connect 没有执行此操作的权限，或者没有数据流或其他错误。
您的日志输出并不表示事情实际上正在工作，因为它只是说消费者偏移量已重置为 Kafka 分区的开头