This can happen if you have configured support for multiple protocols in your cluster. The correct broker hosts/ports cannot be determined from the data in the Zookeeper.In this case you need to leave the Zookeeper host/port fields blank. You have no access to the Zookeeper host in your cluster due to security, firewall or other reasons.In some cases you must enter values in the 'Bootstrap servers' field in order to be able to connect to your Kafka cluster: The defalit value is correct in most cases. chroot path - path where the kafka cluster data appears in Zookeeper.Zookeeper Port - port of the zookeeper host.Zookeeper Host - hostname or IP address of the zookeeper host in the cluster.Cluster Name - name you want to give the cluster you're connecting to.In the 'Add Cluster' dialog you must provide the following values under the General-section This can be done using the 'Add Cluster' toolbar button or the 'Add New Connection' menu item in the File-menu. All rights reserved.In order to view data in your Kafka cluster you must first create a connection to it. Offset Explorer | UI Tool for Apache Kafka The messages/keys will be decorated using your custom decorator. In the 'Content Types' drop-downs you should see the name of your decorator. Restart Offset Explorer and navigate to the topic that you want to use the decorator with. Once you have compiled and packaged your jar, copy it to the 'plugins' folder in the Offset Explorer installation folder. Do not include any jars that are already in the 'lib' directory of Offset Explorer, especially any You must put your own compiled classes and any dependencies you might have (e.g. You must compile your source code using Java 8 compatible compiler. It does not provide support for message headers. Notice that the old ICustomMessageDecorator interface is deprecated but still supported. The 'reserved' argument is currently used but may contain data in future releases. You should not throw any exceptions from this method, you should catchĪll throwables in a try/catch block in your implementation. This method does the actual conversion from a byte array to a String that contains the desired output. public String decorate(String zookeeperHost, String brokerHost, String topic, long partitionId, long offset, byte msg, Map headers, Map reserved).This method should return a name that will be shown in the Offset Explorer's topic configuration screen where you can pick the content type for the selected topic. The interface is located in the 'src' directory of the provided example plugin and it has two methods that you need to implement You need to create a class that implements the 2 interface. You can also find an example Avro plugin developed by a third-party by following this link. There is an example of how to write a plugin in the plugins/example folder in your Offset Explorer installation directory. Plugins allow you to view messages that are not natively understood by Offset Explorer, in a format that you see fit.įor example, one can write a decorator for Avro (or Thrift) messages that will show the actual contents of the Avro objects in a suitable format. Offset Explorer supports custom plugins written in Java.
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |