com.posco.reuse.kafka.clients
Class PosKafkaProducer

java.lang.Object
  com.posco.reuse.kafka.clients.PosKafkaProducer

All Implemented Interfaces:

InitializingBean

public class PosKafkaProducer
extends Object
implements InitializingBean

Kafka에 데이타를 송신해 주는 기능을 제공하는 클래스

  Bean Property
  
  - propertisMap : (필수) KafkaProducer에 필요한 property 값을 Map 형식으로 설정
  
  
  applicationContext.xml 사용 예
  
    <bean id="kafkaSender" class="com.posco.reuse.kafka.clients.PosKafkaProducer">
      <property name="propertiesMap">
        <map>
          <entry key="bootstrap.servers" value="192.168.193.141:9092,192.168.193.142:9092" />
        </map>
      </property>
    </bean>
 
 

Field Summary

protected org.slf4j.Logger

logger

Constructor Summary

PosKafkaProducer()

Method Summary

void	afterPropertiesSet()
void	sendMessage(String topic, byte[] message)
void	sendMessage(String topic, String id, byte[] message)
void	setPropertiesMap(Map<String,String> propertiesMap)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

protected final org.slf4j.Logger logger

Constructor Detail

PosKafkaProducer

public PosKafkaProducer()

Method Detail

setPropertiesMap

public void setPropertiesMap(Map<String,String> propertiesMap)

sendMessage

public void sendMessage(String topic,
                        byte[] message)

sendMessage

public void sendMessage(String topic,
                        String id,
                        byte[] message)

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

Exception