73         rd_kafka_topic_partition_t *rktpar; /**< Back-pointer to the  member
153 create_transactional_producer (const rd_kafka_topic_partition_t *rktpar) {  in create_transactional_producer()  argument
162                  rktpar->topic, rktpar->partition);  in create_transactional_producer()
231                                                    state->rktpar->topic, NULL);  in abort_transaction_and_rewind()
238                 state->rktpar->topic, state->rktpar->partition);  in abort_transaction_and_rewind()
253                                           state->rktpar->topic,  in abort_transaction_and_rewind()
254                                           state->rktpar->partition);  in abort_transaction_and_rewind()
260                       state->rktpar->topic, (int)state->rktpar->partition,  in abort_transaction_and_rewind()
265         err = rd_kafka_seek(rkt, state->rktpar->partition,  in abort_transaction_and_rewind()
275                       state->rktpar->topic, (int)state->rktpar->partition,  in abort_transaction_and_rewind()
292                 state->rktpar->topic, state->rktpar->partition);  in commit_transaction_and_start_new()
305                                           state->rktpar->topic,  in commit_transaction_and_start_new()
306                                           state->rktpar->partition);  in commit_transaction_and_start_new()
310                       state->rktpar->topic, state->rktpar->partition,  in commit_transaction_and_start_new()
389                         rd_kafka_topic_partition_t *rktpar =  in consumer_group_rebalance_cb()  local
393                         state->producer = create_transactional_producer(rktpar);  in consumer_group_rebalance_cb()
394                         state->rktpar = rktpar;  in consumer_group_rebalance_cb()
395                         rktpar->opaque = state;  in consumer_group_rebalance_cb()
400                                 rktpar->topic, rktpar->partition,  in consumer_group_rebalance_cb()
618                 rd_kafka_topic_partition_t *rktpar;  in main()  local
638                 rktpar = rd_kafka_topic_partition_list_find(  in main()
641                 if (!rktpar)  in main()
648                 state = (struct state *)rktpar->opaque;  in main()