Skip to content

Commit 5a31f01

Browse files
committed
Correct C cast (confluentinc#10)
1 parent e735d05 commit 5a31f01

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka/config.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,7 @@ func (cConf *rdkConf) set(cKey *C.char, cVal *C.char, cErrstr *C.char, errstrSiz
124124
}
125125

126126
func (ctopicConf *rdkTopicConf) set(cKey *C.char, cVal *C.char, cErrstr *C.char, errstrSize int) C.rd_kafka_conf_res_t {
127-
return C.rd_kafka_topic_conf_set((*C.rd_kafka_conf_t)(ctopicConf), cKey, cVal, cErrstr, C.size_t(errstrSize))
127+
return C.rd_kafka_topic_conf_set((*C.rd_kafka_topic_conf_t)(ctopicConf), cKey, cVal, cErrstr, C.size_t(errstrSize))
128128
}
129129

130130
func configConvertAnyconf(m ConfigMap, anyconf rdkAnyconf) (err error) {

0 commit comments

Comments
 (0)