Kafka Consumer
To add a consumer in Axibase Collector, navigate to Data Sources > Kafka Consumers and select "Add".
Supported Brokers
Apache Kafka 0.9.0.x +
Settings
| Field | Description |
|---|---|
| Name | Name of consumer. |
| Server(s) | A list of host/port pairs to use for establishing the initial connection to the Kafka cluster. The client will make use of all servers irrespective of which servers are specified here for bootstrapping—this list only impacts the initial hosts used to discover the full set of servers. This list should be in the form 'host1:port1,host2:port2,...'. Since these servers are just used for the initial connection to discover the full cluster membership (which may change dynamically), this list need not contain the full set of servers (you may want more than one, though, in case a server is down) |
| Security Protocol | Protocol used to communicate with brokers. Supported protocols: * PLAINTEXT * SSL |
| Read Timeout, seconds | The amount of time in seconds to block message reading. |
| Poll Timeout, ms | The amount of time in milliseconds to block waiting for input. |
| Properties | Extended consumer properties |
SSL Settings
If SSL protocol is selected, we need to configure additional settings:
| Field | Description |
|---|---|
| Key Store | Key stores: * CUSTOM - use custom trust/key stores * DEFAULT - use Collector stores |
| Trust Store Path | The location of the trust store file. |
| Trust Store Password | The password for the trust store file. |
| Two-Way Authentication | Enable 2-Way Authentication (client verification). |
| Key Store Path | The location of the key store file. |
| Key Store Password | The store password for the key store file. |
| Key Alias | The unique name of the entry in the store. |
| Key Password | The password of the private key in the key store file. |
Screenshots
Configuration
Test Result
