使用kafka-python api向主題發送一串消息。消息的一部分獲得成功發送到主題,但該方案與以下錯誤消息終止之前不是所有的人都送: KeyError: <kafka.producer.record_accumulator.RecordBatch object at 0x143d290>
Batch is already closed -- ignoring batch.done()
Er
我們有一個WinForm應用程序,它具有所有其他窗體繼承的基本窗體。 在基礎窗體上有一個Delete按鈕,Delete按鈕調用一個名爲DeleteData的虛擬bool方法。 public virtual void DeleteButton_Click(object sender, EventArgs e)
{
if (DeleteData())
{
// run