@Service
public class KafkaConsumerService
extends java.lang.Object
Constructor and Description |
---|
KafkaConsumerService(Communication simulation) |
Modifier and Type | Method and Description |
---|---|
void |
toDriver(byte[] message) |
void |
toPassenger(byte[] message) |
@Autowired public KafkaConsumerService(Communication simulation)
@KafkaListener(topics="${kafka.topic.to-passenger}", groupId="passengers") public void toPassenger(@Payload byte[] message) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
@KafkaListener(topics="${kafka.topic.to-driver}", groupId="drivers") public void toDriver(@Payload byte[] message) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.