Signed-off-by: myan <[email protected]>
add message implementation
Signed-off-by: myan <[email protected]>
add ut test
Signed-off-by: myan <[email protected]>
add integration test
Signed-off-by: myan <[email protected]>
add integration test and samples
Signed-off-by: Meng Yan <[email protected]>
offset
Signed-off-by: Meng Yan <[email protected]>
remove the ctx
Signed-off-by: myan <[email protected]>
review
Signed-off-by: Meng Yan <[email protected]>
remove
Signed-off-by: Meng Yan <[email protected]>
init consumer and producer on 1 client
Signed-off-by: myan <[email protected]>
reply the reviews
Signed-off-by: myan <[email protected]>
fix the ci
Signed-off-by: myan <[email protected]>
ci fix
Signed-off-by: Meng Yan <[email protected]>
add confluent test in github action
Signed-off-by: Meng Yan <[email protected]>
add the mis-used test case
Signed-off-by: Meng Yan <[email protected]>
remove the invalidated bootstrapserver
Signed-off-by: Meng Yan <[email protected]>
log kafka error message
Signed-off-by: myan <[email protected]>
review
Signed-off-by: myan <[email protected]>
Update protocol/kafka_confluent/v2/option.go
Co-authored-by: Michael Gasch <[email protected]>
Signed-off-by: myan <[email protected]>
add the auto recover option
Signed-off-by: myan <[email protected]>
kafka error handler
Signed-off-by: myan <[email protected]>
remove the delievery chan
Signed-off-by: myan <[email protected]>
Update protocol/kafka_confluent/v2/protocol.go
Co-authored-by: Michael Gasch <[email protected]>
Update protocol/kafka_confluent/v2/protocol.go
Co-authored-by: Michael Gasch <[email protected]>
Update protocol/kafka_confluent/v2/option.go
Co-authored-by: Michael Gasch <[email protected]>
Update protocol/kafka_confluent/v2/protocol.go
Co-authored-by: Michael Gasch <[email protected]>
reply review
Signed-off-by: myan <[email protected]>
modify the git action
Signed-off-by: Meng Yan <[email protected]>
reply review
Signed-off-by: Meng Yan <[email protected]>
reply review
Signed-off-by: Meng Yan <[email protected]>
handle race condition between sender and closer
Signed-off-by: Meng Yan <[email protected]>
reply review
Signed-off-by: Meng Yan <[email protected]>
reply review1
Signed-off-by: Meng Yan <[email protected]>
add defer close
Signed-off-by: Meng Yan <[email protected]>
add comment
Signed-off-by: Meng Yan <[email protected]>