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