kafka发到elasticSearch的数据在哪里？知道我在使用ElasticSearch接收器吗？

Question

这是我的输出。我认为一切都很好：

[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中可视化数据？

Answer 1

您可以直接使用Elasticsearch REST API来访问您在Connect Config中设置的索引，或者我相信是/_cat端点。

然而，Kibana作为可视化工具会更容易。在Kibana中做任何事情之前，你必须通过设置面板设置一个索引模式，它会提示输入一个时间字段，如果你没有时间字段，可以忽略它，但是你可以转到Discover面板，根据需要查询数据。

如果没有创建索引模式，则Connect没有权限这样做，或者没有数据流，或者其他一些错误。

您的日志输出并不能说明实际正在运行，因为它只是说明消费者偏移量已被重置为Kafka分区的开头