(transactionalID string)
| 153 | } |
| 154 | |
| 155 | func emptyToNullable(transactionalID string) (result *string) { |
| 156 | if transactionalID != "" { |
| 157 | result = &transactionalID |
| 158 | } |
| 159 | return result |
| 160 | } |
| 161 | |
| 162 | // NewConnWith returns a new kafka connection configured with config. |
| 163 | // The offset is initialized to FirstOffset. |
no outgoing calls