This repository was archived by the owner on Feb 23, 2023. It is now read-only.
Commit b608e32 1 parent e9d6002 commit b608e32 Copy full SHA for b608e32
File tree 3 files changed +11
-14
lines changed
src/main/java/com/example/kafka
3 files changed +11
-14
lines changed Original file line number Diff line number Diff line change 1
1
version : ' 3'
2
2
services :
3
- zookeeper :
4
- image : wurstmeister/zookeeper
5
- ports :
6
- - ' 2181:2181'
7
3
kafka :
8
4
image : wurstmeister/kafka
9
5
ports :
10
- - ' 9092:9092'
11
- depends_on :
12
- - zookeeper
6
+ - " 9092:9092"
13
7
environment :
8
+ - KAFKA_ADVERTISED_HOST_NAME=127.0.0.1
9
+ - KAFKA_ADVERTISED_PORT=9092
14
10
- KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
15
- - KAFKA_ADVERTISED_HOST_NAME=kafka
16
- kafka-sample :
17
- image : kafka:0.0.1-SNAPSHOT
18
11
depends_on :
19
- - kafka
12
+ - zookeeper
13
+ zookeeper :
14
+ image : wurstmeister/zookeeper
15
+ ports :
16
+ - " 2181:2181"
20
17
environment :
21
- - SPRING_KAFKA_BOOTSTRAP_SERVERS=kafka:9092
18
+ - KAFKA_ADVERTISED_HOST_NAME=zookeeper
Original file line number Diff line number Diff line change @@ -25,7 +25,7 @@ public static void main(String[] args) {
25
25
26
26
@ KafkaListener (id = "graal" , topics = "graal" )
27
27
public void listen (Greeting in ) {
28
- System .out .println ("++++++Received:" + in );
28
+ System .out .println ("++++++Received: " + in );
29
29
}
30
30
31
31
@ Bean
Original file line number Diff line number Diff line change 1
1
#! /usr/bin/env bash
2
2
sleep 2
3
- if [[ ` cat target/native/test-output.txt | grep " ++++++Received:foo " ` ]]; then
3
+ if [[ ` cat target/native/test-output.txt | grep " ++++++Received: Greeting{message='Hello from GraalVM!'} " ` ]]; then
4
4
exit 0
5
5
else
6
6
exit 1
You can’t perform that action at this time.
0 commit comments