kafka消費者命令行的使用方法

root@ocdata07 bin]# ./kafka-console-consumer.sh
The console consumer is a tool that reads data from Kafka and outputs it to standard output.
Option                                  Description                            
------                                  -----------                            
--blacklist <blacklist>                 Blacklist of topics to exclude from    
                                          consumption.                         
--consumer.config <config file>         Consumer config properties file.       
--csv-reporter-enabled                  If set, the CSV metrics reporter will  
                                          be enabled                           
--delete-consumer-offsets               If specified, the consumer path in     
                                          zookeeper is deleted when starting up
--formatter <class>                     The name of a class to use for         
                                          formatting kafka messages for        
                                          display. (default: kafka.tools.      
                                          DefaultMessageFormatter)             
--from-beginning                        If the consumer does not already have  
                                          an established offset to consume     
                                          from, start with the earliest        
                                          message present in the log rather    
                                          than the latest message.             
--max-messages <Integer: num_messages>  The maximum number of messages to      
                                          consume before exiting. If not set,  
                                          consumption is continual.            
--metrics-dir <metrics dictory>         If csv-reporter-enable is set, and     
                                          this parameter isset, the csv        
                                          metrics will be outputed here        
--property <prop>                                                              
--skip-message-on-error                 If there is an error when processing a
                                          message, skip it instead of halt.    
--topic <topic>                         The topic id to consume on.            
--whitelist <whitelist>                 Whitelist of topics to include for     
                                          consumption.                         
--zookeeper <urls>                      REQUIRED: The connection string for    
                                          the zookeeper connection in the form
                                          host:port. Multiple URLS can be      
                                          given to allow fail-over.     
java


所以要同時啓動 多個不一樣組的消費者,要麼指定不一樣的配置文件,要麼設置不一樣的propertyapi

不過設置consumer.config 的試過了 --能夠用
this

可是property的只是在java api中用過 所以我感受這裏也能夠用(猜測)   

url

相關文章
相關標籤/搜索