GithubStar/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-10-22 23:39:54 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #700 from wzl12356/master

Browse Source 
kafka: fix cgroup bug
This commit is contained in:
xiehan
2021-12-22 15:12:33 +08:00
committed by GitHub
parent 1247a44266 12f8a48818
commit ddf23e535f
2 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/factory/KafkaTaskImpl.cc
+4 -3
View File
@@ -421,9 +421,10 @@ bool __ComplexKafkaTask::process_join_group()
KafkaResponse *msg = this->get_resp();
if (!msg->get_cgroup()->get_coordinator()->is_to_addr())
{
const struct sockaddr *paddr;
socklen_t addrlen;
msg->get_broker()->get_broker_addr(&paddr, &addrlen);
struct sockaddr_storage addr;
socklen_t addrlen = sizeof addr;
const struct sockaddr *paddr = (const struct sockaddr *)&addr;
this->get_peer_addr((struct sockaddr *)&addr, &addrlen);
msg->get_cgroup()->get_coordinator()->set_broker_addr(paddr, addrlen);
msg->get_cgroup()->get_coordinator()->set_to_addr(1);
}
src/protocol/KafkaMessage.cc
+1 -1
View File
@@ -1135,7 +1135,7 @@ static int parse_varint_u64(void **buf, size_t *size, uint64_t *val)
do
{
if (*size - 1 == 0)
if (*size == 0)
{
*size = org_size;
errno = EBADMSG;