6
대용량 실시간 자바 웹 앱에서 나는 apache kafka에게 메시지를 보내고 있습니다. 현재 하나의 주제로 보내고 있지만 나중에 여러 주제로 메시지를 보내야 할 수도 있습니다.카프카에서 만드는 제작자는 몇 명입니까?
이 경우 필자는 주제별 제작자를 생성 할 날씨가 좋지 않거나 모든 주제에 대해 단일 제작자를 사용해야합니까? 당신이 볼 수 있듯이
props = new Properties();
props.put("zk.connect", <zk-ip1>:<2181>,<zk-ip3>:<2181>,<zk-ip3>:<2181>);
props.put("zk.connectiontimeout.ms", "1000000");
props.put("producer.type", "async");
Producer<String, Message> producer = new kafka.javaapi.producer.Producer<String, Message>(new ProducerConfig(props));
ProducerData<String, Message> producerData1 = new ProducerData<String, Message>("someTopic1", messageTosend);
ProducerData<String, Message> producerData2 = new ProducerData<String, Message>("someTopic2", messageTosend);
producer.send(producerData1);
producer.send(producerData2);
는, 생산자가 생성되면 내가 다른 주제로 데이터를 전송하는 데 사용할 수 있습니다 :
여기 내 코드입니다. 모범 사례가 무엇인지 궁금합니다. 내 앱이 여러 주제로 전송되는 경우 (각 주제마다 다른 데이터가 표시됨) 하나의 제작자를 사용할 수 있습니까? 아니면 여러 개의 제작자를 만들어야합니까? (일반적으로 말하면) 한 명 이상의 제작자를 사용해야합니까?