File tree Expand file tree Collapse file tree 2 files changed +6
-4
lines changed
Expand file tree Collapse file tree 2 files changed +6
-4
lines changed Original file line number Diff line number Diff line change @@ -78,6 +78,7 @@ class HeaderIterator {
7878 header_list_ = other.header_list_ ;
7979 header_ = make_header (other.header_ );
8080 index_ = other.index_ ;
81+ return *this ;
8182 }
8283 HeaderIterator (HeaderIterator&&) = default ;
8384 HeaderIterator& operator =(HeaderIterator&&) = default ;
Original file line number Diff line number Diff line change @@ -45,10 +45,11 @@ TopicPartitionsListPtr convert(const TopicPartitionList& topic_partitions) {
4545 TopicPartitionsListPtr handle (rd_kafka_topic_partition_list_new (topic_partitions.size ()),
4646 &rd_kafka_topic_partition_list_destroy);
4747 for (const auto & item : topic_partitions) {
48- rd_kafka_topic_partition_t * new_item = nullptr ;
49- new_item = rd_kafka_topic_partition_list_add (handle.get (),
50- item.get_topic ().data (),
51- item.get_partition ());
48+ rd_kafka_topic_partition_t * new_item = rd_kafka_topic_partition_list_add (
49+ handle.get (),
50+ item.get_topic ().data (),
51+ item.get_partition ()
52+ );
5253 new_item->offset = item.get_offset ();
5354 }
5455 return handle;
You can’t perform that action at this time.
0 commit comments