Skip to main content

Kafka Comands

Starting Zookeeper 

C:\kafka_2.12-2.4\kafka_2.12-2.4.0\bin\windows>zookeeper-server-start C:\kafka_2.12-2.4\kafka_2.12-2.4.0\config\zookeeper.properties

Starting Kafka server

C:\ Kafka\ kafka-server-start.bat C:\kafka_2.12-2.4\kafka_2.12-2.4.0\config\server.properties

Creating topics

C:\Users\AnilBalwani>kafka-topics --zookeeper 127.0.0.1:2181 --topic test_topic --create --partitions 3 --replication-factor 1
WARNING: Due to limitations in metric names, topics with a period ('.') or underscore ('_') could collide. To avoid issues it is best to use either, but not both.
Created topic test_topic.
C:\Users\AnilBalwani>


List topics

C:\Users\AnilBalwani>kafka-topics --zookeeper 127.0.0.1:2181 --list
test_topic


Kafka Information about topics

C:\Users\AnilBalwani>kafka-topics --zookeeper 127.0.0.1:2181 --topic test_topic --describe
Topic: test_topic      PartitionCount: 3       ReplicationFactor: 1    Configs:
        Topic: test_topic      Partition: 0    Leader: 0       Replicas: 0     Isr: 0
        Topic: test_topic      Partition: 1    Leader: 0       Replicas: 0     Isr: 0
        Topic: test_topic      Partition: 2    Leader: 0       Replicas: 0     Isr: 0












Comments

Post a Comment

Popular posts from this blog

Maximo Interview Questions - Maximo Technical and Functional Questions

Technical Questions How do you rate your self in :- 1. PL/SQL 2. Java 3. Automation Script 4. Mbo Customization 5. Admininstration Jobs 6. Funtional Concepts 7. Maximo Configuration Do not rate anything less than 7 unless you don't want interview to skip the topic Deployment / Administration  1. Explain LDAP integration? 2. Explain SSO and LTPA token? 3. What is global security? 4. How session is managed in Websphere or Maximo? 16. How to insert attributes from Backend? 5. How request is passed in Maximo? 6. How to do horizontal and vertical clustering? 7. Explain how you confire websphere for maximo manually? 8. What are Websphere MQ? 9. What is JMS, Connection Factory and Queues? 10. What is difference between vmm and ldap sync integration ? 11. What is Standalone and federated repository? 12. How to install a new language in Maximo? 13. What are the steps to apply a Fix pack in Maximo, Websphere or DB2? 14. Have you worked on any performance checking tools? 15...
3 comments
Read more

Maximo Bean Class Methods

Methods of Bean Classes of Maximo Reset Method   This method is called when a new filter is applied for the dialog's MboSet.  @see psdi.webclient.system.beans.DataBean#reset()     @Override     public void reset() throws MXException     {             try         {                 saveCurrentSelection();         }         catch (RemoteException e)         {             handleRemoteException(e);         }         super.reset();     } Initialize It is used to initialize values on a d...
3 comments
Read more

Integration Control

Integration control used in making conditions for processing  provides a way to match xml field or object field with particular value. We have 4 types of integration control 1. Value 2.List 3. XRef 4.Boolean Value control is used to compare with single value. List control is used to compare with list of values which may come from domains. Boolean control is true or false value used to compare yorn field I personally never used it. XRef control i.e cross reference control is used to to swap values foe example we have different orgid in other system than we can define cross reference control inorder to translate. We create cross reference control and associate it with enterprise service or publish channel. We can also override these values at external system level.
2 comments
Read more